[GitHub] [flink] zzchun commented on issue #11599: [FLINK-16919][Blink Planner]Parameter 'jobName' does not take effect in BatchTableEnvUtil

2020-04-05 Thread GitBox
zzchun commented on issue #11599: [FLINK-16919][Blink Planner]Parameter 'jobName' does not take effect in BatchTableEnvUtil URL: https://github.com/apache/flink/pull/11599#issuecomment-609601502 @flinkbot run azure This is an

[GitHub] [flink] rmetzger commented on issue #11635: [FLINK-16979][hive][build] Exclude jdk.tools

2020-04-05 Thread GitBox
rmetzger commented on issue #11635: [FLINK-16979][hive][build] Exclude jdk.tools URL: https://github.com/apache/flink/pull/11635#issuecomment-609600538 The Java 11 detection for the e2e tests is based on the $PROFILE contents (it checks for `jdk11`). I have only switched the JDK version, wi

[GitHub] [flink] rmetzger commented on issue #11638: [FLINK-16973][tests] Add tooling for collecting jvm crash files

2020-04-05 Thread GitBox
rmetzger commented on issue #11638: [FLINK-16973][tests] Add tooling for collecting jvm crash files URL: https://github.com/apache/flink/pull/11638#issuecomment-609600649 I will look into the precommit test failures on Travis

[GitHub] [flink] xintongsong commented on issue #11353: [FLINK-16438][yarn] Make YarnResourceManager starts workers using WorkerResourceSpec requested by SlotManager

2020-04-05 Thread GitBox
xintongsong commented on issue #11353: [FLINK-16438][yarn] Make YarnResourceManager starts workers using WorkerResourceSpec requested by SlotManager URL: https://github.com/apache/flink/pull/11353#issuecomment-609595678 @tillrohrmann, thanks for the review. Regarding hiding `pending

[GitHub] [flink] xintongsong commented on a change in pull request #11353: [FLINK-16438][yarn] Make YarnResourceManager starts workers using WorkerResourceSpec requested by SlotManager

2020-04-05 Thread GitBox
xintongsong commented on a change in pull request #11353: [FLINK-16438][yarn] Make YarnResourceManager starts workers using WorkerResourceSpec requested by SlotManager URL: https://github.com/apache/flink/pull/11353#discussion_r403852622 ## File path: flink-yarn/src/main/java/org/

[GitHub] [flink] xintongsong commented on a change in pull request #11353: [FLINK-16438][yarn] Make YarnResourceManager starts workers using WorkerResourceSpec requested by SlotManager

2020-04-05 Thread GitBox
xintongsong commented on a change in pull request #11353: [FLINK-16438][yarn] Make YarnResourceManager starts workers using WorkerResourceSpec requested by SlotManager URL: https://github.com/apache/flink/pull/11353#discussion_r403851359 ## File path: flink-yarn/src/main/java/org/

[GitHub] [flink] xintongsong commented on a change in pull request #11353: [FLINK-16438][yarn] Make YarnResourceManager starts workers using WorkerResourceSpec requested by SlotManager

2020-04-05 Thread GitBox
xintongsong commented on a change in pull request #11353: [FLINK-16438][yarn] Make YarnResourceManager starts workers using WorkerResourceSpec requested by SlotManager URL: https://github.com/apache/flink/pull/11353#discussion_r403850488 ## File path: flink-yarn/src/main/java/org/

[GitHub] [flink] xintongsong commented on a change in pull request #11353: [FLINK-16438][yarn] Make YarnResourceManager starts workers using WorkerResourceSpec requested by SlotManager

2020-04-05 Thread GitBox
xintongsong commented on a change in pull request #11353: [FLINK-16438][yarn] Make YarnResourceManager starts workers using WorkerResourceSpec requested by SlotManager URL: https://github.com/apache/flink/pull/11353#discussion_r403848261 ## File path: flink-yarn/src/main/java/org/

[GitHub] [flink] xintongsong commented on a change in pull request #11353: [FLINK-16438][yarn] Make YarnResourceManager starts workers using WorkerResourceSpec requested by SlotManager

2020-04-05 Thread GitBox
xintongsong commented on a change in pull request #11353: [FLINK-16438][yarn] Make YarnResourceManager starts workers using WorkerResourceSpec requested by SlotManager URL: https://github.com/apache/flink/pull/11353#discussion_r403846970 ## File path: flink-yarn/src/test/java/org/

[GitHub] [flink] xintongsong commented on a change in pull request #11353: [FLINK-16438][yarn] Make YarnResourceManager starts workers using WorkerResourceSpec requested by SlotManager

2020-04-05 Thread GitBox
xintongsong commented on a change in pull request #11353: [FLINK-16438][yarn] Make YarnResourceManager starts workers using WorkerResourceSpec requested by SlotManager URL: https://github.com/apache/flink/pull/11353#discussion_r403843921 ## File path: flink-yarn/src/test/java/org/a

[GitHub] [flink] xintongsong commented on a change in pull request #11353: [FLINK-16438][yarn] Make YarnResourceManager starts workers using WorkerResourceSpec requested by SlotManager

2020-04-05 Thread GitBox
xintongsong commented on a change in pull request #11353: [FLINK-16438][yarn] Make YarnResourceManager starts workers using WorkerResourceSpec requested by SlotManager URL: https://github.com/apache/flink/pull/11353#discussion_r403843921 ## File path: flink-yarn/src/test/java/org/a

[jira] [Updated] (FLINK-16677) Make Stateful Functions more prominent in the Flink website.

2020-04-05 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16677: --- Labels: pull-request-available (was: ) > Make Stateful Functions more prominent in the Flin

[jira] [Updated] (FLINK-16978) Update flink-statefun README.md for Stateful Functions 2.0.

2020-04-05 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16978: --- Labels: pull-request-available (was: ) > Update flink-statefun README.md for Stateful Funct

[GitHub] [flink-statefun] morsapaes opened a new pull request #96: [FLINK-16978] Update flink-statefun README.md for Stateful Functions 2.0.

2020-04-05 Thread GitBox
morsapaes opened a new pull request #96: [FLINK-16978] Update flink-statefun README.md for Stateful Functions 2.0. URL: https://github.com/apache/flink-statefun/pull/96 Updating the README in the repository to fit the changes of Stateful Functions 2.0. Also updating the README in th

[GitHub] [flink] xintongsong commented on a change in pull request #11353: [FLINK-16438][yarn] Make YarnResourceManager starts workers using WorkerResourceSpec requested by SlotManager

2020-04-05 Thread GitBox
xintongsong commented on a change in pull request #11353: [FLINK-16438][yarn] Make YarnResourceManager starts workers using WorkerResourceSpec requested by SlotManager URL: https://github.com/apache/flink/pull/11353#discussion_r403840142 ## File path: flink-yarn/src/main/java/org/

[GitHub] [flink] xintongsong commented on a change in pull request #11353: [FLINK-16438][yarn] Make YarnResourceManager starts workers using WorkerResourceSpec requested by SlotManager

2020-04-05 Thread GitBox
xintongsong commented on a change in pull request #11353: [FLINK-16438][yarn] Make YarnResourceManager starts workers using WorkerResourceSpec requested by SlotManager URL: https://github.com/apache/flink/pull/11353#discussion_r403835524 ## File path: flink-yarn/src/main/java/org/

[GitHub] [flink] xintongsong commented on a change in pull request #11353: [FLINK-16438][yarn] Make YarnResourceManager starts workers using WorkerResourceSpec requested by SlotManager

2020-04-05 Thread GitBox
xintongsong commented on a change in pull request #11353: [FLINK-16438][yarn] Make YarnResourceManager starts workers using WorkerResourceSpec requested by SlotManager URL: https://github.com/apache/flink/pull/11353#discussion_r403834604 ## File path: flink-kubernetes/src/test/jav

[GitHub] [flink] xintongsong commented on a change in pull request #11353: [FLINK-16438][yarn] Make YarnResourceManager starts workers using WorkerResourceSpec requested by SlotManager

2020-04-05 Thread GitBox
xintongsong commented on a change in pull request #11353: [FLINK-16438][yarn] Make YarnResourceManager starts workers using WorkerResourceSpec requested by SlotManager URL: https://github.com/apache/flink/pull/11353#discussion_r403831354 ## File path: flink-kubernetes/src/main/jav

[GitHub] [flink] xintongsong edited a comment on issue #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity.

2020-04-05 Thread GitBox
xintongsong edited a comment on issue #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity. URL: https://github.com/apache/flink/pull/11320#issuecomment-609556553 Thanks for the review, @tillrohrmann. Regarding the nullable

[GitHub] [flink] xintongsong edited a comment on issue #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity.

2020-04-05 Thread GitBox
xintongsong edited a comment on issue #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity. URL: https://github.com/apache/flink/pull/11320#issuecomment-609556553 Thanks for the review, @tillrohrmann. Regarding the nullable

[GitHub] [flink] xintongsong commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity.

2020-04-05 Thread GitBox
xintongsong commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity. URL: https://github.com/apache/flink/pull/11320#discussion_r403823418 ## File path: flink-runtime/src/main/java/org/a

[GitHub] [flink] xintongsong commented on issue #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity.

2020-04-05 Thread GitBox
xintongsong commented on issue #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity. URL: https://github.com/apache/flink/pull/11320#issuecomment-609556553 Thanks for the review, @tillrohrmann. Regarding the nullable `defaul

[jira] [Closed] (FLINK-16950) Kafka console consumer displays uncommitted records.

2020-04-05 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-16950. --- Fix Version/s: statefun-2.0.0 Resolution: Fixed Fixed * master: c8a5c734a123

[jira] [Updated] (FLINK-16948) Change docs to better highlight embedded vs remote module configurations

2020-04-05 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-16948: Fix Version/s: (was: 2.0.0) statefun-2.0.0 > Change docs to

[jira] [Assigned] (FLINK-16948) Change docs to better highlight embedded vs remote module configurations

2020-04-05 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-16948: --- Assignee: Seth Wiesman > Change docs to better highlight embedded vs remote

[jira] [Closed] (FLINK-16948) Change docs to better highlight embedded vs remote module configurations

2020-04-05 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-16948. --- Resolution: Fixed Fixed * master: 4948b2c72f224fda46f7045efe99fd4d959ab2b3 * releas

[GitHub] [flink-statefun] tzulitai closed pull request #94: [FLINK-16950][docs] Add Isolation level to

2020-04-05 Thread GitBox
tzulitai closed pull request #94: [FLINK-16950][docs] Add Isolation level to URL: https://github.com/apache/flink-statefun/pull/94 This is an automated message from the Apache Git Service. To respond to the message, please l

[GitHub] [flink-statefun] tzulitai closed pull request #93: [FLINK-16948][docs] Change docs to better highlight embedded vs remote module configurations

2020-04-05 Thread GitBox
tzulitai closed pull request #93: [FLINK-16948][docs] Change docs to better highlight embedded vs remote module configurations URL: https://github.com/apache/flink-statefun/pull/93 This is an automated message from the Apach

[jira] [Updated] (FLINK-16624) Support user-specified annotations for the rest Service

2020-04-05 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-16624: - Parent: FLINK-14460 Issue Type: Sub-task (was: Improvement) > Support user-specified an

[jira] [Closed] (FLINK-15822) Rethink the necessity of the internal Service

2020-04-05 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng closed FLINK-15822. Fix Version/s: (was: 1.10.1) Resolution: Fixed > Rethink the necessity of the internal

[jira] [Updated] (FLINK-16602) Rework the Service design for native Kubernetes deployment

2020-04-05 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-16602: - Summary: Rework the Service design for native Kubernetes deployment (was: Rework the Service de

[jira] [Updated] (FLINK-16602) Rework the Service design for native Kubernetes deployment

2020-04-05 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-16602: - Parent: FLINK-14460 Issue Type: Sub-task (was: Improvement) > Rework the Service design

[jira] [Updated] (FLINK-15646) Configurable K8s context support

2020-04-05 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-15646: - Parent: FLINK-14460 Issue Type: Sub-task (was: New Feature) > Configurable K8s context

[jira] [Updated] (FLINK-15646) Configurable K8s context support

2020-04-05 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-15646: - Parent: (was: FLINK-15788) Issue Type: New Feature (was: Sub-task) > Configurable K

[jira] [Commented] (FLINK-15656) Support user-specified pod templates

2020-04-05 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17076019#comment-17076019 ] Canbin Zheng commented on FLINK-15656: -- [~fly_in_gis] Sorry for the late reply. Th

[GitHub] [flink-statefun] tzulitai commented on issue #94: [FLINK-16950][docs] Add Isolation level to

2020-04-05 Thread GitBox
tzulitai commented on issue #94: [FLINK-16950][docs] Add Isolation level to URL: https://github.com/apache/flink-statefun/pull/94#issuecomment-609544066 Had an offline discussion with Igal: On second thought, since read_uncomitted doesn’t affect outputs for non-transactional writes,

[GitHub] [flink] xintongsong commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity.

2020-04-05 Thread GitBox
xintongsong commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity. URL: https://github.com/apache/flink/pull/11320#discussion_r403806981 ## File path: flink-runtime/src/main/java/org/a

[GitHub] [flink] xintongsong commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity.

2020-04-05 Thread GitBox
xintongsong commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity. URL: https://github.com/apache/flink/pull/11320#discussion_r403805525 ## File path: flink-runtime/src/main/java/org/a

[GitHub] [flink] xintongsong commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity.

2020-04-05 Thread GitBox
xintongsong commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity. URL: https://github.com/apache/flink/pull/11320#discussion_r403799016 ## File path: flink-runtime/src/main/java/org/a

[GitHub] [flink] xintongsong commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity.

2020-04-05 Thread GitBox
xintongsong commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity. URL: https://github.com/apache/flink/pull/11320#discussion_r403793315 ## File path: flink-runtime/src/main/java/org/a

[GitHub] [flink] xintongsong commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity.

2020-04-05 Thread GitBox
xintongsong commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity. URL: https://github.com/apache/flink/pull/11320#discussion_r403789023 ## File path: flink-runtime/src/main/java/org/a

[GitHub] [flink] xintongsong commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity.

2020-04-05 Thread GitBox
xintongsong commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity. URL: https://github.com/apache/flink/pull/11320#discussion_r403789023 ## File path: flink-runtime/src/main/java/org/a

[GitHub] [flink] xintongsong commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity.

2020-04-05 Thread GitBox
xintongsong commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity. URL: https://github.com/apache/flink/pull/11320#discussion_r403789023 ## File path: flink-runtime/src/main/java/org/a

[GitHub] [flink] rkhachatryan commented on a change in pull request #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints

2020-04-05 Thread GitBox
rkhachatryan commented on a change in pull request #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints URL: https://github.com/apache/flink/pull/11515#discussion_r403754836 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/chec

[GitHub] [flink] flinkbot edited a comment on issue #11641: [FLINK-16921][e2e] Disable K8s tests until instability is resolved

2020-04-05 Thread GitBox
flinkbot edited a comment on issue #11641: [FLINK-16921][e2e] Disable K8s tests until instability is resolved URL: https://github.com/apache/flink/pull/11641#issuecomment-609458594 ## CI report: * f49ae09c49c96f3c831d798180cc2b6198f0a11a Travis: [SUCCESS](https://travis-ci.com/g

[GitHub] [flink] flinkbot edited a comment on issue #11641: [FLINK-16921][e2e] Disable K8s tests until instability is resolved

2020-04-05 Thread GitBox
flinkbot edited a comment on issue #11641: [FLINK-16921][e2e] Disable K8s tests until instability is resolved URL: https://github.com/apache/flink/pull/11641#issuecomment-609458594 ## CI report: * f49ae09c49c96f3c831d798180cc2b6198f0a11a Travis: [PENDING](https://travis-ci.com/g

[GitHub] [flink] flinkbot edited a comment on issue #11640: add end-to-end-performance test

2020-04-05 Thread GitBox
flinkbot edited a comment on issue #11640: add end-to-end-performance test URL: https://github.com/apache/flink/pull/11640#issuecomment-609448172 ## CI report: * 8fbcc43cbe849943bb538ebd85e223316662d65a Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/15851323

[GitHub] [flink] flinkbot edited a comment on issue #11641: [FLINK-16921][e2e] Disable K8s tests until instability is resolved

2020-04-05 Thread GitBox
flinkbot edited a comment on issue #11641: [FLINK-16921][e2e] Disable K8s tests until instability is resolved URL: https://github.com/apache/flink/pull/11641#issuecomment-609458594 ## CI report: * f49ae09c49c96f3c831d798180cc2b6198f0a11a Travis: [PENDING](https://travis-ci.com/g

[GitHub] [flink] flinkbot commented on issue #11641: [FLINK-16921][e2e] Disable K8s tests until instability is resolved

2020-04-05 Thread GitBox
flinkbot commented on issue #11641: [FLINK-16921][e2e] Disable K8s tests until instability is resolved URL: https://github.com/apache/flink/pull/11641#issuecomment-609458594 ## CI report: * f49ae09c49c96f3c831d798180cc2b6198f0a11a UNKNOWN Bot commands The @flinkbo

[GitHub] [flink] flinkbot edited a comment on issue #11640: add end-to-end-performance test

2020-04-05 Thread GitBox
flinkbot edited a comment on issue #11640: add end-to-end-performance test URL: https://github.com/apache/flink/pull/11640#issuecomment-609448172 ## CI report: * 8fbcc43cbe849943bb538ebd85e223316662d65a Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/15851323

[jira] [Closed] (FLINK-16979) flink-sql-connector-hive-1.2.2_2.11 doesn't compile on JDK11

2020-04-05 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-16979. Resolution: Fixed master: 105379f8e36aec83de8bef92003d4c686023e7ab > flink-sql-connector-

[GitHub] [flink] zentol commented on issue #11635: [FLINK-16979][hive][build] Exclude jdk.tools

2020-04-05 Thread GitBox
zentol commented on issue #11635: [FLINK-16979][hive][build] Exclude jdk.tools URL: https://github.com/apache/flink/pull/11635#issuecomment-609458207 I'll merge the PR since the compile step has passed. @rmetzger Seems like the Java 11 detection isn't working as expected in your cust

[GitHub] [flink] zentol merged pull request #11635: [FLINK-16979][hive][build] Exclude jdk.tools

2020-04-05 Thread GitBox
zentol merged pull request #11635: [FLINK-16979][hive][build] Exclude jdk.tools URL: https://github.com/apache/flink/pull/11635 This is an automated message from the Apache Git Service. To respond to the message, please log o

[GitHub] [flink] flinkbot commented on issue #11641: [FLINK-16921][e2e] Disable K8s tests until instability is resolved

2020-04-05 Thread GitBox
flinkbot commented on issue #11641: [FLINK-16921][e2e] Disable K8s tests until instability is resolved URL: https://github.com/apache/flink/pull/11641#issuecomment-609456467 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[jira] [Commented] (FLINK-16638) Flink checkStateMappingCompleteness doesn't include UserDefinedOperatorIDs

2020-04-05 Thread Bashar Abdul Jawad (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17075893#comment-17075893 ] Bashar Abdul Jawad commented on FLINK-16638: [~pnowojski]I I can submit a fi

[jira] [Commented] (FLINK-16921) "kubernetes session test" is unstable

2020-04-05 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17075891#comment-17075891 ] Robert Metzger commented on FLINK-16921: E2e tests are failing quite reliably wi

[GitHub] [flink] rmetzger opened a new pull request #11641: [FLINK-16921][e2e] Disable K8s tests until instability is resolved

2020-04-05 Thread GitBox
rmetzger opened a new pull request #11641: [FLINK-16921][e2e] Disable K8s tests until instability is resolved URL: https://github.com/apache/flink/pull/11641 ## What is the purpose of the change Disable an unstable e2e test. --

[GitHub] [flink] rmetzger commented on issue #11635: [FLINK-16979][hive][build] Exclude jdk.tools

2020-04-05 Thread GitBox
rmetzger commented on issue #11635: [FLINK-16979][hive][build] Exclude jdk.tools URL: https://github.com/apache/flink/pull/11635#issuecomment-609453353 Damn, good catch. The pipeline is configured to use the flink repo pipeline definition, that's why it didn't pick up the version defined in

[GitHub] [flink] dawidwys merged pull request #11622: [FLINK-16913][configuration, statebackend] Migrated StateBackends to use ReadableConfig instead of Configuration

2020-04-05 Thread GitBox
dawidwys merged pull request #11622: [FLINK-16913][configuration, statebackend] Migrated StateBackends to use ReadableConfig instead of Configuration URL: https://github.com/apache/flink/pull/11622 This is an automated messa

[GitHub] [flink] flinkbot edited a comment on issue #11638: [FLINK-16973][tests] Add tooling for collecting jvm crash files

2020-04-05 Thread GitBox
flinkbot edited a comment on issue #11638: [FLINK-16973][tests] Add tooling for collecting jvm crash files URL: https://github.com/apache/flink/pull/11638#issuecomment-609422779 ## CI report: * 3bd90923fbd55b2238d716ad1ad5946d8ab7fa61 Travis: [FAILURE](https://travis-ci.com/gith

[GitHub] [flink] flinkbot edited a comment on issue #11640: add end-to-end-performance test

2020-04-05 Thread GitBox
flinkbot edited a comment on issue #11640: add end-to-end-performance test URL: https://github.com/apache/flink/pull/11640#issuecomment-609448172 ## CI report: * 8fbcc43cbe849943bb538ebd85e223316662d65a Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/15851323

[GitHub] [flink] flinkbot commented on issue #11640: add end-to-end-performance test

2020-04-05 Thread GitBox
flinkbot commented on issue #11640: add end-to-end-performance test URL: https://github.com/apache/flink/pull/11640#issuecomment-609448172 ## CI report: * 8fbcc43cbe849943bb538ebd85e223316662d65a UNKNOWN Bot commands The @flinkbot bot supports the following command

[jira] [Commented] (FLINK-16929) Session Window produces sessions randomly

2020-04-05 Thread Ori Popowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17075878#comment-17075878 ] Ori Popowski commented on FLINK-16929: -- # {{SessionStartProcessFunction}} just oupu

[GitHub] [flink] flinkbot commented on issue #11640: add end-to-end-performance test

2020-04-05 Thread GitBox
flinkbot commented on issue #11640: add end-to-end-performance test URL: https://github.com/apache/flink/pull/11640#issuecomment-609447554 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

[GitHub] [flink] Li-Aihua opened a new pull request #11640: add end-to-end-performance test

2020-04-05 Thread GitBox
Li-Aihua opened a new pull request #11640: add end-to-end-performance test URL: https://github.com/apache/flink/pull/11640 ## What is the purpose of the change *Add funcion to set up environment to run performance e2e tests which methoned in .FLINK-14920* ## Brief

[GitHub] [flink] pnowojski commented on a change in pull request #11567: [FLINK-16645] Limit the maximum backlogs in subpartitions

2020-04-05 Thread GitBox
pnowojski commented on a change in pull request #11567: [FLINK-16645] Limit the maximum backlogs in subpartitions URL: https://github.com/apache/flink/pull/11567#discussion_r403727993 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultPart

[GitHub] [flink] zhijiangW commented on issue #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

2020-04-05 Thread GitBox
zhijiangW commented on issue #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#issuecomment-609445924 @AHeise I confirmed the related comments and resolved most of them. Except for the main concerns for handlin

[GitHub] [flink] zhijiangW commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

2020-04-05 Thread GitBox
zhijiangW commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#discussion_r403726537 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtim

[GitHub] [flink] zhijiangW commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

2020-04-05 Thread GitBox
zhijiangW commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#discussion_r403725829 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/

[GitHub] [flink] flinkbot edited a comment on issue #11639: [FLINK-16626][runtime] Prevent REST handler from being closed more than once

2020-04-05 Thread GitBox
flinkbot edited a comment on issue #11639: [FLINK-16626][runtime] Prevent REST handler from being closed more than once URL: https://github.com/apache/flink/pull/11639#issuecomment-609430703 ## CI report: * 3d2868f287cd4df7bf4d71947a2f04d482a936cf UNKNOWN * 6cec9f68ac5dee45ace

[GitHub] [flink] zhijiangW commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

2020-04-05 Thread GitBox
zhijiangW commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#discussion_r403724706 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtim

[GitHub] [flink] zhijiangW commented on a change in pull request #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints

2020-04-05 Thread GitBox
zhijiangW commented on a change in pull request #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints URL: https://github.com/apache/flink/pull/11515#discussion_r403721544 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streamin

[GitHub] [flink] zhijiangW commented on a change in pull request #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints

2020-04-05 Thread GitBox
zhijiangW commented on a change in pull request #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints URL: https://github.com/apache/flink/pull/11515#discussion_r403720984 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpo

[GitHub] [flink] zentol commented on issue #11635: [FLINK-16979][hive][build] Exclude jdk.tools

2020-04-05 Thread GitBox
zentol commented on issue #11635: [FLINK-16979][hive][build] Exclude jdk.tools URL: https://github.com/apache/flink/pull/11635#issuecomment-609438838 @rmetzger The maven output in the compile step indicates that Java 8 is being used? ``` Apache Maven 3.2.5 (12a6b3acb947671f09b81f49094

[GitHub] [flink] zentol edited a comment on issue #11635: [FLINK-16979][hive][build] Exclude jdk.tools

2020-04-05 Thread GitBox
zentol edited a comment on issue #11635: [FLINK-16979][hive][build] Exclude jdk.tools URL: https://github.com/apache/flink/pull/11635#issuecomment-609438838 @rmetzger The maven output in the compile step indicates that Java 8 is being used? ``` Apache Maven 3.2.5 (12a6b3acb947671f09b

[GitHub] [flink] zentol commented on issue #11634: [FLINK-16984][tests] Consolidate Log4j2-test.properties

2020-04-05 Thread GitBox
zentol commented on issue #11634: [FLINK-16984][tests] Consolidate Log4j2-test.properties URL: https://github.com/apache/flink/pull/11634#issuecomment-609438563 > some modules seem to have some module specifics encoded in their logging config (I propose the keep the files for those modules

[GitHub] [flink] flinkbot edited a comment on issue #11639: [FLINK-16626][runtime] Prevent REST handler from being closed more than once

2020-04-05 Thread GitBox
flinkbot edited a comment on issue #11639: [FLINK-16626][runtime] Prevent REST handler from being closed more than once URL: https://github.com/apache/flink/pull/11639#issuecomment-609430703 ## CI report: * 3d2868f287cd4df7bf4d71947a2f04d482a936cf UNKNOWN * 6cec9f68ac5dee45ace

[GitHub] [flink] zhijiangW commented on a change in pull request #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints

2020-04-05 Thread GitBox
zhijiangW commented on a change in pull request #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints URL: https://github.com/apache/flink/pull/11515#discussion_r403717544 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streamin

[GitHub] [flink] flinkbot edited a comment on issue #11639: [FLINK-16626][runtime] Prevent REST handler from being closed more than once

2020-04-05 Thread GitBox
flinkbot edited a comment on issue #11639: [FLINK-16626][runtime] Prevent REST handler from being closed more than once URL: https://github.com/apache/flink/pull/11639#issuecomment-609430703 ## CI report: * 3d2868f287cd4df7bf4d71947a2f04d482a936cf UNKNOWN * 6cec9f68ac5dee45ace

[GitHub] [flink] flinkbot edited a comment on issue #11638: [FLINK-16973][tests] Add tooling for collecting jvm crash files

2020-04-05 Thread GitBox
flinkbot edited a comment on issue #11638: [FLINK-16973][tests] Add tooling for collecting jvm crash files URL: https://github.com/apache/flink/pull/11638#issuecomment-609422779 ## CI report: * 3bd90923fbd55b2238d716ad1ad5946d8ab7fa61 Travis: [FAILURE](https://travis-ci.com/gith

[GitHub] [flink] flinkbot edited a comment on issue #11622: [FLINK-16913][configuration, statebackend] Migrated StateBackends to use ReadableConfig instead of Configuration

2020-04-05 Thread GitBox
flinkbot edited a comment on issue #11622: [FLINK-16913][configuration, statebackend] Migrated StateBackends to use ReadableConfig instead of Configuration URL: https://github.com/apache/flink/pull/11622#issuecomment-607942457 ## CI report: * 46e2d9b408be3eecbd83a8aeb8bd1aa911cd

[GitHub] [flink] kylemeow commented on issue #11639: [FLINK-16626][runtime] Prevent REST handler from being closed more than once

2020-04-05 Thread GitBox
kylemeow commented on issue #11639: [FLINK-16626][runtime] Prevent REST handler from being closed more than once URL: https://github.com/apache/flink/pull/11639#issuecomment-609430867 Hi @TisonKun @GJL , would you please help review this PR? Thank you very much : ) ---

[GitHub] [flink] flinkbot commented on issue #11639: [FLINK-16626][runtime] Prevent REST handler from being closed more than once

2020-04-05 Thread GitBox
flinkbot commented on issue #11639: [FLINK-16626][runtime] Prevent REST handler from being closed more than once URL: https://github.com/apache/flink/pull/11639#issuecomment-609430703 ## CI report: * 3d2868f287cd4df7bf4d71947a2f04d482a936cf UNKNOWN Bot commands Th

[GitHub] [flink] flinkbot commented on issue #11639: [FLINK-16626][runtime] Prevent REST handler from being closed more than once

2020-04-05 Thread GitBox
flinkbot commented on issue #11639: [FLINK-16626][runtime] Prevent REST handler from being closed more than once URL: https://github.com/apache/flink/pull/11639#issuecomment-609428724 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[jira] [Updated] (FLINK-16626) Prevent REST handler from being closed more than once

2020-04-05 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16626: --- Labels: pull-request-available (was: ) > Prevent REST handler from being closed more than o

[GitHub] [flink] kylemeow opened a new pull request #11639: [FLINK-16626][runtime] Prevent REST handler from being closed more than once

2020-04-05 Thread GitBox
kylemeow opened a new pull request #11639: [FLINK-16626][runtime] Prevent REST handler from being closed more than once URL: https://github.com/apache/flink/pull/11639 ## What is the purpose of the change In Flink 1.10.0 release, job cancellation can be problematic, as users frequen

[GitHub] [flink] flinkbot edited a comment on issue #11638: [FLINK-16973][tests] Add tooling for collecting jvm crash files

2020-04-05 Thread GitBox
flinkbot edited a comment on issue #11638: [FLINK-16973][tests] Add tooling for collecting jvm crash files URL: https://github.com/apache/flink/pull/11638#issuecomment-609422779 ## CI report: * 3bd90923fbd55b2238d716ad1ad5946d8ab7fa61 Travis: [PENDING](https://travis-ci.com/gith

[jira] [Updated] (FLINK-16626) Prevent REST handler from being closed more than once

2020-04-05 Thread Weike Dong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weike Dong updated FLINK-16626: --- Description: In Flink 1.10.0 release, job cancellation can be problematic, as users  frequently expe

[jira] [Updated] (FLINK-16626) Prevent REST handler from being closed more than once

2020-04-05 Thread Weike Dong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weike Dong updated FLINK-16626: --- Summary: Prevent REST handler from being closed more than once (was: Exception encountered when can

[jira] [Commented] (FLINK-11499) Extend StreamingFileSink BulkFormats to support arbitrary roll policies

2020-04-05 Thread Sivaprasanna Sethuraman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17075847#comment-17075847 ] Sivaprasanna Sethuraman commented on FLINK-11499: - [~pnowojski] Yes, tha

[GitHub] [flink] flinkbot commented on issue #11638: [FLINK-16973][tests] Add tooling for collecting jvm crash files

2020-04-05 Thread GitBox
flinkbot commented on issue #11638: [FLINK-16973][tests] Add tooling for collecting jvm crash files URL: https://github.com/apache/flink/pull/11638#issuecomment-609422779 ## CI report: * 3bd90923fbd55b2238d716ad1ad5946d8ab7fa61 UNKNOWN Bot commands The @flinkbot b

[GitHub] [flink] rmetzger commented on a change in pull request #11634: [FLINK-16984][tests] Consolidate Log4j2-test.properties

2020-04-05 Thread GitBox
rmetzger commented on a change in pull request #11634: [FLINK-16984][tests] Consolidate Log4j2-test.properties URL: https://github.com/apache/flink/pull/11634#discussion_r403707157 ## File path: flink-runtime/src/test/resources/log4j2-test.properties ## @@ -1,32 +0,0 @@ -#

[GitHub] [flink] rmetzger commented on a change in pull request #11634: [FLINK-16984][tests] Consolidate Log4j2-test.properties

2020-04-05 Thread GitBox
rmetzger commented on a change in pull request #11634: [FLINK-16984][tests] Consolidate Log4j2-test.properties URL: https://github.com/apache/flink/pull/11634#discussion_r403707044 ## File path: flink-connectors/flink-connector-kafka-0.10/src/test/resources/log4j2-test.properties

[GitHub] [flink] rmetzger commented on issue #11635: [FLINK-16979][hive][build] Exclude jdk.tools

2020-04-05 Thread GitBox
rmetzger commented on issue #11635: [FLINK-16979][hive][build] Exclude jdk.tools URL: https://github.com/apache/flink/pull/11635#issuecomment-609421110 Thanks a lot! I triggered a JDK11 CI job for this PR: https://dev.azure.com/rmetzger/Flink/_build/results?buildId=7076&view=results --

[GitHub] [flink] flinkbot commented on issue #11638: [FLINK-16973][tests] Add tooling for collecting jvm crash files

2020-04-05 Thread GitBox
flinkbot commented on issue #11638: [FLINK-16973][tests] Add tooling for collecting jvm crash files URL: https://github.com/apache/flink/pull/11638#issuecomment-609420916 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review yo

[jira] [Updated] (FLINK-16973) Various builds failing with "Corrupted STDOUT by directly writing"

2020-04-05 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16973: --- Labels: pull-request-available test-stability (was: test-stability) > Various builds failin

[GitHub] [flink] flinkbot edited a comment on issue #11637: [FLINK-16913][configuration] Support more getters in the ReadableConfigToConfigurationAdapter

2020-04-05 Thread GitBox
flinkbot edited a comment on issue #11637: [FLINK-16913][configuration] Support more getters in the ReadableConfigToConfigurationAdapter URL: https://github.com/apache/flink/pull/11637#issuecomment-609406909 ## CI report: * 0bbf1c204fa76349f6e905b551563f26ed00fc2f Travis: [SUCCE

[GitHub] [flink] rmetzger opened a new pull request #11638: [FLINK-16973][tests] Add tooling for collecting jvm crash files

2020-04-05 Thread GitBox
rmetzger opened a new pull request #11638: [FLINK-16973][tests] Add tooling for collecting jvm crash files URL: https://github.com/apache/flink/pull/11638 ## What is the purpose of the change A lot of tests are failing because of crashed JVMs. This PR will add some tooling to sear

[GitHub] [flink] flinkbot edited a comment on issue #11635: [FLINK-16979][hive][build] Exclude jdk.tools

2020-04-05 Thread GitBox
flinkbot edited a comment on issue #11635: [FLINK-16979][hive][build] Exclude jdk.tools URL: https://github.com/apache/flink/pull/11635#issuecomment-609393178 ## CI report: * 0f29e25d824a5d882e8bdad2aa483c1223f891bb Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/b

[GitHub] [flink] flinkbot edited a comment on issue #11622: [FLINK-16913][configuration, statebackend] Migrated StateBackends to use ReadableConfig instead of Configuration

2020-04-05 Thread GitBox
flinkbot edited a comment on issue #11622: [FLINK-16913][configuration, statebackend] Migrated StateBackends to use ReadableConfig instead of Configuration URL: https://github.com/apache/flink/pull/11622#issuecomment-607942457 ## CI report: * 46e2d9b408be3eecbd83a8aeb8bd1aa911cd

  1   2   >