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

2020-09-14 Thread GitBox
KarmaGYZ commented on a change in pull request #13311: URL: https://github.com/apache/flink/pull/13311#discussion_r488361230 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManagerDriver.java ## @@ -72,354 +62,237 @@ import java.util.ArrayList;

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

2020-09-14 Thread GitBox
KarmaGYZ commented on a change in pull request #13311: URL: https://github.com/apache/flink/pull/13311#discussion_r488366730 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManagerDriver.java ## @@ -508,52 +371,103 @@ private void

[GitHub] [flink] flinkbot edited a comment on pull request #13225: [FLINK-18974][docs-zh]Translate the 'User-Defined Functions' page of "Application Development's DataStream API" into Chinese

2020-09-14 Thread GitBox
flinkbot edited a comment on pull request #13225: URL: https://github.com/apache/flink/pull/13225#issuecomment-678953566 ## CI report: * 9d52b2bde1c0a87d20aac1d7057f231b433d353e Azure:

[GitHub] [flink] zhuxiaoshang commented on pull request #13225: [FLINK-18974][docs-zh]Translate the 'User-Defined Functions' page of "Application Development's DataStream API" into Chinese

2020-09-14 Thread GitBox
zhuxiaoshang commented on pull request #13225: URL: https://github.com/apache/flink/pull/13225#issuecomment-692442654 > @zhuxiaoshang thanks for your contribution, left some comments based on the item `5. 中文标点符号` of

[GitHub] [flink] flinkbot edited a comment on pull request #13225: [FLINK-18974][docs-zh]Translate the 'User-Defined Functions' page of "Application Development's DataStream API" into Chinese

2020-09-14 Thread GitBox
flinkbot edited a comment on pull request #13225: URL: https://github.com/apache/flink/pull/13225#issuecomment-678953566 ## CI report: * 9d52b2bde1c0a87d20aac1d7057f231b433d353e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13386: [FLINK-19226][Kinesis] Updated FullJitterBackoff defaults for describeStream and describeStreamConsumer

2020-09-14 Thread GitBox
flinkbot edited a comment on pull request #13386: URL: https://github.com/apache/flink/pull/13386#issuecomment-692379768 ## CI report: * 61a8bc9d3ddb52628c042b240829ef977b1fe6f2 Azure:

[jira] [Updated] (FLINK-19158) Revisit java e2e download timeouts

2020-09-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19158: --- Labels: pull-request-available test-stability (was: test-stability) > Revisit java e2e

[GitHub] [flink] flinkbot commented on pull request #13389: [FLINK-19158][e2e] Increase download timeouts

2020-09-14 Thread GitBox
flinkbot commented on pull request #13389: URL: https://github.com/apache/flink/pull/13389#issuecomment-692480858 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 #13390: [FLINK-19037] Forward ioExecutor from ClusterEntrypoint to Dispatcher

2020-09-14 Thread GitBox
rmetzger opened a new pull request #13390: URL: https://github.com/apache/flink/pull/13390 ## What is the purpose of the change Before this change, the dispatcher was using the executor of the RPC service for executing IO or heavy tasks. Now, we forward the ioExecutor of the

[jira] [Updated] (FLINK-19037) Introduce proper IO executor in Dispatcher

2020-09-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19037: --- Labels: pull-request-available (was: ) > Introduce proper IO executor in Dispatcher >

[GitHub] [flink-playgrounds] shuiqiangchen edited a comment on pull request #16: [FLINK-19145][walkthroughs] Add PyFlink-walkthrough to Flink playground.

2020-09-14 Thread GitBox
shuiqiangchen edited a comment on pull request #16: URL: https://github.com/apache/flink-playgrounds/pull/16#issuecomment-692423562 Hi @morsapaes @alpinegizmo , sorry for the late reply, I was on vacation in the last four days. Highly appreciate for @morsapaes valuable comments and warmly

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

2020-09-14 Thread GitBox
KarmaGYZ commented on a change in pull request #13311: URL: https://github.com/apache/flink/pull/13311#discussion_r488363795 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManagerDriver.java ## @@ -435,53 +308,43 @@ private void

[GitHub] [flink] flinkbot commented on pull request #13389: [FLINK-19158][e2e] Increase download timeouts

2020-09-14 Thread GitBox
flinkbot commented on pull request #13389: URL: https://github.com/apache/flink/pull/13389#issuecomment-692483165 ## CI report: * c6fd8544c7108eb05c21a24f4b897193219187a9 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #13387: [Hotfix][typos]Modify debug log to print the compiling code

2020-09-14 Thread GitBox
flinkbot edited a comment on pull request #13387: URL: https://github.com/apache/flink/pull/13387#issuecomment-692407926 ## CI report: * 5ae3077ffa0d5f79358008be1515a7985706c062 Azure:

[jira] [Commented] (FLINK-18366) Track E2E test durations centrally

2020-09-14 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17195888#comment-17195888 ] Robert Metzger commented on FLINK-18366: Slow run:

[GitHub] [flink] flinkbot commented on pull request #13390: [FLINK-19037] Forward ioExecutor from ClusterEntrypoint to Dispatcher

2020-09-14 Thread GitBox
flinkbot commented on pull request #13390: URL: https://github.com/apache/flink/pull/13390#issuecomment-692482079 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] KarmaGYZ commented on a change in pull request #13311: [FLINK-18721] Migrate YarnResourceManager to the new YarnResourceManagerDriver

2020-09-14 Thread GitBox
KarmaGYZ commented on a change in pull request #13311: URL: https://github.com/apache/flink/pull/13311#discussion_r488362483 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManagerDriver.java ## @@ -435,53 +308,43 @@ private void

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

2020-09-14 Thread GitBox
KarmaGYZ commented on a change in pull request #13311: URL: https://github.com/apache/flink/pull/13311#discussion_r488391778 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/TaskExecutorProcessSpec.java ## @@ -141,6 +143,24 @@ public

[GitHub] [flink] flinkbot edited a comment on pull request #13225: [FLINK-18974][docs-zh]Translate the 'User-Defined Functions' page of "Application Development's DataStream API" into Chinese

2020-09-14 Thread GitBox
flinkbot edited a comment on pull request #13225: URL: https://github.com/apache/flink/pull/13225#issuecomment-678953566 ## CI report: * 313c6760e7d491540ab8d782b87ee2c637d9b5ab Azure:

[GitHub] [flink] rmetzger opened a new pull request #13389: [FLINK-19158][e2e] Increase download timeouts

2020-09-14 Thread GitBox
rmetzger opened a new pull request #13389: URL: https://github.com/apache/flink/pull/13389 ## What is the purpose of the change Increase build stability: some Java e2e tests were failing due to timeout errors. With this PR, we are more generous with the timeouts.

[jira] [Commented] (FLINK-17137) Support mini batch for WindowOperator in blink planner

2020-09-14 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17195873#comment-17195873 ] Benchao Li commented on FLINK-17137: [~tartarus] Would you like to contribute it back to the

[GitHub] [flink] flinkbot edited a comment on pull request #13384: [FLINK-19224][state-processor-api] Support reading window operator state

2020-09-14 Thread GitBox
flinkbot edited a comment on pull request #13384: URL: https://github.com/apache/flink/pull/13384#issuecomment-692330852 ## CI report: * 2e73e742abe73fd0324c3647403131817ef2aada Azure:

[jira] [Updated] (FLINK-19184) Add Batch Physical Pandas Group Aggregate Rule and RelNode

2020-09-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19184: --- Labels: pull-request-available (was: ) > Add Batch Physical Pandas Group Aggregate Rule

[GitHub] [flink] flinkbot commented on pull request #13388: [FLINK-19184][python] Add Batch Physical Pandas Group Aggregate Rule and RelNode

2020-09-14 Thread GitBox
flinkbot commented on pull request #13388: URL: https://github.com/apache/flink/pull/13388#issuecomment-692417535 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] [Created] (FLINK-19235) Support mixed use with built-in aggs for Python UDAF

2020-09-14 Thread Wei Zhong (Jira)
Wei Zhong created FLINK-19235: - Summary: Support mixed use with built-in aggs for Python UDAF Key: FLINK-19235 URL: https://issues.apache.org/jira/browse/FLINK-19235 Project: Flink Issue Type:

[jira] [Created] (FLINK-19230) Support Python UDAF on blink batch planner

2020-09-14 Thread Wei Zhong (Jira)
Wei Zhong created FLINK-19230: - Summary: Support Python UDAF on blink batch planner Key: FLINK-19230 URL: https://issues.apache.org/jira/browse/FLINK-19230 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-19231) Support ListState and ListView for Python UDAF

2020-09-14 Thread Wei Zhong (Jira)
Wei Zhong created FLINK-19231: - Summary: Support ListState and ListView for Python UDAF Key: FLINK-19231 URL: https://issues.apache.org/jira/browse/FLINK-19231 Project: Flink Issue Type:

[jira] [Created] (FLINK-19232) Support MapState and MapView for Python UDAF

2020-09-14 Thread Wei Zhong (Jira)
Wei Zhong created FLINK-19232: - Summary: Support MapState and MapView for Python UDAF Key: FLINK-19232 URL: https://issues.apache.org/jira/browse/FLINK-19232 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-19236) Optimize the performance of Python UDAF

2020-09-14 Thread Wei Zhong (Jira)
Wei Zhong created FLINK-19236: - Summary: Optimize the performance of Python UDAF Key: FLINK-19236 URL: https://issues.apache.org/jira/browse/FLINK-19236 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-19234) Support FILTER KeyWord for Python UDAF

2020-09-14 Thread Wei Zhong (Jira)
Wei Zhong created FLINK-19234: - Summary: Support FILTER KeyWord for Python UDAF Key: FLINK-19234 URL: https://issues.apache.org/jira/browse/FLINK-19234 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-19233) Support DISTINCT KeyWord for Python UDAF

2020-09-14 Thread Wei Zhong (Jira)
Wei Zhong created FLINK-19233: - Summary: Support DISTINCT KeyWord for Python UDAF Key: FLINK-19233 URL: https://issues.apache.org/jira/browse/FLINK-19233 Project: Flink Issue Type: Sub-task

[GitHub] [flink] flinkbot commented on pull request #13388: [FLINK-19184][python] Add Batch Physical Pandas Group Aggregate Rule and RelNode

2020-09-14 Thread GitBox
flinkbot commented on pull request #13388: URL: https://github.com/apache/flink/pull/13388#issuecomment-692422938 ## CI report: * 6d3f77bd08ed3dba62375807a06325e320b98fb3 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink-playgrounds] shuiqiangchen edited a comment on pull request #16: [FLINK-19145][walkthroughs] Add PyFlink-walkthrough to Flink playground.

2020-09-14 Thread GitBox
shuiqiangchen edited a comment on pull request #16: URL: https://github.com/apache/flink-playgrounds/pull/16#issuecomment-692423562 Hi @morsapaes @alpinegizmo , sorry for the late reply, I was on vacation in the last four days. Highly appreciate for @morsapaes valuable comments and warmly

[GitHub] [flink-playgrounds] shuiqiangchen commented on pull request #16: [FLINK-19145][walkthroughs] Add PyFlink-walkthrough to Flink playground.

2020-09-14 Thread GitBox
shuiqiangchen commented on pull request #16: URL: https://github.com/apache/flink-playgrounds/pull/16#issuecomment-692423562 Hi @morsapaes @alpinegizmo , sorry for the late reply, I was on vacation in the last four days. Highly appreciate for @morsapaes valuable comments and warmly

[GitHub] [flink] pyscala commented on pull request #13276: [FLINK-18604][connectors/HBase] HBase ConnectorDescriptor can not work in Table API

2020-09-14 Thread GitBox
pyscala commented on pull request #13276: URL: https://github.com/apache/flink/pull/13276#issuecomment-692424268 @JingsongLi I finished and hope you take a look, thanks. This is an automated message from the Apache Git

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

2020-09-14 Thread GitBox
KarmaGYZ commented on a change in pull request #13311: URL: https://github.com/apache/flink/pull/13311#discussion_r488345856 ## File path: flink-yarn/src/test/java/org/apache/flink/yarn/TestingYarnNMClientAsync.java ## @@ -34,11 +34,25 @@ */ class TestingYarnNMClientAsync

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

2020-09-14 Thread GitBox
KarmaGYZ commented on a change in pull request #13311: URL: https://github.com/apache/flink/pull/13311#discussion_r488345943 ## File path: flink-yarn/src/test/java/org/apache/flink/yarn/TestingYarnNMClientAsync.java ## @@ -51,30 +65,74 @@ public void

[jira] [Commented] (FLINK-17949) KafkaShuffleITCase.testSerDeIngestionTime:156->testRecordSerDe:388 expected:<310> but was:<0>

2020-09-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17195819#comment-17195819 ] Dian Fu commented on FLINK-17949: - Another instance on 1.11: 

[jira] [Comment Edited] (FLINK-19167) Proccess Function Example could not work

2020-09-14 Thread tinny cat (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17193306#comment-17193306 ] tinny cat edited comment on FLINK-19167 at 9/15/20, 2:38 AM: - the watermark

[GitHub] [flink] flinkbot edited a comment on pull request #13388: [FLINK-19184][python] Add Batch Physical Pandas Group Aggregate Rule and RelNode

2020-09-14 Thread GitBox
flinkbot edited a comment on pull request #13388: URL: https://github.com/apache/flink/pull/13388#issuecomment-692422938 ## CI report: * 6d3f77bd08ed3dba62375807a06325e320b98fb3 Azure:

[jira] [Commented] (FLINK-19167) Proccess Function Example could not work

2020-09-14 Thread tinny cat (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17195831#comment-17195831 ] tinny cat commented on FLINK-19167: --- the timer method did fired, but this if statement will not hold:

[jira] [Commented] (FLINK-19207) TtlListState#IteratorWithCleanup support remove method

2020-09-14 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17195832#comment-17195832 ] Jark Wu commented on FLINK-19207: - Hi [~lsy], remove on the returned iterator can't remove the element

[GitHub] [flink] flinkbot edited a comment on pull request #13385: [FLINK-18128][FLINK-19223][connectors] Fixes to Connector Base Availability logic

2020-09-14 Thread GitBox
flinkbot edited a comment on pull request #13385: URL: https://github.com/apache/flink/pull/13385#issuecomment-692360622 ## CI report: * 0231272dac19c37325c150946ad3f87416e7b6b5 Azure:

[jira] [Commented] (FLINK-19196) FlinkSQL aggregation function to aggregate array typed column to Map/Multiset

2020-09-14 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17195836#comment-17195836 ] Jark Wu commented on FLINK-19196: - Hi, Flink doesn't provide such built-in function yet. You can

[jira] [Comment Edited] (FLINK-19196) FlinkSQL aggregation function to aggregate array typed column to Map/Multiset

2020-09-14 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17195836#comment-17195836 ] Jark Wu edited comment on FLINK-19196 at 9/15/20, 3:03 AM: --- Hi, Flink doesn't

[jira] [Comment Edited] (FLINK-19196) FlinkSQL aggregation function to aggregate array typed column to Map/Multiset

2020-09-14 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17195836#comment-17195836 ] Jark Wu edited comment on FLINK-19196 at 9/15/20, 3:04 AM: --- Hi, Flink doesn't

[jira] [Commented] (FLINK-19194) The UDF split and split_index get wrong result

2020-09-14 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17195837#comment-17195837 ] Jark Wu commented on FLINK-19194: - Hi [~faaronzheng], I'm not sure this is a bug in Table/SQL. Flink

[jira] [Commented] (FLINK-19194) The UDF split and split_index get wrong result

2020-09-14 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17195838#comment-17195838 ] Jark Wu commented on FLINK-19194: - Could you provide a program which can reproduce your result? > The

[jira] [Updated] (FLINK-19227) The catalog is still created after opening failed in catalog registering

2020-09-14 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19227: Labels: starter (was: ) > The catalog is still created after opening failed in catalog registering >

[jira] [Updated] (FLINK-19237) LeaderChangeClusterComponentsTest.testReelectionOfJobMaster failed with "NoResourceAvailableException: Could not allocate the required slot within slot request timeout"

2020-09-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19237: Labels: test-stability (was: ) > LeaderChangeClusterComponentsTest.testReelectionOfJobMaster failed with

[jira] [Created] (FLINK-19237) LeaderChangeClusterComponentsTest.testReelectionOfJobMaster failed with "NoResourceAvailableException: Could not allocate the required slot within slot request timeout"

2020-09-14 Thread Dian Fu (Jira)
Dian Fu created FLINK-19237: --- Summary: LeaderChangeClusterComponentsTest.testReelectionOfJobMaster failed with "NoResourceAvailableException: Could not allocate the required slot within slot request timeout" Key: FLINK-19237

[GitHub] [flink] wuchong merged pull request #13352: [FLINK-19092][sql-parser] Parse comment on computed column failed

2020-09-14 Thread GitBox
wuchong merged pull request #13352: URL: https://github.com/apache/flink/pull/13352 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] [Commented] (FLINK-19237) LeaderChangeClusterComponentsTest.testReelectionOfJobMaster failed with "NoResourceAvailableException: Could not allocate the required slot within slot request timeout

2020-09-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17195842#comment-17195842 ] Dian Fu commented on FLINK-19237: - This issue and FLINK-19210 seems caused of the same problem. >

[jira] [Commented] (FLINK-17137) Support mini batch for WindowOperator in blink planner

2020-09-14 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17195841#comment-17195841 ] tartarus commented on FLINK-17137: -- [~libenchao] we have done the local-global optimization for window,

[GitHub] [flink] wuchong commented on pull request #13352: [FLINK-19092][sql-parser] Parse comment on computed column failed

2020-09-14 Thread GitBox
wuchong commented on pull request #13352: URL: https://github.com/apache/flink/pull/13352#issuecomment-692439120 Mering... This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Updated] (FLINK-19092) Parse comment on computed column failed

2020-09-14 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19092: Issue Type: New Feature (was: Bug) > Parse comment on computed column failed >

[jira] [Closed] (FLINK-19092) Parse comment on computed column failed

2020-09-14 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-19092. --- Resolution: Fixed Implemented in master (1.12.0): b873564357612bbea788332632955fc256105d35 > Parse comment

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

2020-09-14 Thread GitBox
KarmaGYZ commented on a change in pull request #13311: URL: https://github.com/apache/flink/pull/13311#discussion_r488360039 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManagerDriver.java ## @@ -72,354 +62,237 @@ import java.util.ArrayList;

[jira] [Commented] (FLINK-17328) Expose network metric for job vertex in rest api

2020-09-14 Thread lining (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17195262#comment-17195262 ] lining commented on FLINK-17328: WebUI has monitor backpressure. But users need to know current and

[jira] [Assigned] (FLINK-19188) Add a new streaming SQL examples

2020-09-14 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-19188: Assignee: Timo Walther > Add a new streaming SQL examples >

[GitHub] [flink] flinkbot edited a comment on pull request #13276: [FLINK-18604][connectors/HBase] HBase ConnectorDescriptor can not work in Table API

2020-09-14 Thread GitBox
flinkbot edited a comment on pull request #13276: URL: https://github.com/apache/flink/pull/13276#issuecomment-682412809 ## CI report: * 2a5f47d699973aae920f37649b6291e08e254200 Azure:

[GitHub] [flink] flinkbot commented on pull request #13378: 1

2020-09-14 Thread GitBox
flinkbot commented on pull request #13378: URL: https://github.com/apache/flink/pull/13378#issuecomment-691912364 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] lijufeng2016 closed pull request #13379: 1

2020-09-14 Thread GitBox
lijufeng2016 closed pull request #13379: URL: https://github.com/apache/flink/pull/13379 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

[GitHub] [flink] lijufeng2016 commented on pull request #13379: 1

2020-09-14 Thread GitBox
lijufeng2016 commented on pull request #13379: URL: https://github.com/apache/flink/pull/13379#issuecomment-691912259 1 This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] lijufeng2016 opened a new pull request #13379: 1

2020-09-14 Thread GitBox
lijufeng2016 opened a new pull request #13379: URL: https://github.com/apache/flink/pull/13379 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring

[GitHub] [flink] lijufeng2016 closed pull request #13378: 1

2020-09-14 Thread GitBox
lijufeng2016 closed pull request #13378: URL: https://github.com/apache/flink/pull/13378 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

[jira] [Comment Edited] (FLINK-19195) question on security vulnerabilities in flink

2020-09-14 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17195307#comment-17195307 ] Chesnay Schepler edited comment on FLINK-19195 at 9/14/20, 9:00 AM:

[GitHub] [flink] flinkbot edited a comment on pull request #13225: [FLINK-18974][docs-zh]Translate the 'User-Defined Functions' page of "Application Development's DataStream API" into Chinese

2020-09-14 Thread GitBox
flinkbot edited a comment on pull request #13225: URL: https://github.com/apache/flink/pull/13225#issuecomment-678953566 ## CI report: * 9d52b2bde1c0a87d20aac1d7057f231b433d353e Azure:

[jira] [Commented] (FLINK-19195) question on security vulnerabilities in flink

2020-09-14 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17195307#comment-17195307 ] Chesnay Schepler commented on FLINK-19195: -- FLINK-16961 bumped the netty version for transitive

[GitHub] [flink] dawidwys commented on a change in pull request #13360: [FLINK-19152] Remove Kafka 0.10.x and 0.11.x connectors

2020-09-14 Thread GitBox
dawidwys commented on a change in pull request #13360: URL: https://github.com/apache/flink/pull/13360#discussion_r487769851 ## File path: docs/dev/connectors/kafka.md ## @@ -554,14 +551,26 @@ A mismatch in service name between client and server configuration will cause th

[GitHub] [flink] flinkbot edited a comment on pull request #13276: [FLINK-18604][connectors/HBase] HBase ConnectorDescriptor can not work in Table API

2020-09-14 Thread GitBox
flinkbot edited a comment on pull request #13276: URL: https://github.com/apache/flink/pull/13276#issuecomment-682412809 ## CI report: * a46b14b67415ec7548e9f1444b1478096170cbb0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13319: [FLINK-19022][runtime]Register the TerminationFuture of ResourceManager and Dispatcher with DispatcherResourceManagerComponent

2020-09-14 Thread GitBox
flinkbot edited a comment on pull request #13319: URL: https://github.com/apache/flink/pull/13319#issuecomment-686508323 ## CI report: * 9fab4d5bbccc29d78dee92726cce852421e40541 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13319: [FLINK-19022][runtime]Register the TerminationFuture of ResourceManager and Dispatcher with DispatcherResourceManagerComponent

2020-09-14 Thread GitBox
flinkbot edited a comment on pull request #13319: URL: https://github.com/apache/flink/pull/13319#issuecomment-686508323 ## CI report: * 9fab4d5bbccc29d78dee92726cce852421e40541 Azure:

[jira] [Commented] (FLINK-16768) HadoopS3RecoverableWriterITCase.testRecoverWithStateWithMultiPart hangs

2020-09-14 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17195385#comment-17195385 ] Robert Metzger commented on FLINK-16768: I agree that it is a good idea to cherry-pick the

[jira] [Comment Edited] (FLINK-16768) HadoopS3RecoverableWriterITCase.testRecoverWithStateWithMultiPart hangs

2020-09-14 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17195385#comment-17195385 ] Robert Metzger edited comment on FLINK-16768 at 9/14/20, 11:09 AM: --- I

[GitHub] [flink] twalthr commented on a change in pull request #13373: [FLINK-18802] Upgrade avro to 1.10

2020-09-14 Thread GitBox
twalthr commented on a change in pull request #13373: URL: https://github.com/apache/flink/pull/13373#discussion_r487694408 ## File path: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroSchemaConverter.java ## @@ -255,28 +257,24 @@ private

[jira] [Assigned] (FLINK-18192) Upgrade to Avro version 1.9.2 from 1.8.2

2020-09-14 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-18192: Assignee: Dawid Wysakowicz > Upgrade to Avro version 1.9.2 from 1.8.2 >

[jira] [Updated] (FLINK-18192) Upgrade to Avro version 1.9.2 from 1.8.2

2020-09-14 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-18192: - Component/s: (was: Build System) > Upgrade to Avro version 1.9.2 from 1.8.2 >

[GitHub] [flink] dawidwys commented on a change in pull request #13373: [FLINK-18802] Upgrade avro to 1.10

2020-09-14 Thread GitBox
dawidwys commented on a change in pull request #13373: URL: https://github.com/apache/flink/pull/13373#discussion_r487738769 ## File path: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroSchemaConverter.java ## @@ -255,28 +257,24 @@ private

[jira] [Commented] (FLINK-18842) e2e test failed to download "localhost:9999/flink.tgz" in "Wordcount on Docker test"

2020-09-14 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17195300#comment-17195300 ] Chesnay Schepler commented on FLINK-18842: -- Maybe we could harden the start of the fileserver;

[jira] [Closed] (FLINK-19195) question on security vulnerabilities in flink

2020-09-14 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-19195. -- Resolution: Duplicate > question on security vulnerabilities in flink >

[jira] [Commented] (FLINK-19195) question on security vulnerabilities in flink

2020-09-14 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17195369#comment-17195369 ] Robert Metzger commented on FLINK-19195: Thanks. Closing this ticket. > question on security

[GitHub] [flink] flinkbot edited a comment on pull request #13225: [FLINK-18974][docs-zh]Translate the 'User-Defined Functions' page of "Application Development's DataStream API" into Chinese

2020-09-14 Thread GitBox
flinkbot edited a comment on pull request #13225: URL: https://github.com/apache/flink/pull/13225#issuecomment-678953566 ## CI report: * f6141fa38f42a92fe10ca6b707813f0253ba5f3f Azure:

[GitHub] [flink] dawidwys commented on a change in pull request #13373: [FLINK-18802] Upgrade avro to 1.10

2020-09-14 Thread GitBox
dawidwys commented on a change in pull request #13373: URL: https://github.com/apache/flink/pull/13373#discussion_r487722209 ## File path: flink-formats/pom.xml ## @@ -81,6 +81,7 @@ under the License. flink-sql-orc

[jira] [Comment Edited] (FLINK-19167) Proccess Function Example could not work

2020-09-14 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17195306#comment-17195306 ] Dawid Wysakowicz edited comment on FLINK-19167 at 9/14/20, 9:02 AM:

[GitHub] [flink] dawidwys commented on a change in pull request #13373: [FLINK-18802] Upgrade avro to 1.10

2020-09-14 Thread GitBox
dawidwys commented on a change in pull request #13373: URL: https://github.com/apache/flink/pull/13373#discussion_r487766920 ## File path: flink-formats/flink-avro/src/test/java/org/apache/flink/table/runtime/batch/AvroTypesITCase.java ## @@ -147,24 +150,26 @@ public

[GitHub] [flink] flinkbot edited a comment on pull request #13373: [FLINK-18802] Upgrade avro to 1.10

2020-09-14 Thread GitBox
flinkbot edited a comment on pull request #13373: URL: https://github.com/apache/flink/pull/13373#issuecomment-691085636 ## CI report: * 8396f34387c87703171a06563b15e0f0b2a53699 UNKNOWN * bab621c4f92387eef5bf0101a5b687e45c479f80 Azure:

[jira] [Closed] (FLINK-15587) Flink image does not run on OpenShift

2020-09-14 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-15587. -- Resolution: Not A Problem > Flink image does not run on OpenShift >

[jira] [Assigned] (FLINK-19158) Revisit java e2e download timeouts

2020-09-14 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-19158: -- Assignee: Robert Metzger > Revisit java e2e download timeouts >

[GitHub] [flink] twalthr commented on a change in pull request #13373: [FLINK-18802] Upgrade avro to 1.10

2020-09-14 Thread GitBox
twalthr commented on a change in pull request #13373: URL: https://github.com/apache/flink/pull/13373#discussion_r487696747 ## File path: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java ## @@ -75,12 +75,11 @@ */

[GitHub] [flink] twalthr commented on pull request #13373: [FLINK-18802] Upgrade avro to 1.10

2020-09-14 Thread GitBox
twalthr commented on pull request #13373: URL: https://github.com/apache/flink/pull/13373#issuecomment-691878539 Thanks for the update @dawidwys. I added my last set of comments. Feel free to merge afterwards if Azure is green.

[jira] [Created] (FLINK-19213) Update the Chinese documentation

2020-09-14 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-19213: Summary: Update the Chinese documentation Key: FLINK-19213 URL: https://issues.apache.org/jira/browse/FLINK-19213 Project: Flink Issue Type:

[jira] [Updated] (FLINK-19213) Update the Chinese documentation

2020-09-14 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-19213: - Priority: Trivial (was: Major) > Update the Chinese documentation >

[GitHub] [flink] twalthr commented on a change in pull request #13373: [FLINK-18802] Upgrade avro to 1.10

2020-09-14 Thread GitBox
twalthr commented on a change in pull request #13373: URL: https://github.com/apache/flink/pull/13373#discussion_r487723278 ## File path: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroSchemaConverter.java ## @@ -255,28 +257,24 @@ private

[jira] [Commented] (FLINK-16961) Bump Netty 4 to 4.1.44

2020-09-14 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17195305#comment-17195305 ] Chesnay Schepler commented on FLINK-16961: -- [~rmetzger] Flink-shaded-netty bumps are handled

[jira] [Commented] (FLINK-19195) question on security vulnerabilities in flink

2020-09-14 Thread Miguel Costa (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17195309#comment-17195309 ] Miguel Costa commented on FLINK-19195: -- [~chesnay] ok thank you for the feedback. I'm not following

[GitHub] [flink] echauchot edited a comment on pull request #13040: [FLINK-17073] [checkpointing] checkpointing backpressure if there are too many checkpoints to clean

2020-09-14 Thread GitBox
echauchot edited a comment on pull request #13040: URL: https://github.com/apache/flink/pull/13040#issuecomment-690156463 @ifndef-SleePy or @pnowojski @rkhachatryan I addressed all the comments PTAL. There is just the ITest to address left.

[jira] [Commented] (FLINK-15587) Flink image does not run on OpenShift

2020-09-14 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17195372#comment-17195372 ] Robert Metzger commented on FLINK-15587: Ah, nice. If our assumption that OpenShift only

[jira] [Comment Edited] (FLINK-19195) question on security vulnerabilities in flink

2020-09-14 Thread Miguel Costa (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17195309#comment-17195309 ] Miguel Costa edited comment on FLINK-19195 at 9/14/20, 10:54 AM: -

[GitHub] [flink] twalthr commented on a change in pull request #13373: [FLINK-18802] Upgrade avro to 1.10

2020-09-14 Thread GitBox
twalthr commented on a change in pull request #13373: URL: https://github.com/apache/flink/pull/13373#discussion_r487703709 ## File path: flink-formats/flink-avro/src/test/java/org/apache/flink/table/runtime/batch/AvroTypesITCase.java ## @@ -147,24 +150,26 @@ public

  1   2   3   >