[jira] [Commented] (FLINK-19028) Translate the "application_parameters.zh.md" into Chinese

2020-10-06 Thread fanyuexiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17209302#comment-17209302 ] fanyuexiang commented on FLINK-19028: - This is the first time i join the flink community,Please

[jira] [Commented] (FLINK-19497) Implement mutator methods for FlinkCounterWrapper

2020-10-06 Thread Richard Moorhead (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17209262#comment-17209262 ] Richard Moorhead commented on FLINK-19497: -- A better question might be: is a patch release

[jira] [Updated] (FLINK-19517) Support for Confluent Kafka of Table Creation in Flink SQL Client

2020-10-06 Thread Kevin Kwon (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Kwon updated FLINK-19517: --- Description: Currently, table creation from SQL client such as below works well {code:sql} CREATE

[jira] [Updated] (FLINK-19517) Support for Confluent Kafka of Table Creation in Flink SQL Client

2020-10-06 Thread Kevin Kwon (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Kwon updated FLINK-19517: --- Description: Currently, table creation from SQL client such as below works well {code:sql} CREATE

[jira] [Updated] (FLINK-19517) Support for Confluent Kafka of Table Creation in Flink SQL Client

2020-10-06 Thread Kevin Kwon (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Kwon updated FLINK-19517: --- Description: Currently, table creation from SQL client such as below works well {code:sql} CREATE

[jira] [Updated] (FLINK-19517) Support for Confluent Kafka of Table Creation in Flink SQL Client

2020-10-06 Thread Kevin Kwon (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Kwon updated FLINK-19517: --- Description: Currently, table creation from SQL client such as below works well {code:sql} CREATE

[jira] [Updated] (FLINK-19517) Support for Confluent Kafka of Table Creation in Flink SQL Client

2020-10-06 Thread Kevin Kwon (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Kwon updated FLINK-19517: --- Summary: Support for Confluent Kafka of Table Creation in Flink SQL Client (was: Support for

[jira] [Updated] (FLINK-19517) Support for Confluent Kafka on table creation

2020-10-06 Thread Kevin Kwon (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Kwon updated FLINK-19517: --- Description: Currently, table creation from SQL client such as below works well {code:sql} CREATE

[jira] [Created] (FLINK-19517) Support for Confluent Kafka on table creation

2020-10-06 Thread Kevin Kwon (Jira)
Kevin Kwon created FLINK-19517: -- Summary: Support for Confluent Kafka on table creation Key: FLINK-19517 URL: https://issues.apache.org/jira/browse/FLINK-19517 Project: Flink Issue Type: Wish

[GitHub] [flink] flinkbot edited a comment on pull request #13351: [FLINK-18990][task] Read channel state sequentially

2020-10-06 Thread GitBox
flinkbot edited a comment on pull request #13351: URL: https://github.com/apache/flink/pull/13351#issuecomment-688741492 ## CI report: * ec6d68e0c67f14994082adb24e4f86dd599fc9f0 Azure:

[GitHub] [flink] lvhuyen commented on pull request #6613: [FLINK-9940] [API/DataStream][File source] out-of-order files were missed in continuous monitoring

2020-10-06 Thread GitBox
lvhuyen commented on pull request #6613: URL: https://github.com/apache/flink/pull/6613#issuecomment-704578210 Thanks @guoweiM. Please give me a bit more time to arrange my time working on this PR. This is an automated

[GitHub] [flink] flinkbot edited a comment on pull request #13351: [FLINK-18990][task] Read channel state sequentially

2020-10-06 Thread GitBox
flinkbot edited a comment on pull request #13351: URL: https://github.com/apache/flink/pull/13351#issuecomment-688741492 ## CI report: * 5f4afd19fde91ffe545666daffd8953b126de7bf Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13351: [FLINK-18990][task] Read channel state sequentially

2020-10-06 Thread GitBox
flinkbot edited a comment on pull request #13351: URL: https://github.com/apache/flink/pull/13351#issuecomment-688741492 ## CI report: * 5f4afd19fde91ffe545666daffd8953b126de7bf Azure:

[GitHub] [flink] tillrohrmann commented on a change in pull request #13313: [FLINK-18722][mesos] Migrate MesosResourceManager to the new MesosResourceManagerDriver

2020-10-06 Thread GitBox
tillrohrmann commented on a change in pull request #13313: URL: https://github.com/apache/flink/pull/13313#discussion_r500423676 ## File path: flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManager.java ## @@ -882,7 +820,7 @@ public

[GitHub] [flink] flinkbot edited a comment on pull request #13544: [FLINK-19309][coordination] Add TaskExecutorManager

2020-10-06 Thread GitBox
flinkbot edited a comment on pull request #13544: URL: https://github.com/apache/flink/pull/13544#issuecomment-704178057 ## CI report: * bbba3f53abb4d4d6c220f8a87fa31c395d5c4f86 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13540: [FLINK-19344] Fix DispatcherResourceCleanupTest race condition

2020-10-06 Thread GitBox
flinkbot edited a comment on pull request #13540: URL: https://github.com/apache/flink/pull/13540#issuecomment-703484500 ## CI report: * 8842d1927613cdcd09f4e6c671c9cb1dc671269e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13351: [FLINK-18990][task] Read channel state sequentially

2020-10-06 Thread GitBox
flinkbot edited a comment on pull request #13351: URL: https://github.com/apache/flink/pull/13351#issuecomment-688741492 ## CI report: * 5f4afd19fde91ffe545666daffd8953b126de7bf Azure:

[jira] [Commented] (FLINK-19515) Async RequestReply handler concurrency bug

2020-10-06 Thread Igal Shilman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17209119#comment-17209119 ] Igal Shilman commented on FLINK-19515: -- Hi, I think that you are correct, and it does seems like a

[GitHub] [flink] flinkbot edited a comment on pull request #13549: [FLINK-18660] Bump flink-shaded to 1.12; Bump netty to 4.1.49

2020-10-06 Thread GitBox
flinkbot edited a comment on pull request #13549: URL: https://github.com/apache/flink/pull/13549#issuecomment-704349970 ## CI report: * aa06dc0c462dcba26088f707a33e3d724df53023 Azure:

[jira] [Commented] (FLINK-15578) Implement exactly-once JDBC sink

2020-10-06 Thread Kenzyme Le (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17209035#comment-17209035 ] Kenzyme Le commented on FLINK-15578: Thank you for the update [~roman_khachatryan] . I'll look into

[GitHub] [flink] GJL commented on a change in pull request #6464: [FLINK-9936][mesos] Mesos resource manager unable to connect to master after failover

2020-10-06 Thread GitBox
GJL commented on a change in pull request #6464: URL: https://github.com/apache/flink/pull/6464#discussion_r500526730 ## File path: flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManager.java ## @@ -794,7 +828,7 @@ public void run() {

[jira] [Updated] (FLINK-19474) Implement a state backend that holds a single key at a time

2020-10-06 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19474: --- Labels: pull-request-available (was: ) > Implement a state backend that holds a single key

[GitHub] [flink] flinkbot edited a comment on pull request #13550: [FLINK-19474] Implement a state backend that holds a single key at a time

2020-10-06 Thread GitBox
flinkbot edited a comment on pull request #13550: URL: https://github.com/apache/flink/pull/13550#issuecomment-704399024 ## CI report: * 5e658efd970cd23de2637876e59becdbf00a8921 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13529: [FLINK-19473] Implement multi inputs sorting DataInput

2020-10-06 Thread GitBox
flinkbot edited a comment on pull request #13529: URL: https://github.com/apache/flink/pull/13529#issuecomment-702193043 ## CI report: * 055e55a0e4e55637a5896a173939e00e6991abe4 Azure:

[jira] [Commented] (FLINK-19497) Implement mutator methods for FlinkCounterWrapper

2020-10-06 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17209011#comment-17209011 ] Chesnay Schepler commented on FLINK-19497: -- I would be hesitant since it is conceivable that it

[GitHub] [flink] flinkbot edited a comment on pull request #13547: [FLINK-14406][runtime] Exposes managed memory usage through the REST API

2020-10-06 Thread GitBox
flinkbot edited a comment on pull request #13547: URL: https://github.com/apache/flink/pull/13547#issuecomment-704265372 ## CI report: * 20c70c0fec1ceb77e60e138bb334bb48f5bcadcf Azure:

[jira] [Commented] (FLINK-19497) Implement mutator methods for FlinkCounterWrapper

2020-10-06 Thread Richard Moorhead (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17208975#comment-17208975 ] Richard Moorhead commented on FLINK-19497: -- Is it reasonable to request this be added to a

[GitHub] [flink] asfgit merged pull request #13548: [FLINK-19441][network] Avoid loading of ResultPartition wrapper class for consumable notifications when possible.

2020-10-06 Thread GitBox
asfgit merged pull request #13548: URL: https://github.com/apache/flink/pull/13548 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[jira] [Created] (FLINK-19516) PerJobMiniClusterFactoryTest. testJobClient()

2020-10-06 Thread Stephan Ewen (Jira)
Stephan Ewen created FLINK-19516: Summary: PerJobMiniClusterFactoryTest. testJobClient() Key: FLINK-19516 URL: https://issues.apache.org/jira/browse/FLINK-19516 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on pull request #13548: [FLINK-19441][network] Avoid loading of ResultPartition wrapper class for consumable notifications when possible.

2020-10-06 Thread GitBox
flinkbot edited a comment on pull request #13548: URL: https://github.com/apache/flink/pull/13548#issuecomment-704335711 ## CI report: * 3e996d9860a1b1f5431a2c3abee8f1c41b7bbd00 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13550: [FLINK-19474] Implement a state backend that holds a single key at a time

2020-10-06 Thread GitBox
flinkbot edited a comment on pull request #13550: URL: https://github.com/apache/flink/pull/13550#issuecomment-704399024 ## CI report: * 5e658efd970cd23de2637876e59becdbf00a8921 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13540: [FLINK-19344] Fix DispatcherResourceCleanupTest race condition

2020-10-06 Thread GitBox
flinkbot edited a comment on pull request #13540: URL: https://github.com/apache/flink/pull/13540#issuecomment-703484500 ## CI report: * 6650579aa244c53d76237be84b861224c451b4ba Azure:

[GitHub] [flink] tillrohrmann commented on a change in pull request #6464: [FLINK-9936][mesos] Mesos resource manager unable to connect to master after failover

2020-10-06 Thread GitBox
tillrohrmann commented on a change in pull request #6464: URL: https://github.com/apache/flink/pull/6464#discussion_r500456079 ## File path: flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManager.java ## @@ -794,7 +828,7 @@ public void

[GitHub] [flink] flinkbot commented on pull request #13550: [FLINK-19474] Implement a state backend that holds a single key at a time

2020-10-06 Thread GitBox
flinkbot commented on pull request #13550: URL: https://github.com/apache/flink/pull/13550#issuecomment-704399024 ## CI report: * 5e658efd970cd23de2637876e59becdbf00a8921 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #13529: [FLINK-19473] Implement multi inputs sorting DataInput

2020-10-06 Thread GitBox
flinkbot edited a comment on pull request #13529: URL: https://github.com/apache/flink/pull/13529#issuecomment-702193043 ## CI report: * d91430e1c66451806b07692731574192c09eca89 Azure:

[GitHub] [flink] dawidwys opened a new pull request #13550: [FLINK-19474] Implement a state backend that holds a single key at a time

2020-10-06 Thread GitBox
dawidwys opened a new pull request #13550: URL: https://github.com/apache/flink/pull/13550 ## What is the purpose of the change This commit introduces a SingleKeyStateBackend. This state backend is a simplified version of a state backend that can be used in a BATCH runtime

[GitHub] [flink] flinkbot edited a comment on pull request #13544: [FLINK-19309][coordination] Add TaskExecutorManager

2020-10-06 Thread GitBox
flinkbot edited a comment on pull request #13544: URL: https://github.com/apache/flink/pull/13544#issuecomment-704178057 This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] flinkbot edited a comment on pull request #13351: [FLINK-18990][task] Read channel state sequentially

2020-10-06 Thread GitBox
flinkbot edited a comment on pull request #13351: URL: https://github.com/apache/flink/pull/13351#issuecomment-688741492 ## CI report: * 3e38dfe739fa34ed301dc2c0303086568f138d57 Azure:

[GitHub] [flink] flinkbot commented on pull request #13550: [FLINK-19474] Implement a state backend that holds a single key at a time

2020-10-06 Thread GitBox
flinkbot commented on pull request #13550: URL: https://github.com/apache/flink/pull/13550#issuecomment-704387404 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] zentol commented on a change in pull request #13544: [FLINK-19309][coordination] Add TaskExecutorManager

2020-10-06 Thread GitBox
zentol commented on a change in pull request #13544: URL: https://github.com/apache/flink/pull/13544#discussion_r500420727 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/TaskExecutorManager.java ## @@ -0,0 +1,440 @@ +/* + *

[GitHub] [flink] zentol edited a comment on pull request #13544: [FLINK-19309][coordination] Add TaskExecutorManager

2020-10-06 Thread GitBox
zentol edited a comment on pull request #13544: URL: https://github.com/apache/flink/pull/13544#issuecomment-704383090 This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] zentol commented on pull request #13544: [FLINK-19309][coordination] Add TaskExecutorManager

2020-10-06 Thread GitBox
zentol commented on pull request #13544: URL: https://github.com/apache/flink/pull/13544#issuecomment-704383090 The TEM contains literally all logic that is specific to task executors. That was the entire thought process. Should the SlotManager (SM) handle pending slots? Maybe. But

[jira] [Commented] (FLINK-17259) Have scala 2.12 support

2020-10-06 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17208857#comment-17208857 ] Seth Wiesman commented on FLINK-17259: -- StateFun 2.2 dropped scala 2.11 support in favor of 2.12.

[jira] [Closed] (FLINK-17259) Have scala 2.12 support

2020-10-06 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman closed FLINK-17259. Resolution: Duplicate > Have scala 2.12 support > --- > >

[GitHub] [flink] flinkbot edited a comment on pull request #13548: [FLINK-19441][network] Avoid loading of ResultPartition wrapper class for consumable notifications when possible.

2020-10-06 Thread GitBox
flinkbot edited a comment on pull request #13548: URL: https://github.com/apache/flink/pull/13548#issuecomment-704335711 ## CI report: * 3e996d9860a1b1f5431a2c3abee8f1c41b7bbd00 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13549: [FLINK-18660] Bump flink-shaded to 1.12; Bump netty to 4.1.49

2020-10-06 Thread GitBox
flinkbot edited a comment on pull request #13549: URL: https://github.com/apache/flink/pull/13549#issuecomment-704349970 ## CI report: * aa06dc0c462dcba26088f707a33e3d724df53023 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13540: [FLINK-19344] Fix DispatcherResourceCleanupTest race condition

2020-10-06 Thread GitBox
flinkbot edited a comment on pull request #13540: URL: https://github.com/apache/flink/pull/13540#issuecomment-703484500 ## CI report: * 6650579aa244c53d76237be84b861224c451b4ba Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13351: [FLINK-18990][task] Read channel state sequentially

2020-10-06 Thread GitBox
flinkbot edited a comment on pull request #13351: URL: https://github.com/apache/flink/pull/13351#issuecomment-688741492 ## CI report: * 3e38dfe739fa34ed301dc2c0303086568f138d57 Azure:

[jira] [Commented] (FLINK-19481) Add support for a flink native GCS FileSystem

2020-10-06 Thread Ben Augarten (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17208844#comment-17208844 ] Ben Augarten commented on FLINK-19481: -- [~yunta] yes, that's right. Checkpoint on GCS via the

[GitHub] [flink] StephanEwen commented on pull request #13548: [FLINK-19441][network] Avoid loading of ResultPartition wrapper class for consumable notifications when possible.

2020-10-06 Thread GitBox
StephanEwen commented on pull request #13548: URL: https://github.com/apache/flink/pull/13548#issuecomment-704351300 Adjusted the code to make the role of the utility class more clear. This is an automated message from the

[GitHub] [flink] flinkbot commented on pull request #13549: [FLINK-18660] Bump flink-shaded to 1.12; Bump netty to 4.1.49

2020-10-06 Thread GitBox
flinkbot commented on pull request #13549: URL: https://github.com/apache/flink/pull/13549#issuecomment-704349970 ## CI report: * aa06dc0c462dcba26088f707a33e3d724df53023 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #13548: [FLINK-19441][network] Avoid loading of ResultPartition wrapper class for consumable notifications when possible.

2020-10-06 Thread GitBox
flinkbot edited a comment on pull request #13548: URL: https://github.com/apache/flink/pull/13548#issuecomment-704335711 ## CI report: * 3e996d9860a1b1f5431a2c3abee8f1c41b7bbd00 Azure:

[jira] [Updated] (FLINK-19515) Async RequestReply handler concurrency bug

2020-10-06 Thread Frans King (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Frans King updated FLINK-19515: --- Description: Async RequestReply handler implemented in

[jira] [Comment Edited] (FLINK-19441) Performance regression on 24.09.2020

2020-10-06 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17208828#comment-17208828 ] Stephan Ewen edited comment on FLINK-19441 at 10/6/20, 3:19 PM:  I could

[jira] [Commented] (FLINK-18518) Add Async RequestReply handler for the Python SDK

2020-10-06 Thread Frans King (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17208836#comment-17208836 ] Frans King commented on FLINK-18518: I think there might be a concurrency bug with the

[jira] [Updated] (FLINK-19507) Native support for Apache Pulsar

2020-10-06 Thread John Morrow (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Morrow updated FLINK-19507: Description: Flink StateFun has a sink/source IO module which can be used to plug in existing,

[GitHub] [flink] flinkbot commented on pull request #13549: [FLINK-18660] Bump flink-shaded to 1.12; Bump netty to 4.1.49

2020-10-06 Thread GitBox
flinkbot commented on pull request #13549: URL: https://github.com/apache/flink/pull/13549#issuecomment-704342067 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] rmetzger opened a new pull request #13549: [FLINK-18660] Bump flink-shaded to 1.12; Bump netty to 4.1.49

2020-10-06 Thread GitBox
rmetzger opened a new pull request #13549: URL: https://github.com/apache/flink/pull/13549 Bump netty to 4.1.49 for some security fixes. This also entails bumping netty-tcnative to 2.30.0 This is an automated message from

[jira] [Created] (FLINK-19515) Async RequestReply handler concurrency bug

2020-10-06 Thread Frans King (Jira)
Frans King created FLINK-19515: -- Summary: Async RequestReply handler concurrency bug Key: FLINK-19515 URL: https://issues.apache.org/jira/browse/FLINK-19515 Project: Flink Issue Type: Bug

[GitHub] [flink] fsk119 commented on pull request #13449: [FLINK-19282][table sql/planner]Supports watermark push down with Wat…

2020-10-06 Thread GitBox
fsk119 commented on pull request #13449: URL: https://github.com/apache/flink/pull/13449#issuecomment-704336548 Thanks for your reply. Looking forward for your suggestions! This is an automated message from the Apache Git

[GitHub] [flink] flinkbot commented on pull request #13548: [FLINK-19441][network] Avoid loading of ResultPartition wrapper class for consumable notifications when possible.

2020-10-06 Thread GitBox
flinkbot commented on pull request #13548: URL: https://github.com/apache/flink/pull/13548#issuecomment-704335711 ## CI report: * 3e996d9860a1b1f5431a2c3abee8f1c41b7bbd00 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-19501) Missing state in enum type in rest_api_v1.snapshot

2020-10-06 Thread goutham (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17208833#comment-17208833 ] goutham commented on FLINK-19501: - [~chesnay] sure I can work on it.  > Missing state in enum type in

[jira] [Created] (FLINK-19514) ZooKeeperLeaderElectionITCase.testJobExecutionOnClusterWithLeaderChange times out

2020-10-06 Thread Stephan Ewen (Jira)
Stephan Ewen created FLINK-19514: Summary: ZooKeeperLeaderElectionITCase.testJobExecutionOnClusterWithLeaderChange times out Key: FLINK-19514 URL: https://issues.apache.org/jira/browse/FLINK-19514

[GitHub] [flink] flinkbot commented on pull request #13548: [FLINK-19441][network] Avoid loading of ResultPartition wrapper class for consumable notifications when possible.

2020-10-06 Thread GitBox
flinkbot commented on pull request #13548: URL: https://github.com/apache/flink/pull/13548#issuecomment-704328667 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Commented] (FLINK-19441) Performance regression on 24.09.2020

2020-10-06 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17208828#comment-17208828 ] Stephan Ewen commented on FLINK-19441: --  I could not find anything very suspicious in the code. In

[GitHub] [flink] StephanEwen opened a new pull request #13548: [FLINK-19441][network] Avoid loading of ResultPartition wrapper class for consumable notifications when possible.

2020-10-06 Thread GitBox
StephanEwen opened a new pull request #13548: URL: https://github.com/apache/flink/pull/13548 ## What is the purpose of the change A small code optimization attempting to reduce the virtual method call overhead on the per-record methods in `ResultPartition`. It does that by

[jira] [Updated] (FLINK-19441) Performance regression on 24.09.2020

2020-10-06 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19441: --- Labels: pull-request-available (was: ) > Performance regression on 24.09.2020 >

[GitHub] [flink] flinkbot edited a comment on pull request #13545: [FLINK-19486] Make "Unexpected State Handle" Exception more helpful

2020-10-06 Thread GitBox
flinkbot edited a comment on pull request #13545: URL: https://github.com/apache/flink/pull/13545#issuecomment-704186207 ## CI report: * b66350a46c67dd801c8cb92ad0a33e2ad2e2d759 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13544: [FLINK-19309][coordination] Add TaskExecutorManager

2020-10-06 Thread GitBox
flinkbot edited a comment on pull request #13544: URL: https://github.com/apache/flink/pull/13544#issuecomment-704178057 ## CI report: * a66e85992ca9513c7e54c74f1f098f6773595f10 Azure:

[GitHub] [flink] XComp commented on pull request #13547: [FLINK-14406][runtime] Exposes managed memory usage through the REST API

2020-10-06 Thread GitBox
XComp commented on pull request #13547: URL: https://github.com/apache/flink/pull/13547#issuecomment-704310910 Another thing that's up for discussion: The current implementation does provide redundant information in the REST API. ``` { "id": "192.168.178.34:58646-64d0d8",

[GitHub] [flink] AHeise commented on a change in pull request #13545: [FLINK-19486] Make "Unexpected State Handle" Exception more helpful

2020-10-06 Thread GitBox
AHeise commented on a change in pull request #13545: URL: https://github.com/apache/flink/pull/13545#discussion_r500325899 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/UnexpectedStateHandleException.java ## @@ -0,0 +1,46 @@ +/* + * Licensed to the

[GitHub] [flink] flinkbot edited a comment on pull request #13529: [FLINK-19473] Implement multi inputs sorting DataInput

2020-10-06 Thread GitBox
flinkbot edited a comment on pull request #13529: URL: https://github.com/apache/flink/pull/13529#issuecomment-702193043 ## CI report: * eb1640d14d984365e27d9c0a58bbb2d9e4de6d03 Azure:

[GitHub] [flink] tillrohrmann commented on a change in pull request #13544: [FLINK-19309][coordination] Add TaskExecutorManager

2020-10-06 Thread GitBox
tillrohrmann commented on a change in pull request #13544: URL: https://github.com/apache/flink/pull/13544#discussion_r500299558 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/TaskExecutorManager.java ## @@ -0,0 +1,440 @@ +/* +

[jira] [Closed] (FLINK-19308) Add SlotTracker

2020-10-06 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-19308. Resolution: Fixed master: d196b396c685e0c7de207b283acf34de078fdf43 > Add SlotTracker >

[GitHub] [flink] zentol merged pull request #13508: [FLINK-19308][coordination] Add SlotTracker

2020-10-06 Thread GitBox
zentol merged pull request #13508: URL: https://github.com/apache/flink/pull/13508 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink] zentol merged pull request #13464: [FLINK-19307][coordination] Add ResourceTracker

2020-10-06 Thread GitBox
zentol merged pull request #13464: URL: https://github.com/apache/flink/pull/13464 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[jira] [Updated] (FLINK-19307) Add ResourceTracker

2020-10-06 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-19307: - Summary: Add ResourceTracker (was: Add RequirementsTracker) > Add ResourceTracker >

[jira] [Closed] (FLINK-19307) Add RequirementsTracker

2020-10-06 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-19307. Resolution: Fixed master: 7f07b62723a1b49ab5403b3b2797cb87686fbbd6 > Add

[jira] [Commented] (FLINK-18830) JoinCoGroupFunction and FlatJoinCoGroupFunction work incorrectly for outer join when one side of coGroup is empty

2020-10-06 Thread liupengcheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17208780#comment-17208780 ] liupengcheng commented on FLINK-18830: -- [~aljoscha] [~jark] Thanks for clarification, yes, I think

[GitHub] [flink] flinkbot edited a comment on pull request #13529: [FLINK-19473] Implement multi inputs sorting DataInput

2020-10-06 Thread GitBox
flinkbot edited a comment on pull request #13529: URL: https://github.com/apache/flink/pull/13529#issuecomment-702193043 ## CI report: * eb1640d14d984365e27d9c0a58bbb2d9e4de6d03 Azure:

[GitHub] [flink] flinkbot commented on pull request #13547: [FLINK-14406][runtime] Exposes managed memory usage through the REST API

2020-10-06 Thread GitBox
flinkbot commented on pull request #13547: URL: https://github.com/apache/flink/pull/13547#issuecomment-704265372 ## CI report: * 20c70c0fec1ceb77e60e138bb334bb48f5bcadcf UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #13547: [FLINK-14406][runtime] Exposes managed memory usage through the REST API

2020-10-06 Thread GitBox
flinkbot edited a comment on pull request #13547: URL: https://github.com/apache/flink/pull/13547#issuecomment-704265372 ## CI report: * 20c70c0fec1ceb77e60e138bb334bb48f5bcadcf Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13508: [FLINK-19308][coordination] Add SlotTracker

2020-10-06 Thread GitBox
flinkbot edited a comment on pull request #13508: URL: https://github.com/apache/flink/pull/13508#issuecomment-700676990 ## CI report: * 7bad74a7405f33d6ed8fd9ba7e9741be89406658 Azure:

[jira] [Closed] (FLINK-19027) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnParallelRemoteChannel failed because of test timeout

2020-10-06 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise closed FLINK-19027. --- Fix Version/s: (was: 1.11.3) Resolution: Fixed >

[jira] [Updated] (FLINK-19027) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnParallelRemoteChannel failed because of test timeout

2020-10-06 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-19027: Affects Version/s: (was: 1.11.2) >

[jira] [Commented] (FLINK-19027) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnParallelRemoteChannel failed because of test timeout

2020-10-06 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17208735#comment-17208735 ] Arvid Heise commented on FLINK-19027: - I don't see any failures on release-1.11, probably because

[GitHub] [flink] kezhuw commented on a change in pull request #13124: [FLINK-18815][test-stability] Close safety net guarded closeable iff it is still registered

2020-10-06 Thread GitBox
kezhuw commented on a change in pull request #13124: URL: https://github.com/apache/flink/pull/13124#discussion_r500268405 ## File path: flink-core/src/main/java/org/apache/flink/util/AbstractCloseableRegistry.java ## @@ -163,9 +163,9 @@ protected final void

[jira] [Commented] (FLINK-19489) SplitFetcherTest.testNotifiesWhenGoingIdleConcurrent gets stuck

2020-10-06 Thread Kezhu Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17208723#comment-17208723 ] Kezhu Wang commented on FLINK-19489: Here are my imaginative execution flows for this issue, please

[GitHub] [flink] tillrohrmann commented on a change in pull request #13508: [FLINK-19308][coordination] Add SlotTracker

2020-10-06 Thread GitBox
tillrohrmann commented on a change in pull request #13508: URL: https://github.com/apache/flink/pull/13508#discussion_r500285786 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherResourceCleanupTest.java ## @@ -343,6 +344,7 @@ public void

[jira] [Closed] (FLINK-19472) Implement one input sorting DataInput

2020-10-06 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-19472. Resolution: Fixed Implemented via: * bd1e1f306d9e8e94421a4a0587182a2e0283adf0 ...

[GitHub] [flink] XComp commented on pull request #13547: [FLINK-14406][runtime] Exposes managed memory usage through the REST API

2020-10-06 Thread GitBox
XComp commented on pull request #13547: URL: https://github.com/apache/flink/pull/13547#issuecomment-704258348 @azagrebin Feel free to review the changes. I am not 100% happy with the naming of the metrics (specifically, `Status.ManagedMemory.Used` vs

[GitHub] [flink] tillrohrmann commented on a change in pull request #13311: [FLINK-18721] Migrate YarnResourceManager to the new YarnResourceManagerDriver

2020-10-06 Thread GitBox
tillrohrmann commented on a change in pull request #13311: URL: https://github.com/apache/flink/pull/13311#discussion_r500102360 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/configuration/YarnResourceManagerConfiguration.java ## @@ -0,0 +1,118 @@ +/* + *

[GitHub] [flink] aljoscha commented on a change in pull request #13545: [FLINK-19486] Make "Unexpected State Handle" Exception more helpful

2020-10-06 Thread GitBox
aljoscha commented on a change in pull request #13545: URL: https://github.com/apache/flink/pull/13545#discussion_r500277349 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/UnexpectedStateHandleException.java ## @@ -0,0 +1,46 @@ +/* + * Licensed to

[GitHub] [flink] dawidwys closed pull request #13521: [FLINK-19472] Implement a one input sorting DataInput

2020-10-06 Thread GitBox
dawidwys closed pull request #13521: URL: https://github.com/apache/flink/pull/13521 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[GitHub] [flink] flinkbot commented on pull request #13547: [FLINK-14406][runtime] Exposes managed memory usage through the REST API

2020-10-06 Thread GitBox
flinkbot commented on pull request #13547: URL: https://github.com/apache/flink/pull/13547#issuecomment-704258387 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] aljoscha commented on a change in pull request #13545: [FLINK-19486] Make "Unexpected State Handle" Exception more helpful

2020-10-06 Thread GitBox
aljoscha commented on a change in pull request #13545: URL: https://github.com/apache/flink/pull/13545#discussion_r500276832 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/state/UnexpectedStateHandleExceptionTest.java ## @@ -0,0 +1,55 @@ +/* + * Licensed

[GitHub] [flink] aljoscha commented on a change in pull request #13545: [FLINK-19486] Make "Unexpected State Handle" Exception more helpful

2020-10-06 Thread GitBox
aljoscha commented on a change in pull request #13545: URL: https://github.com/apache/flink/pull/13545#discussion_r500276055 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/UnexpectedStateHandleException.java ## @@ -0,0 +1,46 @@ +/* + * Licensed to

[GitHub] [flink] XComp opened a new pull request #13547: [FLINK-14406][runtime] Exposes managed memory usage through the REST API

2020-10-06 Thread GitBox
XComp opened a new pull request #13547: URL: https://github.com/apache/flink/pull/13547 ## What is the purpose of the change This change is meant to expose the managed memory usage through the REST API to make it available in the web UI. ## Brief change log - Added

[GitHub] [flink] tillrohrmann commented on a change in pull request #13540: [FLINK-19344] Fix DispatcherResourceCleanupTest race condition

2020-10-06 Thread GitBox
tillrohrmann commented on a change in pull request #13540: URL: https://github.com/apache/flink/pull/13540#discussion_r500275816 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherResourceCleanupTest.java ## @@ -350,6 +350,10 @@ public

[jira] [Updated] (FLINK-19513) Update docs/build_docs.sh to support the new parameters for regenerating the docs

2020-10-06 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-19513: - Description: I came across Jekyll's regeneration feature not working anymore. After doing some

  1   2   3   >