[GitHub] [flink] rkhachatryan commented on pull request #13351: [FLINK-18990][task] Read channel state sequentially

rkhachatryan commented on pull request #13351: URL: https://github.com/apache/flink/pull/13351#issuecomment-700492276 Thanks for reviewing @AHeise and @pnowojski I've addressed your feedback, please take a look. This is a

[GitHub] [flink] rkhachatryan commented on a change in pull request #13351: [FLINK-18990][task] Read channel state sequentially

rkhachatryan commented on a change in pull request #13351: URL: https://github.com/apache/flink/pull/13351#discussion_r496457872 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/SequentialChannelStateReaderImpl.java ## @@ -0,0 +1,263 @@ +/*

[GitHub] [flink] SteNicholas commented on pull request #13434: [FLINK-19292][hive] HiveCatalog should support specifying Hadoop conf dir with configuration

SteNicholas commented on pull request #13434: URL: https://github.com/apache/flink/pull/13434#issuecomment-700489072 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, ple

[jira] [Commented] (FLINK-19445) Several tests for HBase connector 1.4 failed with "NoSuchMethodError: com.google.common.base.Preconditions.checkArgument(ZLjava/lang/String;Ljava/lang/Object;)V"

[ https://issues.apache.org/jira/browse/FLINK-19445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17203724#comment-17203724 ] Dian Fu commented on FLINK-19445: - This is from the nightly test which will run more kin

[jira] [Commented] (FLINK-19445) Several tests for HBase connector 1.4 failed with "NoSuchMethodError: com.google.common.base.Preconditions.checkArgument(ZLjava/lang/String;Ljava/lang/Object;)V"

[ https://issues.apache.org/jira/browse/FLINK-19445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17203721#comment-17203721 ] Gyula Fora commented on FLINK-19445: I wonder why these tests did not run for the PR

[jira] [Comment Edited] (FLINK-19447) HBaseConnectorITCase.HBaseTestingClusterAutoStarter failed with "Master not initialized after 200000ms"

[ https://issues.apache.org/jira/browse/FLINK-19447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17203719#comment-17203719 ] Dian Fu edited comment on FLINK-19447 at 9/29/20, 6:45 AM: --- cc

[jira] [Commented] (FLINK-19447) HBaseConnectorITCase.HBaseTestingClusterAutoStarter failed with "Master not initialized after 200000ms"

[ https://issues.apache.org/jira/browse/FLINK-19447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17203719#comment-17203719 ] Dian Fu commented on FLINK-19447: - cc [~mgergely] [~gyfora] > HBaseConnectorITCase.HBa

[jira] [Updated] (FLINK-19447) HBaseConnectorITCase.HBaseTestingClusterAutoStarter failed with "Master not initialized after 200000ms"

[ https://issues.apache.org/jira/browse/FLINK-19447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19447: Labels: test-stability (was: ) > HBaseConnectorITCase.HBaseTestingClusterAutoStarter failed with "Master

[jira] [Updated] (FLINK-19447) HBaseConnectorITCase.HBaseTestingClusterAutoStarter failed with "Master not initialized after 200000ms"

[ https://issues.apache.org/jira/browse/FLINK-19447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19447: Component/s: Tests > HBaseConnectorITCase.HBaseTestingClusterAutoStarter failed with "Master not > initia

[GitHub] [flink] flinkbot edited a comment on pull request #13500: [FLINK-19180][state backends] Make RocksDB respect managed memory fraction

flinkbot edited a comment on pull request #13500: URL: https://github.com/apache/flink/pull/13500#issuecomment-699908639 ## CI report: * bee5be24b69942ac4b6323da5bd701e8287f145b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Created] (FLINK-19447) HBaseConnectorITCase.HBaseTestingClusterAutoStarter failed with "Master not initialized after 200000ms"

Dian Fu created FLINK-19447: --- Summary: HBaseConnectorITCase.HBaseTestingClusterAutoStarter failed with "Master not initialized after 20ms" Key: FLINK-19447 URL: https://issues.apache.org/jira/browse/FLINK-19447

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

[ https://issues.apache.org/jira/browse/FLINK-19027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17203717#comment-17203717 ] Dian Fu commented on FLINK-19027: - Another instance on master: https://dev.azure.com/ap

[jira] [Commented] (FLINK-19432) Whether to capture the updates which don't change any monitored columns

[ https://issues.apache.org/jira/browse/FLINK-19432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17203716#comment-17203716 ] Zhengchao Shi commented on FLINK-19432: --- I haven't found a good way to solve the c

[GitHub] [flink] Shawn-Hx commented on a change in pull request #13410: [FLINK-19247][docs-zh] Update Chinese documentation after removal of Kafka 0.10 and 0.11

Shawn-Hx commented on a change in pull request #13410: URL: https://github.com/apache/flink/pull/13410#discussion_r496450685 ## File path: docs/dev/connectors/kafka.zh.md ## @@ -431,39 +371,46 @@ stream.addSink(myProducer); {% highlight scala %} val stream: DataStream[String]

[jira] [Commented] (FLINK-19445) Several tests for HBase connector 1.4 failed with "NoSuchMethodError: com.google.common.base.Preconditions.checkArgument(ZLjava/lang/String;Ljava/lang/Object;)V"

[ https://issues.apache.org/jira/browse/FLINK-19445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17203697#comment-17203697 ] Dian Fu commented on FLINK-19445: - cc [~mgergely] [~gyfora] > Several tests for HBase

[jira] [Created] (FLINK-19446) canal-json has a situation that -U and +U are equal, when updating the null field to be non-null

Zhengchao Shi created FLINK-19446: - Summary: canal-json has a situation that -U and +U are equal, when updating the null field to be non-null Key: FLINK-19446 URL: https://issues.apache.org/jira/browse/FLINK-19446

[jira] [Updated] (FLINK-19445) Several tests for HBase connector 1.4 failed with "NoSuchMethodError: com.google.common.base.Preconditions.checkArgument(ZLjava/lang/String;Ljava/lang/Object;)V"

[ https://issues.apache.org/jira/browse/FLINK-19445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19445: Priority: Blocker (was: Major) > Several tests for HBase connector 1.4 failed with "NoSuchMethodError: >

[jira] [Updated] (FLINK-19445) Several tests for HBase connector 1.4 failed with "NoSuchMethodError: com.google.common.base.Preconditions.checkArgument(ZLjava/lang/String;Ljava/lang/Object;)V"

[ https://issues.apache.org/jira/browse/FLINK-19445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19445: Labels: test-stability (was: ) > Several tests for HBase connector 1.4 failed with "NoSuchMethodError: >

[GitHub] [flink] flinkbot edited a comment on pull request #13500: [FLINK-19180][state backends] Make RocksDB respect managed memory fraction

flinkbot edited a comment on pull request #13500: URL: https://github.com/apache/flink/pull/13500#issuecomment-699908639 ## CI report: * bee5be24b69942ac4b6323da5bd701e8287f145b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Created] (FLINK-19445) Several tests for HBase connector 1.4 failed with "NoSuchMethodError: com.google.common.base.Preconditions.checkArgument(ZLjava/lang/String;Ljava/lang/Object;)V"

Dian Fu created FLINK-19445: --- Summary: Several tests for HBase connector 1.4 failed with "NoSuchMethodError: com.google.common.base.Preconditions.checkArgument(ZLjava/lang/String;Ljava/lang/Object;)V" Key: FLINK-19445

[GitHub] [flink] flinkbot edited a comment on pull request #13439: [FLINK-19295][yarn][tests] Exclude more meaningless akka shutdown errors

flinkbot edited a comment on pull request #13439: URL: https://github.com/apache/flink/pull/13439#issuecomment-696056061 ## CI report: * c05b38c50eec5ab2aedba11e840bbe74c49b40e4 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13434: [FLINK-19292][hive] HiveCatalog should support specifying Hadoop conf dir with configuration

flinkbot edited a comment on pull request #13434: URL: https://github.com/apache/flink/pull/13434#issuecomment-695893232 ## CI report: * 98dfbc96735cb5ae978a526b046c2ec3790b6b4b UNKNOWN * d7638e715ec7af65f8a45e276204ce86bce4369c UNKNOWN * cda95f3a0ee6988a3852d5e731ad360484ba

[GitHub] [flink] flinkbot edited a comment on pull request #13482: test

flinkbot edited a comment on pull request #13482: URL: https://github.com/apache/flink/pull/13482#issuecomment-698903502 ## CI report: * b6d1f311cb2a041680b89e3aedfe3d5cbdca42d0 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13439: [FLINK-19295][yarn][tests] Exclude more meaningless akka shutdown errors

flinkbot edited a comment on pull request #13439: URL: https://github.com/apache/flink/pull/13439#issuecomment-696056061 ## CI report: * c05b38c50eec5ab2aedba11e840bbe74c49b40e4 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Created] (FLINK-19444) flink 1.11 sql group by tumble Window aggregate can only be defined over a time attribute column, but TIMESTAMP(3) encountered

panxiaohu created FLINK-19444: - Summary: flink 1.11 sql group by tumble Window aggregate can only be defined over a time attribute column, but TIMESTAMP(3) encountered Key: FLINK-19444 URL: https://issues.apache.org/j

[GitHub] [flink] klion26 commented on a change in pull request #13410: [FLINK-19247][docs-zh] Update Chinese documentation after removal of Kafka 0.10 and 0.11

klion26 commented on a change in pull request #13410: URL: https://github.com/apache/flink/pull/13410#discussion_r496433356 ## File path: docs/dev/connectors/kafka.zh.md ## @@ -431,39 +371,46 @@ stream.addSink(myProducer); {% highlight scala %} val stream: DataStream[String]

[GitHub] [flink] flinkbot edited a comment on pull request #13482: test

flinkbot edited a comment on pull request #13482: URL: https://github.com/apache/flink/pull/13482#issuecomment-698903502 ## CI report: * b6d1f311cb2a041680b89e3aedfe3d5cbdca42d0 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13434: [FLINK-19292][hive] HiveCatalog should support specifying Hadoop conf dir with configuration

flinkbot edited a comment on pull request #13434: URL: https://github.com/apache/flink/pull/13434#issuecomment-695893232 ## CI report: * 98dfbc96735cb5ae978a526b046c2ec3790b6b4b UNKNOWN * 7a2be06f74b2abc1d40f345fe995634e0f246413 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #13487: [FLINK-19409][Documentation] remove unrelated comment for getValue in ListView

flinkbot edited a comment on pull request #13487: URL: https://github.com/apache/flink/pull/13487#issuecomment-699575614 ## CI report: * 9cbc32fe3fb52c05dce29124ac61c4a7c2952241 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13500: [FLINK-19180][state backends] Make RocksDB respect managed memory fraction

flinkbot edited a comment on pull request #13500: URL: https://github.com/apache/flink/pull/13500#issuecomment-699908639 ## CI report: * bee5be24b69942ac4b6323da5bd701e8287f145b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13487: [FLINK-19409][Documentation] remove unrelated comment for getValue in ListView

flinkbot edited a comment on pull request #13487: URL: https://github.com/apache/flink/pull/13487#issuecomment-699575614 ## CI report: * 9cbc32fe3fb52c05dce29124ac61c4a7c2952241 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-19443) runtime function 'splitIndex'

[ https://issues.apache.org/jira/browse/FLINK-19443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17203628#comment-17203628 ] Benchao Li commented on FLINK-19443: [~mytang0] Thanks for reporting this, would you

[GitHub] [flink] flinkbot edited a comment on pull request #13500: [FLINK-19180][state backends] Make RocksDB respect managed memory fraction

flinkbot edited a comment on pull request #13500: URL: https://github.com/apache/flink/pull/13500#issuecomment-699908639 ## CI report: * bee5be24b69942ac4b6323da5bd701e8287f145b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13356: [FLINK-16789][runtime][rest] Enable JMX RMI port retrieval via REST API

flinkbot edited a comment on pull request #13356: URL: https://github.com/apache/flink/pull/13356#issuecomment-688955548 ## CI report: * c95d0e33b9cd23264c899aae7df75c83d290f129 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13492: [FLINK-19181][python] Make python processes respect the calculated managed memory fraction

flinkbot edited a comment on pull request #13492: URL: https://github.com/apache/flink/pull/13492#issuecomment-699626263 ## CI report: * af73558800083e341dcd9c89819cd00b0572696b UNKNOWN * 59af0e9ec80df5072e44576882f8659db631e424 UNKNOWN * 921b49a2ccb91a91ff0f3c3cf176fec09664

[jira] [Comment Edited] (FLINK-19386) Remove legacy table planner dependecy from connectors and formats

[ https://issues.apache.org/jira/browse/FLINK-19386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17203624#comment-17203624 ] hailong wang edited comment on FLINK-19386 at 9/29/20, 4:23 AM: --

[jira] [Commented] (FLINK-19386) Remove legacy table planner dependecy from connectors and formats

[ https://issues.apache.org/jira/browse/FLINK-19386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17203624#comment-17203624 ] hailong wang commented on FLINK-19386: -- [~jark], here[1] is my idea. can I go ahead

[GitHub] [flink] flinkbot edited a comment on pull request #13434: [FLINK-19292][hive] HiveCatalog should support specifying Hadoop conf dir with configuration

flinkbot edited a comment on pull request #13434: URL: https://github.com/apache/flink/pull/13434#issuecomment-695893232 ## CI report: * 98dfbc96735cb5ae978a526b046c2ec3790b6b4b UNKNOWN * 0f253d15c6a2ab987bf2c824efb810a26c176fff Azure: [PENDING](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #13356: [FLINK-16789][runtime][rest] Enable JMX RMI port retrieval via REST API

flinkbot edited a comment on pull request #13356: URL: https://github.com/apache/flink/pull/13356#issuecomment-688955548 ## CI report: * c95d0e33b9cd23264c899aae7df75c83d290f129 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13434: [FLINK-19292][hive] HiveCatalog should support specifying Hadoop conf dir with configuration

flinkbot edited a comment on pull request #13434: URL: https://github.com/apache/flink/pull/13434#issuecomment-695893232 ## CI report: * 98dfbc96735cb5ae978a526b046c2ec3790b6b4b UNKNOWN * 0f253d15c6a2ab987bf2c824efb810a26c176fff Azure: [PENDING](https://dev.azure.com/apache-fl

[jira] [Closed] (FLINK-19419) "null-string-literal" does not work in HBaseSource decoder

[ https://issues.apache.org/jira/browse/FLINK-19419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] CaoZhen closed FLINK-19419. --- Resolution: Not A Problem > "null-string-literal" does not work in HBaseSource decoder > -

[jira] [Commented] (FLINK-19419) "null-string-literal" does not work in HBaseSource decoder

[ https://issues.apache.org/jira/browse/FLINK-19419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17203621#comment-17203621 ] CaoZhen commented on FLINK-19419: - [~jark] Thanks for your explanation. > "null-string-

[GitHub] [flink] wuchong closed pull request #13489: [hotfix][docs]Fix the FROM_UNIXTIME UTC sample time error

wuchong closed pull request #13489: URL: https://github.com/apache/flink/pull/13489 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink] wuchong commented on pull request #13489: [hotfix][docs]Fix the FROM_UNIXTIME UTC sample time error

wuchong commented on pull request #13489: URL: https://github.com/apache/flink/pull/13489#issuecomment-700410808 Has been fixed in 83b429bbc7fde4b958cfc6d6726fbbe6f590. This is an automated message from the Apache Git Ser

[jira] [Created] (FLINK-19443) runtime function 'splitIndex'

mytang0 created FLINK-19443: --- Summary: runtime function 'splitIndex' Key: FLINK-19443 URL: https://issues.apache.org/jira/browse/FLINK-19443 Project: Flink Issue Type: Bug Components: Tab

[jira] [Commented] (FLINK-19419) "null-string-literal" does not work in HBaseSource decoder

[ https://issues.apache.org/jira/browse/FLINK-19419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17203619#comment-17203619 ] Jark Wu commented on FLINK-19419: - [~caozhen1937], we HAVE TO use an specific string lit

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

[ https://issues.apache.org/jira/browse/FLINK-18830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17203617#comment-17203617 ] Jark Wu edited comment on FLINK-18830 at 9/29/20, 3:48 AM: --- I

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

[ https://issues.apache.org/jira/browse/FLINK-18830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17203617#comment-17203617 ] Jark Wu commented on FLINK-18830: - I agree with [~aljoscha]. I'm pretty sure the current

[jira] [Commented] (FLINK-19435) jdbc JDBCOutputFormat open function invoke Class.forName(drivername)

[ https://issues.apache.org/jira/browse/FLINK-19435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17203615#comment-17203615 ] Jark Wu commented on FLINK-19435: - You mean {{Class.forName()}} is not thread safe? >

[GitHub] [flink] flinkbot edited a comment on pull request #13434: [FLINK-19292][hive] HiveCatalog should support specifying Hadoop conf dir with configuration

flinkbot edited a comment on pull request #13434: URL: https://github.com/apache/flink/pull/13434#issuecomment-695893232 ## CI report: * 98dfbc96735cb5ae978a526b046c2ec3790b6b4b UNKNOWN * 0f253d15c6a2ab987bf2c824efb810a26c176fff Azure: [PENDING](https://dev.azure.com/apache-fl

[jira] [Assigned] (FLINK-19431) Translate "Monitoring REST API" page of "Debugging & Monitoring" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-19431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-19431: --- Assignee: weizheng > Translate "Monitoring REST API" page of "Debugging & Monitoring" into Chinese

[jira] [Commented] (FLINK-19432) Whether to capture the updates which don't change any monitored columns

[ https://issues.apache.org/jira/browse/FLINK-19432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17203612#comment-17203612 ] Jark Wu commented on FLINK-19432: - I'm +1 to this. This can be an optimization when user

[jira] [Closed] (FLINK-19433) An Error example of FROM_UNIXTIME function in document

[ https://issues.apache.org/jira/browse/FLINK-19433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-19433. --- Fix Version/s: 1.12.0 Resolution: Fixed Fixed in master : 83b429bbc7fde4b958cfc6d6726fbbe6f590 >

[GitHub] [flink] wuchong merged pull request #13493: [FLINK-19433] [docs] Correct example of FROM_UNIXTIME function in document

wuchong merged pull request #13493: URL: https://github.com/apache/flink/pull/13493 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink] flinkbot edited a comment on pull request #13473: [FLINK-19264][runtime] Add JobID to ExecutionAttemptID

flinkbot edited a comment on pull request #13473: URL: https://github.com/apache/flink/pull/13473#issuecomment-698203737 ## CI report: * e74c3f4d35222f876456134e4d800611da09c6cf Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13434: [FLINK-19292][hive] HiveCatalog should support specifying Hadoop conf dir with configuration

flinkbot edited a comment on pull request #13434: URL: https://github.com/apache/flink/pull/13434#issuecomment-695893232 ## CI report: * 98dfbc96735cb5ae978a526b046c2ec3790b6b4b UNKNOWN * 0f253d15c6a2ab987bf2c824efb810a26c176fff Azure: [PENDING](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #13492: [FLINK-19181][python] Make python processes respect the calculated managed memory fraction

flinkbot edited a comment on pull request #13492: URL: https://github.com/apache/flink/pull/13492#issuecomment-699626263 ## CI report: * af73558800083e341dcd9c89819cd00b0572696b UNKNOWN * ad9145cd549c242e40862c8ce21cf52b06927f00 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #13473: [FLINK-19264][runtime] Add JobID to ExecutionAttemptID

flinkbot edited a comment on pull request #13473: URL: https://github.com/apache/flink/pull/13473#issuecomment-698203737 ## CI report: * e74c3f4d35222f876456134e4d800611da09c6cf Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13434: [FLINK-19292][hive] HiveCatalog should support specifying Hadoop conf dir with configuration

flinkbot edited a comment on pull request #13434: URL: https://github.com/apache/flink/pull/13434#issuecomment-695893232 ## CI report: * 98dfbc96735cb5ae978a526b046c2ec3790b6b4b UNKNOWN * b5ac11907cbbe41f2b13e2b738458a3315d61663 Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Commented] (FLINK-10644) Batch Job: Speculative execution

[ https://issues.apache.org/jira/browse/FLINK-10644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17203607#comment-17203607 ] fa zheng commented on FLINK-10644: -- Any progress on this issue? It will be helpful in

[GitHub] [flink] caozhen1937 commented on pull request #13296: [FLINK-18774][format][debezium] Support debezium-avro format

caozhen1937 commented on pull request #13296: URL: https://github.com/apache/flink/pull/13296#issuecomment-700393087 @wuchong 1. the 3 debezium binary data file are generated by debezium connect 2. I think it is not easy to generate one file just like debezium-data-schema-exclude.txt

[GitHub] [flink] flinkbot edited a comment on pull request #13434: [FLINK-19292][hive] HiveCatalog should support specifying Hadoop conf dir with configuration

flinkbot edited a comment on pull request #13434: URL: https://github.com/apache/flink/pull/13434#issuecomment-695893232 ## CI report: * 98dfbc96735cb5ae978a526b046c2ec3790b6b4b UNKNOWN * b5ac11907cbbe41f2b13e2b738458a3315d61663 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] caozhen1937 commented on a change in pull request #13296: [FLINK-18774][format][debezium] Support debezium-avro format

caozhen1937 commented on a change in pull request #13296: URL: https://github.com/apache/flink/pull/13296#discussion_r496344141 ## File path: flink-formats/flink-avro-confluent-registry/src/main/java/org/apache/flink/formats/avro/registry/confluent/debezium/DebeziumAvroFormatFactory.j

[GitHub] [flink] caozhen1937 commented on a change in pull request #13296: [FLINK-18774][format][debezium] Support debezium-avro format

caozhen1937 commented on a change in pull request #13296: URL: https://github.com/apache/flink/pull/13296#discussion_r496341421 ## File path: flink-formats/flink-avro-confluent-registry/src/main/java/org/apache/flink/formats/avro/registry/confluent/debezium/DebeziumAvroDeserialization

[GitHub] [flink] shuiqiangchen commented on pull request #13322: [FLINK-17480][kubernetes] Support running PyFlink on Kubernetes.

shuiqiangchen commented on pull request #13322: URL: https://github.com/apache/flink/pull/13322#issuecomment-700386763 @wangyang0918 Thank you for your long time's help for reviewing this pr. @dianfu Could you please have a look at this PR since it has been approved. ---

[GitHub] [flink] flinkbot edited a comment on pull request #13492: [FLINK-19181][python] Make python processes respect the calculated managed memory fraction

flinkbot edited a comment on pull request #13492: URL: https://github.com/apache/flink/pull/13492#issuecomment-699626263 ## CI report: * af73558800083e341dcd9c89819cd00b0572696b UNKNOWN * ad9145cd549c242e40862c8ce21cf52b06927f00 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] KarmaGYZ commented on pull request #13473: [FLINK-19264][runtime] Add JobID to ExecutionAttemptID

KarmaGYZ commented on pull request #13473: URL: https://github.com/apache/flink/pull/13473#issuecomment-700384319 > Can we also add a test that tries to run 2 identical jobs at the same time? Thanks for the comment @zentol . I think it will be good to add a test for it. However, I'm

[GitHub] [flink] dianfu commented on pull request #13492: [FLINK-19181][python] Make python processes respect the calculated managed memory fraction

dianfu commented on pull request #13492: URL: https://github.com/apache/flink/pull/13492#issuecomment-700383952 @HuangXingBo Updated. This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] wangyang0918 commented on pull request #13322: [FLINK-17480][kubernetes] Support running PyFlink on Kubernetes.

wangyang0918 commented on pull request #13322: URL: https://github.com/apache/flink/pull/13322#issuecomment-700382411 +1 for merging. This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] HuangXingBo commented on a change in pull request #13492: [FLINK-19181][python] Make python processes respect the calculated managed memory fraction

HuangXingBo commented on a change in pull request #13492: URL: https://github.com/apache/flink/pull/13492#discussion_r496324046 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/BatchExecPythonOverAggregate.scal

[GitHub] [flink] LakeShen commented on pull request #12781: [FLINK-18376][Table SQL/Runtime]Fix java.lang.ArrayIndexOutOfBoundsException in RetractableTopNFunction

LakeShen commented on pull request #12781: URL: https://github.com/apache/flink/pull/12781#issuecomment-700376927 Anyone to look this issue? This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] HuangXingBo commented on a change in pull request #13492: [FLINK-19181][python] Make python processes respect the calculated managed memory fraction

HuangXingBo commented on a change in pull request #13492: URL: https://github.com/apache/flink/pull/13492#discussion_r496323126 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/BatchExecPythonGroupAggregate.sca

[GitHub] [flink] flinkbot edited a comment on pull request #13434: [FLINK-19292][hive] HiveCatalog should support specifying Hadoop conf dir with configuration

flinkbot edited a comment on pull request #13434: URL: https://github.com/apache/flink/pull/13434#issuecomment-695893232 ## CI report: * 98dfbc96735cb5ae978a526b046c2ec3790b6b4b UNKNOWN * b5ac11907cbbe41f2b13e2b738458a3315d61663 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #13434: [FLINK-19292][hive] HiveCatalog should support specifying Hadoop conf dir with configuration

flinkbot edited a comment on pull request #13434: URL: https://github.com/apache/flink/pull/13434#issuecomment-695893232 ## CI report: * 98dfbc96735cb5ae978a526b046c2ec3790b6b4b UNKNOWN * b5ac11907cbbe41f2b13e2b738458a3315d61663 Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Commented] (FLINK-19326) Allow explicitly configuring time behaviour on CEP PatternStream

[ https://issues.apache.org/jira/browse/FLINK-19326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17203566#comment-17203566 ] Nicholas Jiang commented on FLINK-19326: [~aljoscha]OK, I got the point you ment

[GitHub] [flink] flinkbot edited a comment on pull request #13492: [FLINK-19181][python] Make python processes respect the calculated managed memory fraction

flinkbot edited a comment on pull request #13492: URL: https://github.com/apache/flink/pull/13492#issuecomment-699626263 ## CI report: * af73558800083e341dcd9c89819cd00b0572696b UNKNOWN * ad9145cd549c242e40862c8ce21cf52b06927f00 Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Comment Edited] (FLINK-19401) Job stuck in restart loop due to "Could not find registered job manager"

[ https://issues.apache.org/jira/browse/FLINK-19401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17203298#comment-17203298 ] Steven Zhen Wu edited comment on FLINK-19401 at 9/29/20, 12:25 AM: ---

[GitHub] [flink] flinkbot edited a comment on pull request #13492: [FLINK-19181][python] Make python processes respect the calculated managed memory fraction

flinkbot edited a comment on pull request #13492: URL: https://github.com/apache/flink/pull/13492#issuecomment-699626263 ## CI report: * af73558800083e341dcd9c89819cd00b0572696b UNKNOWN * ad9145cd549c242e40862c8ce21cf52b06927f00 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] wangxlong closed pull request #13387: [Hotfix][typos]Modify debug log to print the compiling code

wangxlong closed pull request #13387: URL: https://github.com/apache/flink/pull/13387 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 t

[GitHub] [flink] wangxlong closed pull request #11124: [Hotfix]Add suffix L to WatermarkGeneratorCodeGenTest#testAscendingWatermark long type fields

wangxlong closed pull request #11124: URL: https://github.com/apache/flink/pull/11124 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 t

[GitHub] [flink] wangxlong closed pull request #11016: [FLINK-15677][TABLE-COMMON]Use physical field names for the default implementation of Tablesource#explainSource

wangxlong closed pull request #11016: URL: https://github.com/apache/flink/pull/11016 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 t

[GitHub] [flink] flinkbot edited a comment on pull request #13492: [FLINK-19181][python] Make python processes respect the calculated managed memory fraction

flinkbot edited a comment on pull request #13492: URL: https://github.com/apache/flink/pull/13492#issuecomment-699626263 ## CI report: * af73558800083e341dcd9c89819cd00b0572696b UNKNOWN * ad9145cd549c242e40862c8ce21cf52b06927f00 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] dianfu commented on pull request #13492: [FLINK-19181][python] Make python processes respect the calculated managed memory fraction

dianfu commented on pull request #13492: URL: https://github.com/apache/flink/pull/13492#issuecomment-700329112 @HuangXingBo Thanks for the review. Updated the PR. This is an automated message from the Apache Git Service. To

[GitHub] [flink] flinkbot edited a comment on pull request #13502: [FLINK-19392] Add the execution.runtime-mode

flinkbot edited a comment on pull request #13502: URL: https://github.com/apache/flink/pull/13502#issuecomment-700213477 ## CI report: * 145edc64fe7676b60df3fd322d771fb01711aaf8 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13458: FLINK-18851 [runtime] Add checkpoint type to checkpoint history entries in Web UI

flinkbot edited a comment on pull request #13458: URL: https://github.com/apache/flink/pull/13458#issuecomment-697041219 ## CI report: * 1b59c5c3c61d9ea667f3e722bb54788d1d687cec Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-19300) Timer loss after restoring from savepoint

[ https://issues.apache.org/jira/browse/FLINK-19300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17203504#comment-17203504 ] Xiang Gao commented on FLINK-19300: --- [~klion26] Thanks for taking a look! I'm not sure

[GitHub] [flink] flinkbot edited a comment on pull request #13502: [FLINK-19392] Add the execution.runtime-mode

flinkbot edited a comment on pull request #13502: URL: https://github.com/apache/flink/pull/13502#issuecomment-700213477 ## CI report: * 145edc64fe7676b60df3fd322d771fb01711aaf8 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

flinkbot edited a comment on pull request #13351: URL: https://github.com/apache/flink/pull/13351#issuecomment-688741492 ## CI report: * d5de65d33ae7216bee7ae8d55bf20839584c520f Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #13502: [FLINK-19392] Add the execution.runtime-mode

flinkbot commented on pull request #13502: URL: https://github.com/apache/flink/pull/13502#issuecomment-700213477 ## CI report: * 145edc64fe7676b60df3fd322d771fb01711aaf8 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot commented on pull request #13502: [FLINK-19392] Add the execution.runtime-mode

flinkbot commented on pull request #13502: URL: https://github.com/apache/flink/pull/13502#issuecomment-700209876 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 pro

[GitHub] [flink] kl0u opened a new pull request #13502: [FLINK-19392] Add the execution.runtime-mode

kl0u opened a new pull request #13502: URL: https://github.com/apache/flink/pull/13502 ## What is the purpose of the change This PR adds the `execution.runtime-mode`, as described in FLIP-134, without exposing it yet to the user. For now, we set the mode globally at the `Stre

[jira] [Updated] (FLINK-19392) Detect the execution mode based on the sources in the job.

[ https://issues.apache.org/jira/browse/FLINK-19392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19392: --- Labels: pull-request-available (was: ) > Detect the execution mode based on the sources in

[GitHub] [flink] flinkbot edited a comment on pull request #13458: FLINK-18851 [runtime] Add checkpoint type to checkpoint history entries in Web UI

flinkbot edited a comment on pull request #13458: URL: https://github.com/apache/flink/pull/13458#issuecomment-697041219 ## CI report: * 3340d3b1f62c8cfe9e9b30fee877a4728d4b0837 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13438: [FLINK-19014][e2e] Increase startup timeout

flinkbot edited a comment on pull request #13438: URL: https://github.com/apache/flink/pull/13438#issuecomment-696045369 ## CI report: * 4e3397e2476210d441ceefab6802d4bbab1053c8 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13458: FLINK-18851 [runtime] Add checkpoint type to checkpoint history entries in Web UI

flinkbot edited a comment on pull request #13458: URL: https://github.com/apache/flink/pull/13458#issuecomment-697041219 ## CI report: * 3340d3b1f62c8cfe9e9b30fee877a4728d4b0837 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] gm7y8 commented on pull request #13458: FLINK-18851 [runtime] Add checkpoint type to checkpoint history entries in Web UI

gm7y8 commented on pull request #13458: URL: https://github.com/apache/flink/pull/13458#issuecomment-700174911 @XComp I have taken care of commit message and other formatting issues. This is an automated message from the Apa

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

[ https://issues.apache.org/jira/browse/FLINK-15578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17203347#comment-17203347 ] Kenzyme Le edited comment on FLINK-15578 at 9/28/20, 4:36 PM:

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

[ https://issues.apache.org/jira/browse/FLINK-15578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17203347#comment-17203347 ] Kenzyme Le commented on FLINK-15578: Hi [~roman_khachatryan] , In case I am using a

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

flinkbot edited a comment on pull request #13040: URL: https://github.com/apache/flink/pull/13040#issuecomment-667140037 ## CI report: * 31abcb25fdf72394dbfa91d0ba9e151968375ad7 UNKNOWN * db99952f8166cb4d6337dcb3815e72ff2b49604b UNKNOWN * 33af84f70ab92a76818f1a4392fecb0c4a8e

[GitHub] [flink] pnowojski commented on a change in pull request #13499: [FLINK-16972][network] LocalBufferPool eagerly fetches global segments to ensure proper availability.

pnowojski commented on a change in pull request #13499: URL: https://github.com/apache/flink/pull/13499#discussion_r495970800 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/BufferPoolFactory.java ## @@ -48,8 +48,6 @@ *

  1   2   3   >