[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 #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:

[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] 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] 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

[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] 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.

[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] 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

[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 #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:

[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 #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] 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-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] 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] 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_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_r488360039 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManagerDriver.java ## @@ -72,354 +62,237 @@ import java.util.ArrayList;

[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] 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. >

[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] [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,

[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

[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] [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] [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] [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-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

[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-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

[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:

[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] [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] 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

[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

[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: 

[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-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] 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

[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-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

[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-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-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

[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:

[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] [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] HuangXingBo opened a new pull request #13388: [FLINK-19184][python] Add Batch Physical Pandas Group Aggregate Rule and RelNode

2020-09-14 Thread GitBox
HuangXingBo opened a new pull request #13388: URL: https://github.com/apache/flink/pull/13388 ## What is the purpose of the change *This pull request will add Batch Physical Pandas Group Aggregate Rule and RelNode* ## Brief change log - *add

[jira] [Created] (FLINK-19229) Support ValueState and Python UDAF on blink stream planner

2020-09-14 Thread Wei Zhong (Jira)
Wei Zhong created FLINK-19229: - Summary: Support ValueState and Python UDAF on blink stream planner Key: FLINK-19229 URL: https://issues.apache.org/jira/browse/FLINK-19229 Project: Flink Issue

[jira] [Created] (FLINK-19228) Avoid accessing FileSystem in client for file system connector

2020-09-14 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-19228: Summary: Avoid accessing FileSystem in client for file system connector Key: FLINK-19228 URL: https://issues.apache.org/jira/browse/FLINK-19228 Project: Flink

[GitHub] [flink] RocMarshal commented on a change in 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
RocMarshal commented on a change in pull request #13225: URL: https://github.com/apache/flink/pull/13225#discussion_r488333064 ## File path: docs/dev/user_defined_functions.zh.md ## @@ -147,95 +153,78 @@ data.map (new RichMapFunction[String, Int] { -Rich functions

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

2020-09-14 Thread GitBox
shuiqiangchen commented on a change in pull request #16: URL: https://github.com/apache/flink-playgrounds/pull/16#discussion_r488335267 ## File path: pyflink-walkthrough/payment_msg_proccessing.py ## @@ -0,0 +1,93 @@

[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] [Updated] (FLINK-19193) Recommend stop-with-savepoint in upgrade guidelines

2020-09-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19193: Fix Version/s: (was: 1.11.2) 1.11.3 > Recommend stop-with-savepoint in upgrade

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

2020-09-14 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-19227: - Description: > When I create the HiveCatalog and Flink is not able to connect to the

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

2020-09-14 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-19227: - Issue Type: Bug (was: New Feature) > The catalog is still created after opening failed in

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

2020-09-14 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-19227: Summary: The catalog is still created after opening failed in catalog registering Key: FLINK-19227 URL: https://issues.apache.org/jira/browse/FLINK-19227 Project:

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

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

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

2020-09-14 Thread GitBox
flinkbot commented on pull request #13387: URL: https://github.com/apache/flink/pull/13387#issuecomment-692403820 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] wangxlong opened a new pull request #13387: [Hotfix][typos]Modify debug log to print the compiling code

2020-09-14 Thread GitBox
wangxlong opened a new pull request #13387: URL: https://github.com/apache/flink/pull/13387 ## What is the purpose of the change Modify debug log to print the compiling code. ## Brief change log Modify function name to compiling code in

[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:

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

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

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

2020-09-14 Thread GitBox
flinkbot commented on pull request #13386: URL: https://github.com/apache/flink/pull/13386#issuecomment-692377293 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] [Updated] (FLINK-19226) [Kinesis] [EFO] Connector reaches default max attempts for describeStream and describeStreamConsumer when parallelism is high

2020-09-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19226: --- Labels: pull-request-available (was: ) > [Kinesis] [EFO] Connector reaches default max

[GitHub] [flink] hlteoh37 opened a new pull request #13386: [FLINK-19226][Kinesis] Updated FullJitterBackoff defaults for describeStream and describeStreamConsumer

2020-09-14 Thread GitBox
hlteoh37 opened a new pull request #13386: URL: https://github.com/apache/flink/pull/13386 ## What is the purpose of the change Allow FlinkKinesisConsumer to use EFO record publisher with higher parallelism using the default config values. ## Brief change log -

[jira] [Created] (FLINK-19226) [Kinesis] [EFO] Connector reaches default max attempts for describeStream and describeStreamConsumer when parallelism is high

2020-09-14 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-19226: --- Summary: [Kinesis] [EFO] Connector reaches default max attempts for describeStream and describeStreamConsumer when parallelism is high Key: FLINK-19226 URL:

[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:

[GitHub] [flink] StephanEwen commented on pull request #13344: [FLINK-10740] FLIP-27 File Source and various Updates on the Split Reader API

2020-09-14 Thread GitBox
StephanEwen commented on pull request #13344: URL: https://github.com/apache/flink/pull/13344#issuecomment-692360653 The tests in this PR fail due to bugs fixed in #13385 This is an automated message from the Apache Git

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

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

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

2020-09-14 Thread GitBox
flinkbot commented on pull request #13385: URL: https://github.com/apache/flink/pull/13385#issuecomment-692355155 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] StephanEwen commented on pull request #13366: [FLINK-17393][connector/common] Wakeup the SplitFetchers more elegantly.

2020-09-14 Thread GitBox
StephanEwen commented on pull request #13366: URL: https://github.com/apache/flink/pull/13366#issuecomment-692355604 I incorporated this PR in a follow-up PR with some more changes and bug fixes: #13385 This is an automated

[jira] [Updated] (FLINK-18128) CoordinatedSourceITCase.testMultipleSources gets stuck

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

[GitHub] [flink] StephanEwen opened a new pull request #13385: [FLINK-18128][FLINK-19223][connectors] Fixes to Connector Base Availability logic

2020-09-14 Thread GitBox
StephanEwen opened a new pull request #13385: URL: https://github.com/apache/flink/pull/13385 ## What is the purpose of the change This PR fixes bugs in the connector base (`SourceReaderBase` and `SplitFetcher`) availability logic. This could previously lead to conditions where

[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] [Created] (FLINK-19225) Improve code and logging in SourceReaderBase

2020-09-14 Thread Stephan Ewen (Jira)
Stephan Ewen created FLINK-19225: Summary: Improve code and logging in SourceReaderBase Key: FLINK-19225 URL: https://issues.apache.org/jira/browse/FLINK-19225 Project: Flink Issue Type:

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

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

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

2020-09-14 Thread GitBox
flinkbot commented on pull request #13384: URL: https://github.com/apache/flink/pull/13384#issuecomment-692328370 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] sjwiesman commented on pull request #13384: [FLINK-19224][state-processor-api] Support reading window operator state

2020-09-14 Thread GitBox
sjwiesman commented on pull request #13384: URL: https://github.com/apache/flink/pull/13384#issuecomment-692328179 @alpinegizmo would you like to take a look at this. This PR is mostly boilerplate to support all the different window operator configurations. All the actual runtime changes

[GitHub] [flink] sjwiesman opened a new pull request #13384: [FLINK-19224][state-processor-api] Support reading window operator state

2020-09-14 Thread GitBox
sjwiesman opened a new pull request #13384: URL: https://github.com/apache/flink/pull/13384 ## What is the purpose of the change Add support for reading window operator state with the state processor api. This includes: - TimeWindows and other arbitrary window types -

[jira] [Updated] (FLINK-19224) Provide an easy way to read window state

2020-09-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19224: --- Labels: pull-request-available (was: ) > Provide an easy way to read window state >

[jira] [Created] (FLINK-19224) Provide an easy way to read window state

2020-09-14 Thread Seth Wiesman (Jira)
Seth Wiesman created FLINK-19224: Summary: Provide an easy way to read window state Key: FLINK-19224 URL: https://issues.apache.org/jira/browse/FLINK-19224 Project: Flink Issue Type:

[jira] [Commented] (FLINK-18128) CoordinatedSourceITCase.testMultipleSources gets stuck

2020-09-14 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17195735#comment-17195735 ] Stephan Ewen commented on FLINK-18128: -- The problem is the following: - When the fetching thread

[jira] [Created] (FLINK-19223) Simplify Availability Future Model in Base Connector

2020-09-14 Thread Stephan Ewen (Jira)
Stephan Ewen created FLINK-19223: Summary: Simplify Availability Future Model in Base Connector Key: FLINK-19223 URL: https://issues.apache.org/jira/browse/FLINK-19223 Project: Flink Issue

[jira] [Updated] (FLINK-19209) Single bucket

2020-09-14 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-19209: - Priority: Minor (was: Major) > Single bucket > - > > Key:

[jira] [Commented] (FLINK-19209) Single bucket

2020-09-14 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17195732#comment-17195732 ] Seth Wiesman commented on FLINK-19209: -- thanks for catching this! > Single bucket > -

[jira] [Assigned] (FLINK-19209) Single bucket

2020-09-14 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman reassigned FLINK-19209: Assignee: Seth Wiesman > Single bucket > - > > Key:

[GitHub] [flink] flinkbot edited a comment on pull request #13383: [FLINK-15467][task] Wait for sourceTaskThread to finish before exiting from StreamTask.invoke [1.10]

2020-09-14 Thread GitBox
flinkbot edited a comment on pull request #13383: URL: https://github.com/apache/flink/pull/13383#issuecomment-692066644 ## CI report: * 75eb7195c13f8641a58870c1ae2861c1302e437c Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/184220187) *

[jira] [Closed] (FLINK-18978) Support full table scan of key and namespace from statebackend

2020-09-14 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman closed FLINK-18978. Resolution: Fixed > Support full table scan of key and namespace from statebackend >

[jira] [Commented] (FLINK-18978) Support full table scan of key and namespace from statebackend

2020-09-14 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17195728#comment-17195728 ] Seth Wiesman commented on FLINK-18978: -- fixed in cd81e9bbbd7456e6aedbff31054700cc4da70fa3 >

  1   2   3   >