[GitHub] [flink] rmetzger commented on issue #9938: [FLINK-14175] [flink-connector-kinesis] Update KPL version to 0.13.1

rmetzger commented on issue #9938: [FLINK-14175] [flink-connector-kinesis] Update KPL version to 0.13.1 URL: https://github.com/apache/flink/pull/9938#issuecomment-544990038 Related: https://github.com/apache/flink/pull/9939

[GitHub] [flink] flinkbot edited a comment on issue #9747: [FLINK-13985] Use unsafe memory for managed memory

flinkbot edited a comment on issue #9747: [FLINK-13985] Use unsafe memory for managed memory URL: https://github.com/apache/flink/pull/9747#issuecomment-534087338 ## CI report: * 1967191401dfac1a56eb3d82a0e97bd080e4c588 : SUCCESS

[GitHub] [flink] TisonKun commented on a change in pull request #9832: [FLINK-11843] Bind lifespan of Dispatcher to leader session

TisonKun commented on a change in pull request #9832: [FLINK-11843] Bind lifespan of Dispatcher to leader session URL: https://github.com/apache/flink/pull/9832#discussion_r337549852 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java

[GitHub] [flink] TisonKun commented on a change in pull request #9832: [FLINK-11843] Bind lifespan of Dispatcher to leader session

TisonKun commented on a change in pull request #9832: [FLINK-11843] Bind lifespan of Dispatcher to leader session URL: https://github.com/apache/flink/pull/9832#discussion_r337546924 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java

[jira] [Closed] (FLINK-14245) Kafka010ProducerITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceRegularSink fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-14245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-14245. -- Resolution: Fixed This was probably a duplicated issue of

[jira] [Closed] (FLINK-14224) Kafka010ProducerITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceCustomOperator fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-14224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-14224. -- Resolution: Duplicate This was probably a duplicated issue of

[jira] [Assigned] (FLINK-14224) Kafka010ProducerITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceCustomOperator fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-14224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-14224: -- Assignee: (was: Alex) >

[jira] [Closed] (FLINK-14235) Kafka010ProducerITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceCustomOperator fails on travis

[ https://issues.apache.org/jira/browse/FLINK-14235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-14235. -- Resolution: Fixed I hope this issue should be fixed by *c31e44e* (merged to the master

[jira] [Assigned] (FLINK-14235) Kafka010ProducerITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceCustomOperator fails on travis

[ https://issues.apache.org/jira/browse/FLINK-14235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-14235: -- Assignee: Piotr Nowojski >

[GitHub] [flink] TisonKun commented on a change in pull request #9832: [FLINK-11843] Bind lifespan of Dispatcher to leader session

TisonKun commented on a change in pull request #9832: [FLINK-11843] Bind lifespan of Dispatcher to leader session URL: https://github.com/apache/flink/pull/9832#discussion_r337541083 ## File path:

[jira] [Commented] (FLINK-14224) Kafka010ProducerITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceCustomOperator fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-14224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16957105#comment-16957105 ] Yun Tang commented on FLINK-14224: -- Another instance:

[GitHub] [flink] pnowojski commented on issue #9959: [FLINK-14235][kafka, tests] Change source in at-least-once test from finite to infinite

pnowojski commented on issue #9959: [FLINK-14235][kafka,tests] Change source in at-least-once test from finite to infinite URL: https://github.com/apache/flink/pull/9959#issuecomment-544982034 Thanks for the quick review @AHeise. Merging. I will close all of the three linked tickets and

[GitHub] [flink] pnowojski merged pull request #9959: [FLINK-14235][kafka, tests] Change source in at-least-once test from finite to infinite

pnowojski merged pull request #9959: [FLINK-14235][kafka,tests] Change source in at-least-once test from finite to infinite URL: https://github.com/apache/flink/pull/9959 This is an automated message from the Apache Git

[GitHub] [flink] flinkbot edited a comment on issue #9966: [FLINK-14053] [blink-planner] DenseRankAggFunction.accumulateExpressions. it should be thinki…

flinkbot edited a comment on issue #9966: [FLINK-14053] [blink-planner] DenseRankAggFunction.accumulateExpressions. it should be thinki… URL: https://github.com/apache/flink/pull/9966#issuecomment-544859291 ## CI report: * 6d09ab06b8bffd326034d8872cd85810bc09b164 : FAILURE

[GitHub] [flink] flinkbot commented on issue #9969: [FLINK-14022][table-planner][table-planner-blink] Add validation check for places where Python ScalarFunction cannot be used

flinkbot commented on issue #9969: [FLINK-14022][table-planner][table-planner-blink] Add validation check for places where Python ScalarFunction cannot be used URL: https://github.com/apache/flink/pull/9969#issuecomment-54497 ## CI report: *

[GitHub] [flink] flinkbot commented on issue #9970: [FLINK-14395] Refactor ES 7 connectors to make them keep consistency with es 6 connectors

flinkbot commented on issue #9970: [FLINK-14395] Refactor ES 7 connectors to make them keep consistency with es 6 connectors URL: https://github.com/apache/flink/pull/9970#issuecomment-544980056 ## CI report: * a2b9906d887c4feba3f1777957af4d3027116cb0 : UNKNOWN Bot

[GitHub] [flink] flinkbot edited a comment on issue #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever

flinkbot edited a comment on issue #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever URL: https://github.com/apache/flink/pull/9950#issuecomment-544414033 ## CI report: * decba8623c001e8bbe5dc797de2bc421b2e216ef : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9928: [FLINK-12122] Add support for spreading slots out across all TaskExecutors

flinkbot edited a comment on issue #9928: [FLINK-12122] Add support for spreading slots out across all TaskExecutors URL: https://github.com/apache/flink/pull/9928#issuecomment-543204040 ## CI report: * 1f0eed38301790afdbbd981d2a9853fa240e10df : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9881: [FLINK-14377] Parse Executor-relevant ProgramOptions to ConfigOptions

flinkbot edited a comment on issue #9881: [FLINK-14377] Parse Executor-relevant ProgramOptions to ConfigOptions URL: https://github.com/apache/flink/pull/9881#issuecomment-541072480 ## CI report: * 03fb6e64db35f290c9a1d5552aa34dfe5ccf9cd8 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9300: [FLINK-13513][ml] Add the FlatMapper and related classes for later al…

flinkbot edited a comment on issue #9300: [FLINK-13513][ml] Add the FlatMapper and related classes for later al… URL: https://github.com/apache/flink/pull/9300#issuecomment-516849331 ## CI report: * 9b5b5ff5df053498e491d43a04f44d5ba452579c : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9881: [FLINK-14377] Parse Executor-relevant ProgramOptions to ConfigOptions

flinkbot edited a comment on issue #9881: [FLINK-14377] Parse Executor-relevant ProgramOptions to ConfigOptions URL: https://github.com/apache/flink/pull/9881#issuecomment-541072480 ## CI report: * 03fb6e64db35f290c9a1d5552aa34dfe5ccf9cd8 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9747: [FLINK-13985] Use unsafe memory for managed memory

flinkbot edited a comment on issue #9747: [FLINK-13985] Use unsafe memory for managed memory URL: https://github.com/apache/flink/pull/9747#issuecomment-534087338 ## CI report: * 1967191401dfac1a56eb3d82a0e97bd080e4c588 : SUCCESS

[jira] [Commented] (FLINK-13025) Elasticsearch 7.x support

[ https://issues.apache.org/jira/browse/FLINK-13025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16957054#comment-16957054 ] vinoyang commented on FLINK-13025: -- [~lilyevsky] It seems you can get the artifact in the maven central

[GitHub] [flink] tillrohrmann commented on a change in pull request #9832: [FLINK-11843] Bind lifespan of Dispatcher to leader session

tillrohrmann commented on a change in pull request #9832: [FLINK-11843] Bind lifespan of Dispatcher to leader session URL: https://github.com/apache/flink/pull/9832#discussion_r337511483 ## File path:

[jira] [Commented] (FLINK-13025) Elasticsearch 7.x support

[ https://issues.apache.org/jira/browse/FLINK-13025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16957049#comment-16957049 ] Leonid Ilyevsky commented on FLINK-13025: - Thanks everybody. When can we see this artifact in

[GitHub] [flink] flinkbot edited a comment on issue #9747: [FLINK-13985] Use unsafe memory for managed memory

flinkbot edited a comment on issue #9747: [FLINK-13985] Use unsafe memory for managed memory URL: https://github.com/apache/flink/pull/9747#issuecomment-534087338 ## CI report: * 1967191401dfac1a56eb3d82a0e97bd080e4c588 : SUCCESS

[GitHub] [flink] flinkbot commented on issue #9970: [FLINK-14395] Refactor ES 7 connectors to make them keep consistency with es 6 connectors

flinkbot commented on issue #9970: [FLINK-14395] Refactor ES 7 connectors to make them keep consistency with es 6 connectors URL: https://github.com/apache/flink/pull/9970#issuecomment-544951741 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] [flink] flinkbot edited a comment on issue #9928: [FLINK-12122] Add support for spreading slots out across all TaskExecutors

flinkbot edited a comment on issue #9928: [FLINK-12122] Add support for spreading slots out across all TaskExecutors URL: https://github.com/apache/flink/pull/9928#issuecomment-543204040 ## CI report: * 1f0eed38301790afdbbd981d2a9853fa240e10df : FAILURE

[GitHub] [flink] yanghua opened a new pull request #9970: [FLINK-14395] Refactor ES 7 connectors to make them keep consistency with es 6 connectors

yanghua opened a new pull request #9970: [FLINK-14395] Refactor ES 7 connectors to make them keep consistency with es 6 connectors URL: https://github.com/apache/flink/pull/9970 ## What is the purpose of the change *This pull request refactors ES 7 connectors to make them keep

[GitHub] [flink] flinkbot commented on issue #9969: [FLINK-14022][table-planner][table-planner-blink] Add validation check for places where Python ScalarFunction cannot be used

flinkbot commented on issue #9969: [FLINK-14022][table-planner][table-planner-blink] Add validation check for places where Python ScalarFunction cannot be used URL: https://github.com/apache/flink/pull/9969#issuecomment-544948951 Thanks a lot for your contribution to the Apache Flink

[GitHub] [flink] flinkbot edited a comment on issue #9300: [FLINK-13513][ml] Add the FlatMapper and related classes for later al…

flinkbot edited a comment on issue #9300: [FLINK-13513][ml] Add the FlatMapper and related classes for later al… URL: https://github.com/apache/flink/pull/9300#issuecomment-516849331 ## CI report: * 9b5b5ff5df053498e491d43a04f44d5ba452579c : SUCCESS

[jira] [Updated] (FLINK-14022) Add validation check for places where Python ScalarFunction cannot be used

[ https://issues.apache.org/jira/browse/FLINK-14022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14022: --- Labels: pull-request-available (was: ) > Add validation check for places where Python

[GitHub] [flink] HuangXingBo opened a new pull request #9969: [FLINK-14022][table-planner][table-planner-blink] Add validation check for places where Python ScalarFunction cannot be used

HuangXingBo opened a new pull request #9969: [FLINK-14022][table-planner][table-planner-blink] Add validation check for places where Python ScalarFunction cannot be used URL: https://github.com/apache/flink/pull/9969 ## What is the purpose of the change *Currently, there are places

[jira] [Resolved] (FLINK-14447) Network metrics doc table render confusion

[ https://issues.apache.org/jira/browse/FLINK-14447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin resolved FLINK-14447. - Release Note: Merged into master by 56126bd43f6539dea39419e8f81779419ccea1c4 Merged

[GitHub] [flink] flinkbot edited a comment on issue #9747: [FLINK-13985] Use unsafe memory for managed memory

flinkbot edited a comment on issue #9747: [FLINK-13985] Use unsafe memory for managed memory URL: https://github.com/apache/flink/pull/9747#issuecomment-534087338 ## CI report: * 1967191401dfac1a56eb3d82a0e97bd080e4c588 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9966: [FLINK-14053] [blink-planner] DenseRankAggFunction.accumulateExpressions. it should be thinki…

flinkbot edited a comment on issue #9966: [FLINK-14053] [blink-planner] DenseRankAggFunction.accumulateExpressions. it should be thinki… URL: https://github.com/apache/flink/pull/9966#issuecomment-544859291 ## CI report: * 6d09ab06b8bffd326034d8872cd85810bc09b164 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever

flinkbot edited a comment on issue #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever URL: https://github.com/apache/flink/pull/9950#issuecomment-544414033 ## CI report: * decba8623c001e8bbe5dc797de2bc421b2e216ef : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9928: [FLINK-12122] Add support for spreading slots out across all TaskExecutors

flinkbot edited a comment on issue #9928: [FLINK-12122] Add support for spreading slots out across all TaskExecutors URL: https://github.com/apache/flink/pull/9928#issuecomment-543204040 ## CI report: * 1f0eed38301790afdbbd981d2a9853fa240e10df : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9300: [FLINK-13513][ml] Add the FlatMapper and related classes for later al…

flinkbot edited a comment on issue #9300: [FLINK-13513][ml] Add the FlatMapper and related classes for later al… URL: https://github.com/apache/flink/pull/9300#issuecomment-516849331 ## CI report: * 9b5b5ff5df053498e491d43a04f44d5ba452579c : SUCCESS

[jira] [Updated] (FLINK-14447) Network metrics doc table render confusion

[ https://issues.apache.org/jira/browse/FLINK-14447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-14447: Fix Version/s: 1.9.2 1.10.0 > Network metrics doc table render

[GitHub] [flink] flinkbot edited a comment on issue #9747: [FLINK-13985] Use unsafe memory for managed memory

flinkbot edited a comment on issue #9747: [FLINK-13985] Use unsafe memory for managed memory URL: https://github.com/apache/flink/pull/9747#issuecomment-534087338 ## CI report: * 1967191401dfac1a56eb3d82a0e97bd080e4c588 : SUCCESS

[GitHub] [flink] azagrebin merged pull request #9951: [FLINK-14447] Network metrics doc table render confusion

azagrebin merged pull request #9951: [FLINK-14447] Network metrics doc table render confusion URL: https://github.com/apache/flink/pull/9951 This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] xuyang1706 commented on issue #9300: [FLINK-13513][ml] Add the FlatMapper and related classes for later al…

xuyang1706 commented on issue #9300: [FLINK-13513][ml] Add the FlatMapper and related classes for later al… URL: https://github.com/apache/flink/pull/9300#issuecomment-544931164 > @xuyang1706 Thanks for the patch. The structure and semantic in the patch seems a little confusing to me. I

[GitHub] [flink] flinkbot edited a comment on issue #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever

flinkbot edited a comment on issue #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever URL: https://github.com/apache/flink/pull/9950#issuecomment-544414033 ## CI report: * decba8623c001e8bbe5dc797de2bc421b2e216ef : SUCCESS

[GitHub] [flink] xuyang1706 commented on a change in pull request #9300: [FLINK-13513][ml] Add the FlatMapper and related classes for later al…

xuyang1706 commented on a change in pull request #9300: [FLINK-13513][ml] Add the FlatMapper and related classes for later al… URL: https://github.com/apache/flink/pull/9300#discussion_r337475511 ## File path:

[jira] [Closed] (FLINK-13984) Separate on-heap and off-heap managed memory pools

[ https://issues.apache.org/jira/browse/FLINK-13984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin closed FLINK-13984. --- Release Note: The managed memory segment preallocation has been completely removed

[jira] [Closed] (FLINK-14399) Add memory chunk reservation API to MemoryManager

[ https://issues.apache.org/jira/browse/FLINK-14399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin closed FLINK-14399. --- Fix Version/s: 1.10.0 Resolution: Done Merged into master by

[GitHub] [flink] guoweiM commented on issue #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever

guoweiM commented on issue #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever URL: https://github.com/apache/flink/pull/9950#issuecomment-544930313 Thanks @zhuzhurk for reviewing. @flinkbot attention @tillrohrmann Could you have a look at this pr.

[GitHub] [flink] xuyang1706 commented on a change in pull request #9300: [FLINK-13513][ml] Add the FlatMapper and related classes for later al…

xuyang1706 commented on a change in pull request #9300: [FLINK-13513][ml] Add the FlatMapper and related classes for later al… URL: https://github.com/apache/flink/pull/9300#discussion_r337474707 ## File path:

[GitHub] [flink] tillrohrmann commented on issue #9928: [FLINK-12122] Add support for spreading slots out across all TaskExecutors

tillrohrmann commented on issue #9928: [FLINK-12122] Add support for spreading slots out across all TaskExecutors URL: https://github.com/apache/flink/pull/9928#issuecomment-544929438 Thanks a lot for your review @xintongsong. I've addressed most of you comments. Concerning the

[jira] [Updated] (FLINK-13984) Separate on-heap and off-heap managed memory pools

[ https://issues.apache.org/jira/browse/FLINK-13984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-13984: Fix Version/s: 1.10.0 > Separate on-heap and off-heap managed memory pools >

[GitHub] [flink] tillrohrmann commented on a change in pull request #9928: [FLINK-12122] Add support for spreading slots out across all TaskExecutors

tillrohrmann commented on a change in pull request #9928: [FLINK-12122] Add support for spreading slots out across all TaskExecutors URL: https://github.com/apache/flink/pull/9928#discussion_r337474651 ## File path:

[GitHub] [flink] xuyang1706 commented on a change in pull request #9300: [FLINK-13513][ml] Add the FlatMapper and related classes for later al…

xuyang1706 commented on a change in pull request #9300: [FLINK-13513][ml] Add the FlatMapper and related classes for later al… URL: https://github.com/apache/flink/pull/9300#discussion_r337473932 ## File path:

[jira] [Updated] (FLINK-13984) Separate on-heap and off-heap managed memory pools

[ https://issues.apache.org/jira/browse/FLINK-13984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13984: --- Labels: pull-request-available (was: ) > Separate on-heap and off-heap managed memory

[GitHub] [flink] xuyang1706 commented on a change in pull request #9300: [FLINK-13513][ml] Add the FlatMapper and related classes for later al…

xuyang1706 commented on a change in pull request #9300: [FLINK-13513][ml] Add the FlatMapper and related classes for later al… URL: https://github.com/apache/flink/pull/9300#discussion_r337473854 ## File path:

[GitHub] [flink] zhuzhurk commented on issue #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever

zhuzhurk commented on issue #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever URL: https://github.com/apache/flink/pull/9950#issuecomment-544928450 Thanks @guoweiM for addressing all the comments. It looks to me now. +1 to merge it.

[GitHub] [flink] azagrebin merged pull request #9693: [FLINK-13984] Separate on-heap and off-heap managed memory pools

azagrebin merged pull request #9693: [FLINK-13984] Separate on-heap and off-heap managed memory pools URL: https://github.com/apache/flink/pull/9693 This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] guoweiM commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever

guoweiM commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever URL: https://github.com/apache/flink/pull/9950#discussion_r337472932 ## File path:

[GitHub] [flink] guoweiM commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever

guoweiM commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever URL: https://github.com/apache/flink/pull/9950#discussion_r337472932 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9542: [FLINK-13873][metrics] Change the column family as tags for influxdb …

flinkbot edited a comment on issue #9542: [FLINK-13873][metrics] Change the column family as tags for influxdb … URL: https://github.com/apache/flink/pull/9542#issuecomment-525276537 ## CI report: * e8636926351f3d406962dcadba275e20e49aff39 : SUCCESS

[GitHub] [flink] zhuzhurk commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever

zhuzhurk commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever URL: https://github.com/apache/flink/pull/9950#discussion_r337468217 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9928: [FLINK-12122] Add support for spreading slots out across all TaskExecutors

tillrohrmann commented on a change in pull request #9928: [FLINK-12122] Add support for spreading slots out across all TaskExecutors URL: https://github.com/apache/flink/pull/9928#discussion_r337467084 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9968: [hotfix][typo] fix typo in YarnClusterDescriptor

flinkbot edited a comment on issue #9968: [hotfix][typo] fix typo in YarnClusterDescriptor URL: https://github.com/apache/flink/pull/9968#issuecomment-544895954 ## CI report: * 76cbd6febfa330bfecab18176279e059241443b7 : SUCCESS

[GitHub] [flink] wangyang0918 commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients

wangyang0918 commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients URL: https://github.com/apache/flink/pull/9965#discussion_r337465776 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9928: [FLINK-12122] Add support for spreading slots out across all TaskExecutors

tillrohrmann commented on a change in pull request #9928: [FLINK-12122] Add support for spreading slots out across all TaskExecutors URL: https://github.com/apache/flink/pull/9928#discussion_r337464754 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever

zhuzhurk commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever URL: https://github.com/apache/flink/pull/9950#discussion_r337462709 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9832: [FLINK-11843] Bind lifespan of Dispatcher to leader session

flinkbot edited a comment on issue #9832: [FLINK-11843] Bind lifespan of Dispatcher to leader session URL: https://github.com/apache/flink/pull/9832#issuecomment-537049332 ## CI report: * abaae048fef753455970fac9d6ab421b660b0536 : UNKNOWN *

[jira] [Commented] (FLINK-14429) Wrong app final status when running batch job on yarn with non-detached mode

[ https://issues.apache.org/jira/browse/FLINK-14429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16956946#comment-16956946 ] liupengcheng commented on FLINK-14429: -- Thanks [~trohrmann] [~aljoscha] , I got it! >Conceptually,

[GitHub] [flink] zhuzhurk commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever

zhuzhurk commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever URL: https://github.com/apache/flink/pull/9950#discussion_r337459475 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever

zhuzhurk commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever URL: https://github.com/apache/flink/pull/9950#discussion_r337458869 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever

flinkbot edited a comment on issue #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever URL: https://github.com/apache/flink/pull/9950#issuecomment-544414033 ## CI report: * decba8623c001e8bbe5dc797de2bc421b2e216ef : SUCCESS

[GitHub] [flink] wangyang0918 commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients

wangyang0918 commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients URL: https://github.com/apache/flink/pull/9965#discussion_r337454573 ## File path:

[GitHub] [flink] wangyang0918 commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients

wangyang0918 commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients URL: https://github.com/apache/flink/pull/9965#discussion_r337454017 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9832: [FLINK-11843] Bind lifespan of Dispatcher to leader session

flinkbot edited a comment on issue #9832: [FLINK-11843] Bind lifespan of Dispatcher to leader session URL: https://github.com/apache/flink/pull/9832#issuecomment-537049332 ## CI report: * abaae048fef753455970fac9d6ab421b660b0536 : UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on issue #9542: [FLINK-13873][metrics] Change the column family as tags for influxdb …

flinkbot edited a comment on issue #9542: [FLINK-13873][metrics] Change the column family as tags for influxdb … URL: https://github.com/apache/flink/pull/9542#issuecomment-525276537 ## CI report: * e8636926351f3d406962dcadba275e20e49aff39 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9255: [FLINK-13034] Introduce isEmpty method for MapState

flinkbot edited a comment on issue #9255: [FLINK-13034] Introduce isEmpty method for MapState URL: https://github.com/apache/flink/pull/9255#issuecomment-515870480 ## CI report: * de863750b7262d091d2e7dd82767b8f9b2e2c52a : SUCCESS

[GitHub] [flink] liuyongvs commented on issue #9966: [FLINK-14053] [blink-planner] DenseRankAggFunction.accumulateExpressions. it should be thinki…

liuyongvs commented on issue #9966: [FLINK-14053] [blink-planner] DenseRankAggFunction.accumulateExpressions. it should be thinki… URL: https://github.com/apache/flink/pull/9966#issuecomment-544906868 > Your base branch seems to be wrong, please use latest master branch and create a fix

[GitHub] [flink] liuyongvs commented on a change in pull request #9966: [FLINK-14053] [blink-planner] DenseRankAggFunction.accumulateExpressions. it should be thinki…

liuyongvs commented on a change in pull request #9966: [FLINK-14053] [blink-planner] DenseRankAggFunction.accumulateExpressions. it should be thinki… URL: https://github.com/apache/flink/pull/9966#discussion_r337447303 ## File path:

[GitHub] [flink] liuyongvs commented on a change in pull request #9966: [FLINK-14053] [blink-planner] DenseRankAggFunction.accumulateExpressions. it should be thinki…

liuyongvs commented on a change in pull request #9966: [FLINK-14053] [blink-planner] DenseRankAggFunction.accumulateExpressions. it should be thinki… URL: https://github.com/apache/flink/pull/9966#discussion_r337446771 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9964: test Travis arm ci

flinkbot edited a comment on issue #9964: test Travis arm ci URL: https://github.com/apache/flink/pull/9964#issuecomment-544799364 ## CI report: * 754182e6b5101abec8af40e3465a9d43c685d63c : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/132933631) *

[GitHub] [flink] flinkbot edited a comment on issue #9967: [FLINK-14453][runtime] Support building pipelined regions from base topology

flinkbot edited a comment on issue #9967: [FLINK-14453][runtime] Support building pipelined regions from base topology URL: https://github.com/apache/flink/pull/9967#issuecomment-544879098 ## CI report: * cdf5f2c32d7ac87b172bc42cb868865e6da2e537 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9968: [hotfix][typo] fix typo in YarnClusterDescriptor

flinkbot edited a comment on issue #9968: [hotfix][typo] fix typo in YarnClusterDescriptor URL: https://github.com/apache/flink/pull/9968#issuecomment-544895954 ## CI report: * 76cbd6febfa330bfecab18176279e059241443b7 : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients

flinkbot edited a comment on issue #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients URL: https://github.com/apache/flink/pull/9965#issuecomment-544813931 ## CI report: * 6f90b457e56a0a8cb45d63c1b05b47d2e38030a1 : SUCCESS

[GitHub] [flink] wangxiyuan closed pull request #9964: test Travis arm ci

wangxiyuan closed pull request #9964: test Travis arm ci URL: https://github.com/apache/flink/pull/9964 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink] flinkbot edited a comment on issue #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever

flinkbot edited a comment on issue #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever URL: https://github.com/apache/flink/pull/9950#issuecomment-544414033 ## CI report: * decba8623c001e8bbe5dc797de2bc421b2e216ef : SUCCESS

[jira] [Commented] (FLINK-9953) Active Kubernetes integration

[ https://issues.apache.org/jira/browse/FLINK-9953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16956925#comment-16956925 ] Yang Wang commented on FLINK-9953: -- It is reasonable for me that we only support session mode in the

[GitHub] [flink] tillrohrmann commented on a change in pull request #9928: [FLINK-12122] Add support for spreading slots out across all TaskExecutors

tillrohrmann commented on a change in pull request #9928: [FLINK-12122] Add support for spreading slots out across all TaskExecutors URL: https://github.com/apache/flink/pull/9928#discussion_r337441021 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9832: [FLINK-11843] Bind lifespan of Dispatcher to leader session

flinkbot edited a comment on issue #9832: [FLINK-11843] Bind lifespan of Dispatcher to leader session URL: https://github.com/apache/flink/pull/9832#issuecomment-537049332 ## CI report: * abaae048fef753455970fac9d6ab421b660b0536 : UNKNOWN *

[GitHub] [flink] tillrohrmann commented on a change in pull request #9928: [FLINK-12122] Add support for spreading slots out across all TaskExecutors

tillrohrmann commented on a change in pull request #9928: [FLINK-12122] Add support for spreading slots out across all TaskExecutors URL: https://github.com/apache/flink/pull/9928#discussion_r337440872 ## File path:

[GitHub] [flink] MalcolmSanders commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients

MalcolmSanders commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients URL: https://github.com/apache/flink/pull/9965#discussion_r337433178 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9542: [FLINK-13873][metrics] Change the column family as tags for influxdb …

flinkbot edited a comment on issue #9542: [FLINK-13873][metrics] Change the column family as tags for influxdb … URL: https://github.com/apache/flink/pull/9542#issuecomment-525276537 ## CI report: * e8636926351f3d406962dcadba275e20e49aff39 : SUCCESS

[GitHub] [flink] MalcolmSanders commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients

MalcolmSanders commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients URL: https://github.com/apache/flink/pull/9965#discussion_r337362157 ## File path:

[GitHub] [flink] MalcolmSanders commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients

MalcolmSanders commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients URL: https://github.com/apache/flink/pull/9965#discussion_r337436697 ## File path:

[GitHub] [flink] MalcolmSanders commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients

MalcolmSanders commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients URL: https://github.com/apache/flink/pull/9965#discussion_r337428992 ## File path: flink-kubernetes/pom.xml ## @@ -0,0 +1,208 @@ + + +

[GitHub] [flink] MalcolmSanders commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients

MalcolmSanders commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients URL: https://github.com/apache/flink/pull/9965#discussion_r337435108 ## File path:

[GitHub] [flink] MalcolmSanders commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients

MalcolmSanders commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients URL: https://github.com/apache/flink/pull/9965#discussion_r337430586 ## File path:

[GitHub] [flink] MalcolmSanders commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients

MalcolmSanders commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients URL: https://github.com/apache/flink/pull/9965#discussion_r337429424 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9928: [FLINK-12122] Add support for spreading slots out across all TaskExecutors

tillrohrmann commented on a change in pull request #9928: [FLINK-12122] Add support for spreading slots out across all TaskExecutors URL: https://github.com/apache/flink/pull/9928#discussion_r337438335 ## File path:

[GitHub] [flink] flinkbot commented on issue #9968: [hotfix][typo] fix typo in YarnClusterDescriptor

flinkbot commented on issue #9968: [hotfix][typo] fix typo in YarnClusterDescriptor URL: https://github.com/apache/flink/pull/9968#issuecomment-544895954 ## CI report: * 76cbd6febfa330bfecab18176279e059241443b7 : UNKNOWN Bot commands The @flinkbot bot supports

[GitHub] [flink] flinkbot edited a comment on issue #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients

flinkbot edited a comment on issue #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients URL: https://github.com/apache/flink/pull/9965#issuecomment-544813931 ## CI report: * 6f90b457e56a0a8cb45d63c1b05b47d2e38030a1 : SUCCESS

<    1   2   3   4   5   >