[
https://issues.apache.org/jira/browse/FLINK-10306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16610165#comment-16610165
]
Jiayi Liao commented on FLINK-10306:
[~zhangxinyu] It makes sense. I think you can d
[
https://issues.apache.org/jira/browse/FLINK-10002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiayi Liao reassigned FLINK-10002:
--
Assignee: zhangxinyu (was: Jiayi Liao)
> WebUI shows logs unfriendly, especially when the am
[
https://issues.apache.org/jira/browse/FLINK-10002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiayi Liao reassigned FLINK-10002:
--
Assignee: Jiayi Liao (was: zhangxinyu)
> WebUI shows logs unfriendly, especially when the am
[
https://issues.apache.org/jira/browse/FLINK-10310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16610162#comment-16610162
]
Till Rohrmann commented on FLINK-10310:
---
Having something similar to the {{ActionR
[
https://issues.apache.org/jira/browse/FLINK-10306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16610151#comment-16610151
]
zhangxinyu commented on FLINK-10306:
Ah, I think we can combine our ideas. For examp
[
https://issues.apache.org/jira/browse/FLINK-10255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16610117#comment-16610117
]
ASF GitHub Bot commented on FLINK-10255:
TisonKun commented on issue #6678: [FLI
TisonKun commented on issue #6678: [FLINK-10255] Only react to onAddedJobGraph
signal when being leader
URL: https://github.com/apache/flink/pull/6678#issuecomment-420151979
Travis show relevant failures, will take a close look later.
```
testGrantingRevokingLeadership(org.apache
[
https://issues.apache.org/jira/browse/FLINK-10255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16610111#comment-16610111
]
ASF GitHub Bot commented on FLINK-10255:
TisonKun commented on a change in pull
TisonKun commented on a change in pull request #6678: [FLINK-10255] Only react
to onAddedJobGraph signal when being leader
URL: https://github.com/apache/flink/pull/6678#discussion_r216548720
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/akka/ActorUtils.java
#
[
https://issues.apache.org/jira/browse/FLINK-10002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai reassigned FLINK-10002:
---
Assignee: zhangxinyu
> WebUI shows logs unfriendly, especially when the amo
[
https://issues.apache.org/jira/browse/FLINK-10223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16610076#comment-16610076
]
ASF GitHub Bot commented on FLINK-10223:
Aitozi commented on issue #6679: [FLINK
Aitozi commented on issue #6679: [FLINK-10223][LOG]Logging with resourceId
during taskmanager startup
URL: https://github.com/apache/flink/pull/6679#issuecomment-420133979
cc @GJL
This is an automated message from the Apache
[
https://issues.apache.org/jira/browse/FLINK-10002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16610059#comment-16610059
]
zhangxinyu commented on FLINK-10002:
[~wind_ljy] Thanks for your suggestions.
# We
[
https://issues.apache.org/jira/browse/FLINK-10002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16610028#comment-16610028
]
Jiayi Liao commented on FLINK-10002:
[~zhangxinyu] Thanks for your idea, but I don't
[
https://issues.apache.org/jira/browse/FLINK-10135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16610023#comment-16610023
]
vinoyang commented on FLINK-10135:
--
[~PedroMrChaves] thanks for details, I am processin
[
https://issues.apache.org/jira/browse/FLINK-10284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16610022#comment-16610022
]
Jiayi Liao commented on FLINK-10284:
[~hequn8128] You're right...Thanks.
> Tumbling
[
https://issues.apache.org/jira/browse/FLINK-10284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16609987#comment-16609987
]
Hequn Cheng commented on FLINK-10284:
-
[~wind_ljy] Thanks for reporting the issue.
[
https://issues.apache.org/jira/browse/FLINK-10223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16609935#comment-16609935
]
aitozi commented on FLINK-10223:
[~gjy]I have pushed the PR, could help take a look plea
Aitozi opened a new pull request #6679: [FLINK-10223][LOG]Logging with
resourceId during taskmanager startup
URL: https://github.com/apache/flink/pull/6679
## What is the purpose of the change
Log the resourceId during taskmanager startup to help with find the specific
taskmanager w
[
https://issues.apache.org/jira/browse/FLINK-10223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16609933#comment-16609933
]
ASF GitHub Bot commented on FLINK-10223:
Aitozi opened a new pull request #6679:
[
https://issues.apache.org/jira/browse/FLINK-10223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10223:
---
Labels: pull-request-available (was: )
> TaskManagers should log their ResourceID during st
Joseph Sims created FLINK-10316:
---
Summary: Kinesalite bug fix (FLINK-9402) doesn't fully fix the
problem.
Key: FLINK-10316
URL: https://issues.apache.org/jira/browse/FLINK-10316
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-10184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16609778#comment-16609778
]
William Cummings commented on FLINK-10184:
--
I've got flink building locally alr
[
https://issues.apache.org/jira/browse/FLINK-10135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16609650#comment-16609650
]
Pedro Miguel Rainho Chaves commented on FLINK-10135:
I'm currently o
[
https://issues.apache.org/jira/browse/FLINK-9523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16609625#comment-16609625
]
ASF GitHub Bot commented on FLINK-9523:
---
SokolovMS commented on issue #6672: [FLINK
SokolovMS commented on issue #6672: [FLINK-9523] [table] Add Kafka examples for
Flink Table/SQL API
URL: https://github.com/apache/flink/pull/6672#issuecomment-420008214
Merged from master. FlinkException disappeared.
This is
[
https://issues.apache.org/jira/browse/FLINK-10284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16609448#comment-16609448
]
Jiayi Liao commented on FLINK-10284:
[~hequn8128] Actually not, the window start wil
yanghua commented on issue #6672: [FLINK-9523] [table] Add Kafka examples for
Flink Table/SQL API
URL: https://github.com/apache/flink/pull/6672#issuecomment-419966647
hi @SokolovMS thanks for your contribution. Firstly, please fix the
checkstyle error:
```
ERROR]
src/main/java
[
https://issues.apache.org/jira/browse/FLINK-9523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16609441#comment-16609441
]
ASF GitHub Bot commented on FLINK-9523:
---
yanghua commented on issue #6672: [FLINK-9
[
https://issues.apache.org/jira/browse/FLINK-10247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16609426#comment-16609426
]
ASF GitHub Bot commented on FLINK-10247:
yanghua commented on a change in pull r
[
https://issues.apache.org/jira/browse/FLINK-10247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16609424#comment-16609424
]
ASF GitHub Bot commented on FLINK-10247:
yanghua commented on a change in pull r
[
https://issues.apache.org/jira/browse/FLINK-10247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16609425#comment-16609425
]
ASF GitHub Bot commented on FLINK-10247:
yanghua commented on a change in pull r
[
https://issues.apache.org/jira/browse/FLINK-10247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16609423#comment-16609423
]
ASF GitHub Bot commented on FLINK-10247:
yanghua commented on a change in pull r
yanghua commented on a change in pull request #6676: [FLINK-10247][Metrics] Run
MetricQueryService in separate thread pool
URL: https://github.com/apache/flink/pull/6676#discussion_r216375912
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/metrics/dump/MetricQuer
yanghua commented on a change in pull request #6676: [FLINK-10247][Metrics] Run
MetricQueryService in separate thread pool
URL: https://github.com/apache/flink/pull/6676#discussion_r216374948
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/metrics/dump/MetricQuer
yanghua commented on a change in pull request #6676: [FLINK-10247][Metrics] Run
MetricQueryService in separate thread pool
URL: https://github.com/apache/flink/pull/6676#discussion_r216376586
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/metrics/dump/MetricQuer
yanghua commented on a change in pull request #6676: [FLINK-10247][Metrics] Run
MetricQueryService in separate thread pool
URL: https://github.com/apache/flink/pull/6676#discussion_r216376070
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/metrics/dump/MetricQuer
yanghua commented on issue #6677: [hotfix] [kubernetes] correct exception typo
URL: https://github.com/apache/flink/pull/6677#issuecomment-419959405
+1
This is an automated message from the Apache Git Service.
To respond to th
[
https://issues.apache.org/jira/browse/FLINK-10258?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16609403#comment-16609403
]
ASF GitHub Bot commented on FLINK-10258:
yanghua commented on issue #6675: [FLIN
yanghua commented on issue #6675: [FLINK-10258][Sql Client] Allow streaming
sources to be present for batch executions
URL: https://github.com/apache/flink/pull/6675#issuecomment-419958704
hi @hequn8128 if you have time, can you review this PR? thanks~
-
[
https://issues.apache.org/jira/browse/FLINK-10284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16609385#comment-16609385
]
Hequn Cheng commented on FLINK-10284:
-
[~wind_ljy] Thanks for pointing this out. I t
[
https://issues.apache.org/jira/browse/FLINK-10315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-10315:
Assignee: vinoyang
> Let JDBCAppendTableSink be built with java.sql.Connection
>
[
https://issues.apache.org/jira/browse/FLINK-10184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16609299#comment-16609299
]
Thomas Wozniakowski commented on FLINK-10184:
-
Hey [~till.rohrmann] - this m
[
https://issues.apache.org/jira/browse/FLINK-10284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16609274#comment-16609274
]
Jiayi Liao edited comment on FLINK-10284 at 9/10/18 2:13 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-10284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16609274#comment-16609274
]
Jiayi Liao commented on FLINK-10284:
[~hequn8128] I'm afraid that the example can't
[
https://issues.apache.org/jira/browse/FLINK-10284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16609248#comment-16609248
]
Hequn Cheng commented on FLINK-10284:
-
Hi [~wind_ljy], this is already supported in
[
https://issues.apache.org/jira/browse/FLINK-10184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16609227#comment-16609227
]
Till Rohrmann commented on FLINK-10184:
---
I have a fix for FLINK-10255. Could you t
François Lacombe created FLINK-10315:
Summary: Let JDBCAppendTableSink be built with java.sql.Connection
Key: FLINK-10315
URL: https://issues.apache.org/jira/browse/FLINK-10315
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-6522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16609205#comment-16609205
]
Ufuk Celebi edited comment on FLINK-6522 at 9/10/18 1:39 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-6522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16609205#comment-16609205
]
Ufuk Celebi commented on FLINK-6522:
[~till.rohrmann] I think I ran into this issue a
[
https://issues.apache.org/jira/browse/FLINK-10245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16609201#comment-16609201
]
Hequn Cheng commented on FLINK-10245:
-
You are right, we can add a scheduler to flus
[
https://issues.apache.org/jira/browse/FLINK-10255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10255:
---
Labels: pull-request-available (was: )
> Standby Dispatcher locks submitted JobGraphs
> ---
[
https://issues.apache.org/jira/browse/FLINK-10255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16609200#comment-16609200
]
ASF GitHub Bot commented on FLINK-10255:
tillrohrmann opened a new pull request
tillrohrmann opened a new pull request #6678: [FLINK-10255] Only react to
onAddedJobGraph signal when being leader
URL: https://github.com/apache/flink/pull/6678
## What is the purpose of the change
The Dispatcher should only react to the onAddedJobGraph signal if it is the
leader.
[
https://issues.apache.org/jira/browse/FLINK-10229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16609134#comment-16609134
]
ASF GitHub Bot commented on FLINK-10229:
hequn8128 commented on issue #6631: [FL
hequn8128 commented on issue #6631: [FLINK-10229] [sql-client] Support listing
of views
URL: https://github.com/apache/flink/pull/6631#issuecomment-419901914
Hi @yanghua , thanks for your update. The PR looks good. +1 to merge from my
side.
Best, Hequn
-
[
https://issues.apache.org/jira/browse/FLINK-10299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16608810#comment-16608810
]
ambition edited comment on FLINK-10299 at 9/10/18 12:51 PM:
[
https://issues.apache.org/jira/browse/FLINK-9735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16609119#comment-16609119
]
ASF GitHub Bot commented on FLINK-9735:
---
yanghua commented on issue #6660: [FLINK-9
yanghua commented on issue #6660: [FLINK-9735] Potential resource leak in
RocksDBStateBackend#getDbOptions
URL: https://github.com/apache/flink/pull/6660#issuecomment-419897753
@StefanRRichter thank you. The title does not indicate its intent, because
it was created by someone else, so I d
[
https://issues.apache.org/jira/browse/FLINK-9735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-9735.
-
Resolution: Fixed
Merged in:
master: 1a94c2094b
> Potential resource leak in RocksDBStateBackend
[
https://issues.apache.org/jira/browse/FLINK-9735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16609109#comment-16609109
]
ASF GitHub Bot commented on FLINK-9735:
---
asfgit closed pull request #6660: [FLINK-9
asfgit closed pull request #6660: [FLINK-9735] Potential resource leak in
RocksDBStateBackend#getDbOptions
URL: https://github.com/apache/flink/pull/6660
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provena
[
https://issues.apache.org/jira/browse/FLINK-9735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16609097#comment-16609097
]
ASF GitHub Bot commented on FLINK-9735:
---
StefanRRichter commented on issue #6660: [
StefanRRichter commented on issue #6660: [FLINK-9735] Potential resource leak
in RocksDBStateBackend#getDbOptions
URL: https://github.com/apache/flink/pull/6660#issuecomment-419893355
Hi, the title of the PR is very misleading. This is not about any leak in
the backend, this is just about
[
https://issues.apache.org/jira/browse/FLINK-10311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao reassigned FLINK-10311:
Assignee: Gary Yao
> HA end-to-end/Jepsen tests for standby Dispatchers
> ---
[
https://issues.apache.org/jira/browse/FLINK-9735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16609090#comment-16609090
]
ASF GitHub Bot commented on FLINK-9735:
---
yanghua commented on issue #6660: [FLINK-9
yanghua commented on issue #6660: [FLINK-9735] Potential resource leak in
RocksDBStateBackend#getDbOptions
URL: https://github.com/apache/flink/pull/6660#issuecomment-419891656
@pnowojski can you review this PR?
This is an au
[
https://issues.apache.org/jira/browse/FLINK-8819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16609082#comment-16609082
]
ASF GitHub Bot commented on FLINK-8819:
---
GJL commented on a change in pull request
GJL commented on a change in pull request #6642: [FLINK-8819][travis] Rework
travis script to use stages
URL: https://github.com/apache/flink/pull/6642#discussion_r216296870
##
File path: tools/travis_controller.sh
##
@@ -0,0 +1,211 @@
+#!/usr/bin/env bash
+###
[
https://issues.apache.org/jira/browse/FLINK-10122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16609077#comment-16609077
]
ASF GitHub Bot commented on FLINK-10122:
StefanRRichter closed pull request #653
StefanRRichter closed pull request #6537: [FLINK-10122] KafkaConsumer should
use partitionable state over union state if partition discovery is not active
URL: https://github.com/apache/flink/pull/6537
This is a PR merged from a forked repository.
As GitHub hides the original diff on merg
StefanRRichter commented on issue #6604: [FLINK-9061] Optionally add entropy to
checkpoint paths better S3 scalability
URL: https://github.com/apache/flink/pull/6604#issuecomment-41930
👍 from my side in case you were waiting for that ;-)
---
[
https://issues.apache.org/jira/browse/FLINK-9061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16609074#comment-16609074
]
ASF GitHub Bot commented on FLINK-9061:
---
StefanRRichter commented on issue #6604: [
[
https://issues.apache.org/jira/browse/FLINK-10198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16609069#comment-16609069
]
ASF GitHub Bot commented on FLINK-10198:
StefanRRichter closed pull request #660
StefanRRichter closed pull request #6603: [FLINK-10198][state] Set Env object
in DBOptions for RocksDB
URL: https://github.com/apache/flink/pull/6603
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
[
https://issues.apache.org/jira/browse/FLINK-10203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16609066#comment-16609066
]
ASF GitHub Bot commented on FLINK-10203:
art4ul commented on issue #6608: [FLINK
art4ul commented on issue #6608: [FLINK-10203]Support truncate method for old
Hadoop versions in HadoopRecoverableFsDataOutputStream
URL: https://github.com/apache/flink/pull/6608#issuecomment-419887998
Hi guys! Maybe there are some comments regarding this PR? I would like to
continue disc
[
https://issues.apache.org/jira/browse/FLINK-7964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16609038#comment-16609038
]
ASF GitHub Bot commented on FLINK-7964:
---
yanghua commented on issue #6577: [FLINK-7
yanghua commented on issue #6577: [FLINK-7964] Add Apache Kafka 1.0/1.1
connectors
URL: https://github.com/apache/flink/pull/6577#issuecomment-419881220
@pnowojski OK, I also claimed
[FLINK-9697](https://issues.apache.org/jira/browse/FLINK-9697), which is about
Flink kafka connection 2.0.
[
https://issues.apache.org/jira/browse/FLINK-9682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16609028#comment-16609028
]
ASF GitHub Bot commented on FLINK-9682:
---
yanghua commented on a change in pull requ
yanghua commented on a change in pull request #6266: [FLINK-9682] Add
setDescription to execution environment and provide description field for the
rest api
URL: https://github.com/apache/flink/pull/6266#discussion_r216284722
##
File path:
flink-core/src/main/java/org/apache/flink
[
https://issues.apache.org/jira/browse/FLINK-8954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16609025#comment-16609025
]
Dmitry Amosov commented on FLINK-8954:
--
[~twalthr] I'm sorry about that. I've been q
[
https://issues.apache.org/jira/browse/FLINK-10247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16609013#comment-16609013
]
Shimin Yang commented on FLINK-10247:
-
[~till.rohrmann] It could be a good way to de
[
https://issues.apache.org/jira/browse/FLINK-8098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16608991#comment-16608991
]
Henrique Barros commented on FLINK-8098:
It happens on flink 1.3.2. I tried with
TisonKun opened a new pull request #6677: [hotfix] [kubernetes] correct
exception typo
URL: https://github.com/apache/flink/pull/6677
as title @GJL @NicoK
This is an automated message from the Apache Git Service.
To respond
[
https://issues.apache.org/jira/browse/FLINK-10131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber resolved FLINK-10131.
-
Resolution: Fixed
Fix Version/s: 1.5.4
1.7.0
1.6.1
[
https://issues.apache.org/jira/browse/FLINK-10131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16608918#comment-16608918
]
ASF GitHub Bot commented on FLINK-10131:
NicoK closed pull request #6547: [FLINK
NicoK closed pull request #6547: [FLINK-10131][network] improve logging around
subpartitions
URL: https://github.com/apache/flink/pull/6547
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this
[
https://issues.apache.org/jira/browse/FLINK-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16608917#comment-16608917
]
Sebastian Klemke commented on FLINK-9891:
-
[~azagrebin] It's not only parsing log
[
https://issues.apache.org/jira/browse/FLINK-10301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16608915#comment-16608915
]
ASF GitHub Bot commented on FLINK-10301:
NicoK commented on a change in pull req
NicoK commented on a change in pull request #6670: [FLINK-10301][network]
extend StreamNetworkBenchmarkEnvironment to allow custom Configuration instances
URL: https://github.com/apache/flink/pull/6670#discussion_r216249203
##
File path:
flink-streaming-java/src/test/java/org/apach
[
https://issues.apache.org/jira/browse/FLINK-9682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16608914#comment-16608914
]
ASF GitHub Bot commented on FLINK-9682:
---
dawidwys commented on a change in pull req
dawidwys commented on a change in pull request #6266: [FLINK-9682] Add
setDescription to execution environment and provide description field for the
rest api
URL: https://github.com/apache/flink/pull/6266#discussion_r216248829
##
File path:
flink-core/src/main/java/org/apache/flin
[
https://issues.apache.org/jira/browse/FLINK-10247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10247:
---
Labels: pull-request-available (was: )
> Run MetricQueryService in separate thread pool
> -
[
https://issues.apache.org/jira/browse/FLINK-10247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16608905#comment-16608905
]
ASF GitHub Bot commented on FLINK-10247:
Clark opened a new pull request #66
Clark opened a new pull request #6676: [FLINK-10247][Metrics] Run
MetricQueryService in separate thread pool
URL: https://github.com/apache/flink/pull/6676
## What is the purpose of the change
Introduce a dedicated thread pool for MetricQueryService to process messages.
azagrebin commented on a change in pull request #6567: [FLINK-10074] Allowable
number of checkpoint failures
URL: https://github.com/apache/flink/pull/6567#discussion_r216242682
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.jav
[
https://issues.apache.org/jira/browse/FLINK-10074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16608886#comment-16608886
]
ASF GitHub Bot commented on FLINK-10074:
azagrebin commented on a change in pull
[
https://issues.apache.org/jira/browse/FLINK-10312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-10312:
--
Fix Version/s: 1.5.4
1.7.0
1.6.1
> Wrong / missing excep
[
https://issues.apache.org/jira/browse/FLINK-10314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-10314:
--
Fix Version/s: 1.5.4
1.7.0
1.6.1
> Blocking calls in Exe
1 - 100 of 135 matches
Mail list logo
