[jira] [Commented] (FLINK-23911) Projections not selecting any metadata columns cause all declared metadata columns to be applied to the source

2021-08-23 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17403535#comment-17403535 ] Jingsong Lee commented on FLINK-23911: -- > I don't think I understand why a separate interface would

[jira] [Commented] (FLINK-23932) KafkaTableITKafkaTableITCase.testKafkaSourceSinkWithKeyAndPartialValue hangs on AzureCase

2021-08-23 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17403534#comment-17403534 ] Till Rohrmann commented on FLINK-23932: --- cc [~twalthr] maybe you know more about this test case.

[jira] [Created] (FLINK-23932) KafkaTableITKafkaTableITCase.testKafkaSourceSinkWithKeyAndPartialValue hangs on AzureCase

2021-08-23 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-23932: - Summary: KafkaTableITKafkaTableITCase.testKafkaSourceSinkWithKeyAndPartialValue hangs on AzureCase Key: FLINK-23932 URL: https://issues.apache.org/jira/browse/FLINK-23932

[jira] [Created] (FLINK-23931) Format the exception message shown in PythonDriver

2021-08-23 Thread Dian Fu (Jira)
Dian Fu created FLINK-23931: --- Summary: Format the exception message shown in PythonDriver Key: FLINK-23931 URL: https://issues.apache.org/jira/browse/FLINK-23931 Project: Flink Issue Type:

[GitHub] [flink] tillrohrmann commented on pull request #16921: [FLINK-23906][tests] Increase the default akka.ask.timeout for the MiniCluster to 5 minutes

2021-08-23 Thread GitBox
tillrohrmann commented on pull request #16921: URL: https://github.com/apache/flink/pull/16921#issuecomment-904337110 Thanks for the review @zentol. Merging this PR now. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[jira] [Updated] (FLINK-15352) develop MySQLCatalog to connect Flink with MySQL tables and ecosystem

2021-08-23 Thread Roc Marshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roc Marshal updated FLINK-15352: Attachment: research-results.tar.gz > develop MySQLCatalog to connect Flink with MySQL tables

[GitHub] [flink] flinkbot edited a comment on pull request #16949: [FLINK-23242][docs-zh] Translate the page of "Handling Application Parameters" into Chinese

2021-08-23 Thread GitBox
flinkbot edited a comment on pull request #16949: URL: https://github.com/apache/flink/pull/16949#issuecomment-904291194 ## CI report: * 075a83a78084f011b92e2b28ba35f0c0983f6dcd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16929: [FLINK-23190][runtime] Make AdaptiveScheduler and DefaultScheduler allocate slot more evenly.

2021-08-23 Thread GitBox
flinkbot edited a comment on pull request #16929: URL: https://github.com/apache/flink/pull/16929#issuecomment-903251846 ## CI report: * 62e003f02a2d28c0b42669e5005c9f958ebdae92 Azure:

[GitHub] [flink] curcur commented on a change in pull request #16898: [FLINK-23876][docs] Update JDBC XA Sink docs

2021-08-23 Thread GitBox
curcur commented on a change in pull request #16898: URL: https://github.com/apache/flink/pull/16898#discussion_r694499069 ## File path: docs/content/docs/connectors/datastream/jdbc.md ## @@ -32,14 +32,6 @@ To use it, add the following dependency to your project (along with

[GitHub] [flink] curcur commented on a change in pull request #16898: [FLINK-23876][docs] Update JDBC XA Sink docs

2021-08-23 Thread GitBox
curcur commented on a change in pull request #16898: URL: https://github.com/apache/flink/pull/16898#discussion_r694499069 ## File path: docs/content/docs/connectors/datastream/jdbc.md ## @@ -32,14 +32,6 @@ To use it, add the following dependency to your project (along with

[jira] [Commented] (FLINK-23725) HadoopFsCommitter, file rename failure

2021-08-23 Thread todd (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17403526#comment-17403526 ] todd commented on FLINK-23725: --  I think that would be a problem if two files are written by different

[jira] [Commented] (FLINK-23725) HadoopFsCommitter, file rename failure

2021-08-23 Thread todd (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17403523#comment-17403523 ] todd commented on FLINK-23725: -- [~sewen]  CC > HadoopFsCommitter, file rename failure >

[GitHub] [flink] curcur edited a comment on pull request #16836: [FLINK-13973][runtime][checkpoint] Fix the state assignments if uidHash is set

2021-08-23 Thread GitBox
curcur edited a comment on pull request #16836: URL: https://github.com/apache/flink/pull/16836#issuecomment-904324432 @gaoyunhaii , thanks for fixing this! The PR LGTM overall, left a few in-line comments. Besides that, is that possible/allowed that an operator has both

[GitHub] [flink] curcur commented on pull request #16836: [FLINK-13973][runtime][checkpoint] Fix the state assignments if uidHash is set

2021-08-23 Thread GitBox
curcur commented on pull request #16836: URL: https://github.com/apache/flink/pull/16836#issuecomment-904325982 Discussed offline. Approved. -- 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

[GitHub] [flink] curcur commented on pull request #16836: [FLINK-13973][runtime][checkpoint] Fix the state assignments if uidHash is set

2021-08-23 Thread GitBox
curcur commented on pull request #16836: URL: https://github.com/apache/flink/pull/16836#issuecomment-904324432 @gaoyunhaii , thanks for fixing this! The PR LGTM overall, left a few in-line comments. Besides that, is that possible/allowed that an operator has both unihash and

[GitHub] [flink] flinkbot edited a comment on pull request #16953: [FLINK-23753][python][docs] Add documentation for Python operator chaining

2021-08-23 Thread GitBox
flinkbot edited a comment on pull request #16953: URL: https://github.com/apache/flink/pull/16953#issuecomment-904312158 ## CI report: * f82ce0c5c8a50b1d681709758453ebf9cf6255cb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16952: [FLINK-23556][tests] Make SQLClientSchemaRegistryITCase more stable

2021-08-23 Thread GitBox
flinkbot edited a comment on pull request #16952: URL: https://github.com/apache/flink/pull/16952#issuecomment-904312136 ## CI report: * b4db61738353ad72d189d2d3e7ce931f930fabdd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16946: [FLINK-23654][runtime] Splitting IO and future threadpools and adding advanced configurations

2021-08-23 Thread GitBox
flinkbot edited a comment on pull request #16946: URL: https://github.com/apache/flink/pull/16946#issuecomment-904042149 ## CI report: * 04c9fc636bd6f07bf47654b5fc6d80c939169bc4 UNKNOWN * 454b7277df57678f94dc74901a54b3b22e241276 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16929: [FLINK-23190][runtime] Make AdaptiveScheduler and DefaultScheduler allocate slot more evenly.

2021-08-23 Thread GitBox
flinkbot edited a comment on pull request #16929: URL: https://github.com/apache/flink/pull/16929#issuecomment-903251846 ## CI report: * 62e003f02a2d28c0b42669e5005c9f958ebdae92 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16902: [FLINK-23113][runtime-web] Migrate to ESLint, add Stylint and address dependency vulnerabilities

2021-08-23 Thread GitBox
flinkbot edited a comment on pull request #16902: URL: https://github.com/apache/flink/pull/16902#issuecomment-902393531 ## CI report: * 1e45c206d1639adc6a4737bd32d30c9e4070937d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16885: [FLINK-23862][runtime] Cleanup StreamTask if cancelled after restore …

2021-08-23 Thread GitBox
flinkbot edited a comment on pull request #16885: URL: https://github.com/apache/flink/pull/16885#issuecomment-901300956 ## CI report: * 3220cb10e3e87a8ed31c453790840d84cd22b519 UNKNOWN * 72db9750aa889c6da828bcb3856311e4b9c02d41 Azure:

[jira] [Commented] (FLINK-23725) HadoopFsCommitter, file rename failure

2021-08-23 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17403519#comment-17403519 ] Paul Lin commented on FLINK-23725: -- [~todd5167] You're right. The commit operations should be retryable

[GitHub] [flink] curcur commented on a change in pull request #16836: [FLINK-13973][runtime][checkpoint] Fix the state assignments if uidHash is set

2021-08-23 Thread GitBox
curcur commented on a change in pull request #16836: URL: https://github.com/apache/flink/pull/16836#discussion_r694473966 ## File path: flink-tests/src/test/java/org/apache/flink/test/checkpointing/CheckpointRestoreWithUidHashITCase.java ## @@ -18,56 +18,185 @@ package

[jira] [Commented] (FLINK-22198) KafkaTableITCase hang.

2021-08-23 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17403517#comment-17403517 ] Jark Wu commented on FLINK-22198: - [~xtsong] [~renqs][~lindong], personally, I'm -1 to change the test

[GitHub] [flink] bgeng777 closed pull request #16864: [FLINK-23556][tests] Make SQLClientSchemaRegistryITCase more stable

2021-08-23 Thread GitBox
bgeng777 closed pull request #16864: URL: https://github.com/apache/flink/pull/16864 -- 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 the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] bgeng777 edited a comment on pull request #16864: [FLINK-23556][tests] Make SQLClientSchemaRegistryITCase more stable

2021-08-23 Thread GitBox
bgeng777 edited a comment on pull request #16864: URL: https://github.com/apache/flink/pull/16864#issuecomment-904315474 HI @xintongsong, Thanks for the feedback. I create a new PR: https://github.com/apache/flink/pull/16952 with clean commit history. For this pr, I am sorry for

[GitHub] [flink] bgeng777 commented on pull request #16864: [FLINK-23556][tests] Make SQLClientSchemaRegistryITCase more stable

2021-08-23 Thread GitBox
bgeng777 commented on pull request #16864: URL: https://github.com/apache/flink/pull/16864#issuecomment-904315474 HI @xintongsong, Thanks for the feedback. I create a new PR: https://github.com/apache/flink/pull/16952 with clean commit history. For this pr, I am sorry for the

[jira] [Comment Edited] (FLINK-23556) SQLClientSchemaRegistryITCase fails with " Subject ... not found"

2021-08-23 Thread Biao Geng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17402730#comment-17402730 ] Biao Geng edited comment on FLINK-23556 at 8/24/21, 4:29 AM: - hi [~xtsong],

[GitHub] [flink] loyili commented on pull request #16929: [FLINK-23190][runtime] Make AdaptiveScheduler and DefaultScheduler allocate slot more evenly.

2021-08-23 Thread GitBox
loyili commented on pull request #16929: URL: https://github.com/apache/flink/pull/16929#issuecomment-904313368 @flinkbot run azure -- 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 the specific

[GitHub] [flink] flinkbot commented on pull request #16953: [FLINK-23753][python][docs] Add documentation for Python operator chaining

2021-08-23 Thread GitBox
flinkbot commented on pull request #16953: URL: https://github.com/apache/flink/pull/16953#issuecomment-904312158 ## CI report: * f82ce0c5c8a50b1d681709758453ebf9cf6255cb UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #16952: [FLINK-23556][tests] Make SQLClientSchemaRegistryITCase more stable

2021-08-23 Thread GitBox
flinkbot commented on pull request #16952: URL: https://github.com/apache/flink/pull/16952#issuecomment-904312136 ## CI report: * b4db61738353ad72d189d2d3e7ce931f930fabdd UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #16951: [FLINK-23807][connector/testing-framework] Use numRestarts metric to detect TaskManager termination in MiniClusterTestEnvironment

2021-08-23 Thread GitBox
flinkbot edited a comment on pull request #16951: URL: https://github.com/apache/flink/pull/16951#issuecomment-904302794 ## CI report: * 4cd7cc8a0b2034285383f31ff38f7cd380dadaf2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16950: [FLINK-22710][formats] Explicitly set the bucket assigner to avoid writing into two buckets in the tests

2021-08-23 Thread GitBox
flinkbot edited a comment on pull request #16950: URL: https://github.com/apache/flink/pull/16950#issuecomment-904302769 ## CI report: * 4ecced5f26139215ae8555cc358291c46e9c7bfb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16902: [FLINK-23113][runtime-web] Migrate to ESLint, add Stylint and address dependency vulnerabilities

2021-08-23 Thread GitBox
flinkbot edited a comment on pull request #16902: URL: https://github.com/apache/flink/pull/16902#issuecomment-902393531 ## CI report: * 1e45c206d1639adc6a4737bd32d30c9e4070937d Azure:

[GitHub] [flink] zlzhang0122 commented on a change in pull request #16847: [FLINK-23561][yarn]Detail the container completed message

2021-08-23 Thread GitBox
zlzhang0122 commented on a change in pull request #16847: URL: https://github.com/apache/flink/pull/16847#discussion_r694480432 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManagerDriver.java ## @@ -689,4 +690,54 @@ public void

[GitHub] [flink] flinkbot commented on pull request #16951: [FLINK-23807][connector/testing-framework] Use numRestarts metric to detect TaskManager termination in MiniClusterTestEnvironment

2021-08-23 Thread GitBox
flinkbot commented on pull request #16951: URL: https://github.com/apache/flink/pull/16951#issuecomment-904302794 ## CI report: * 4cd7cc8a0b2034285383f31ff38f7cd380dadaf2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #16950: [FLINK-22710][formats] Explicitly set the bucket assigner to avoid writing into two buckets in the tests

2021-08-23 Thread GitBox
flinkbot commented on pull request #16950: URL: https://github.com/apache/flink/pull/16950#issuecomment-904302769 ## CI report: * 4ecced5f26139215ae8555cc358291c46e9c7bfb UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #16948: [FLINK-23929][python] Operator with multiple outputs should not chain with one of the outputs

2021-08-23 Thread GitBox
flinkbot edited a comment on pull request #16948: URL: https://github.com/apache/flink/pull/16948#issuecomment-904291156 ## CI report: * 36007764662e3886f21d70ce43175cc763dd7fb9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16949: [FLINK-23242][docs-zh] Translate the page of "Handling Application Parameters" into Chinese

2021-08-23 Thread GitBox
flinkbot edited a comment on pull request #16949: URL: https://github.com/apache/flink/pull/16949#issuecomment-904291194 ## CI report: * 075a83a78084f011b92e2b28ba35f0c0983f6dcd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16725: [BP-1.13][FLINK-23172][docs] Fix broken links to Task Failure Recovery page on Configuration page

2021-08-23 Thread GitBox
flinkbot edited a comment on pull request #16725: URL: https://github.com/apache/flink/pull/16725#issuecomment-893424721 ## CI report: * efcdd33a6cd5f16213864460972b6ea167787c93 Azure:

[GitHub] [flink] wuchong edited a comment on pull request #16889: [FLINK-16152][doc-zh]Translate "Operator/index"(docs/content.zh/docs/dev/datastream/operators/overview.md) into Chinese

2021-08-23 Thread GitBox
wuchong edited a comment on pull request #16889: URL: https://github.com/apache/flink/pull/16889#issuecomment-904302096 @gaoyunhaii , do you have time to review this? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink] wuchong commented on pull request #16889: [FLINK-16152][doc-zh]Translate "Operator/index"(docs/content.zh/docs/dev/datastream/operators/overview.md) into Chinese

2021-08-23 Thread GitBox
wuchong commented on pull request #16889: URL: https://github.com/apache/flink/pull/16889#issuecomment-904302096 @RocMarshal , do you have time to review this? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] flinkbot commented on pull request #16953: [FLINK-23753][python][docs] Add documentation for Python operator chaining

2021-08-23 Thread GitBox
flinkbot commented on pull request #16953: URL: https://github.com/apache/flink/pull/16953#issuecomment-904301863 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-23921) WindowJoinITCase.testInnerJoinWithIsNotDistinctFromOnWTF is not stable

2021-08-23 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-23921: --- Fix Version/s: 1.14.0 > WindowJoinITCase.testInnerJoinWithIsNotDistinctFromOnWTF is not stable >

[jira] [Updated] (FLINK-23921) WindowJoinITCase.testInnerJoinWithIsNotDistinctFromOnWTF is not stable

2021-08-23 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-23921: --- Component/s: (was: Tests) API / DataStream >

[jira] [Updated] (FLINK-23753) Add documentation about Python DataStream API chaining optimization

2021-08-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23753: --- Labels: pull-request-available (was: ) > Add documentation about Python DataStream API

[GitHub] [flink] dianfu opened a new pull request #16953: [FLINK-23753][python][docs] Add documentation for Python operator chaining

2021-08-23 Thread GitBox
dianfu opened a new pull request #16953: URL: https://github.com/apache/flink/pull/16953 ## 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 them on

[GitHub] [flink] flinkbot commented on pull request #16952: [FLINK-23556][tests] Make SQLClientSchemaRegistryITCase more stable

2021-08-23 Thread GitBox
flinkbot commented on pull request #16952: URL: https://github.com/apache/flink/pull/16952#issuecomment-904300521 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] bgeng777 opened a new pull request #16952: [FLINK-23556][tests] Make SQLClientSchemaRegistryITCase more stable

2021-08-23 Thread GitBox
bgeng777 opened a new pull request #16952: URL: https://github.com/apache/flink/pull/16952 ## What is the purpose of the change This PR aims at improving the pass rate of SQLClientSchemaRegistryITCase(an unstable e2e test case). ## Brief change log -

[jira] [Closed] (FLINK-23873) The example of EXPLAIN Statements in the official document is wrong, and the ‘)’ is missing

2021-08-23 Thread JasonLee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JasonLee closed FLINK-23873. Release Note: https://github.com/apache/flink/pull/16051 Resolution: Not A Bug > The example of

[jira] [Closed] (FLINK-23872) The example of EXPLAIN Statements in the official document is wrong, and the ‘)’ is missing

2021-08-23 Thread JasonLee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JasonLee closed FLINK-23872. Fix Version/s: (was: 1.13.0) (was: 1.11.0) 1.14.0

[jira] [Commented] (FLINK-23886) An exception is thrown out when recover job timers from checkpoint file

2021-08-23 Thread xiangqiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17403501#comment-17403501 ] xiangqiao commented on FLINK-23886: --- RocksDBCachingPriorityQueueSet#deserializeElement method will

[GitHub] [flink] PatrickRen commented on a change in pull request #16949: [FLINK-23242][docs-zh] Translate the page of "Handling Application Parameters" into Chinese

2021-08-23 Thread GitBox
PatrickRen commented on a change in pull request #16949: URL: https://github.com/apache/flink/pull/16949#discussion_r694464061 ## File path: docs/content.zh/docs/dev/datastream/application_parameters.md ## @@ -24,28 +24,23 @@ specific language governing permissions and

[GitHub] [flink] flinkbot commented on pull request #16951: [FLINK-23807][connector/testing-framework] Use numRestarts metric to detect TaskManager termination in MiniClusterTestEnvironment

2021-08-23 Thread GitBox
flinkbot commented on pull request #16951: URL: https://github.com/apache/flink/pull/16951#issuecomment-904295008 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] flinkbot commented on pull request #16950: [FLINK-22710][formats] Explicitly set the bucket assigner to avoid writing into two buckets in the tests

2021-08-23 Thread GitBox
flinkbot commented on pull request #16950: URL: https://github.com/apache/flink/pull/16950#issuecomment-904294361 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-23807) Use metrics to detect restarts in MiniClusterTestEnvironment#triggerTaskManagerFailover

2021-08-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23807: --- Labels: pull-request-available (was: ) > Use metrics to detect restarts in >

[GitHub] [flink] PatrickRen opened a new pull request #16951: [FLINK-23807][connector/testing-framework] Use numRestarts metric to detect TaskManager termination in MiniClusterTestEnvironment

2021-08-23 Thread GitBox
PatrickRen opened a new pull request #16951: URL: https://github.com/apache/flink/pull/16951 ## What is the purpose of the change This pull request changes the behavior of detecting TaskManager termination in ```MiniClusterTestEnvironment``` to make the test more stable.

[jira] [Updated] (FLINK-22710) ParquetProtoStreamingFileSinkITCase.testParquetProtoWriters failed

2021-08-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22710: --- Labels: auto-deprioritized-major pull-request-available test-stability (was:

[GitHub] [flink] gaoyunhaii opened a new pull request #16950: [FLINK-22710][formats] Explicitly set the bucket assigner to avoid writing into two buckets in the tests

2021-08-23 Thread GitBox
gaoyunhaii opened a new pull request #16950: URL: https://github.com/apache/flink/pull/16950 ## What is the purpose of the change This PR fixes that some tests use the default DateTimeBucketAssigner which partitions the data into buckets according to the hour, if the test are

[GitHub] [flink] flinkbot commented on pull request #16948: [FLINK-23929][python] Operator with multiple outputs should not chain with one of the outputs

2021-08-23 Thread GitBox
flinkbot commented on pull request #16948: URL: https://github.com/apache/flink/pull/16948#issuecomment-904291156 ## CI report: * 36007764662e3886f21d70ce43175cc763dd7fb9 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #16949: [FLINK-23242][docs-zh] Translate the page of "Handling Application Parameters" into Chinese

2021-08-23 Thread GitBox
flinkbot commented on pull request #16949: URL: https://github.com/apache/flink/pull/16949#issuecomment-904291194 ## CI report: * 075a83a78084f011b92e2b28ba35f0c0983f6dcd UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-23848) PulsarSourceITCase is failed on Azure

2021-08-23 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17403488#comment-17403488 ] Xintong Song commented on FLINK-23848: --

[GitHub] [flink] flinkbot edited a comment on pull request #16902: [FLINK-23113][runtime-web] Migrate to ESLint, add Stylint and address dependency vulnerabilities

2021-08-23 Thread GitBox
flinkbot edited a comment on pull request #16902: URL: https://github.com/apache/flink/pull/16902#issuecomment-902393531 ## CI report: * 1e45c206d1639adc6a4737bd32d30c9e4070937d Azure:

[jira] [Commented] (FLINK-22387) UpsertKafkaTableITCase hangs when setting up kafka

2021-08-23 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17403487#comment-17403487 ] Xintong Song commented on FLINK-22387: --

[GitHub] [flink] flinkbot edited a comment on pull request #16725: [BP-1.13][FLINK-23172][docs] Fix broken links to Task Failure Recovery page on Configuration page

2021-08-23 Thread GitBox
flinkbot edited a comment on pull request #16725: URL: https://github.com/apache/flink/pull/16725#issuecomment-893424721 ## CI report: * efcdd33a6cd5f16213864460972b6ea167787c93 Azure:

[jira] [Commented] (FLINK-23913) UnalignedCheckpointITCase fails with exit code 137 (kernel oom) on Azure VMs

2021-08-23 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17403486#comment-17403486 ] Xintong Song commented on FLINK-23913: --

[jira] [Commented] (FLINK-23848) PulsarSourceITCase is failed on Azure

2021-08-23 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17403485#comment-17403485 ] Xintong Song commented on FLINK-23848: --

[jira] [Commented] (FLINK-23913) UnalignedCheckpointITCase fails with exit code 137 (kernel oom) on Azure VMs

2021-08-23 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17403483#comment-17403483 ] Xintong Song commented on FLINK-23913: --

[jira] [Commented] (FLINK-22480) KafkaChangelogTableITCase hangs on Azure

2021-08-23 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17403482#comment-17403482 ] Xintong Song commented on FLINK-22480: --

[jira] [Commented] (FLINK-22198) KafkaTableITCase hang.

2021-08-23 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17403480#comment-17403480 ] Xintong Song commented on FLINK-22198: --

[jira] [Commented] (FLINK-22971) Initialization of Testcontainers unstable on Azure

2021-08-23 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17403479#comment-17403479 ] Xintong Song commented on FLINK-22971: --

[GitHub] [flink] flinkbot edited a comment on pull request #16947: update hive_function.md

2021-08-23 Thread GitBox
flinkbot edited a comment on pull request #16947: URL: https://github.com/apache/flink/pull/16947#issuecomment-904242624 ## CI report: * ea9b59c52abf8c5e2ee72c9d43e8d74e240ae19b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16902: [FLINK-23113][runtime-web] Migrate to ESLint, add Stylint and address dependency vulnerabilities

2021-08-23 Thread GitBox
flinkbot edited a comment on pull request #16902: URL: https://github.com/apache/flink/pull/16902#issuecomment-902393531 ## CI report: * 1e45c206d1639adc6a4737bd32d30c9e4070937d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16900: [FLINK-23877][connector/pulsar] Provide an embedded pulsar broker for testing.

2021-08-23 Thread GitBox
flinkbot edited a comment on pull request #16900: URL: https://github.com/apache/flink/pull/16900#issuecomment-902199681 ## CI report: * 93ea63d1795facc130ecb8c08a6a07562cfc22d7 Azure:

[GitHub] [flink] Thesharing edited a comment on pull request #16935: [FLINK-23172][docs] Fix broken links to Task Failure Recovery page on Configuration page

2021-08-23 Thread GitBox
Thesharing edited a comment on pull request #16935: URL: https://github.com/apache/flink/pull/16935#issuecomment-904279770 Thank you for helping me merge this PR, @zentol! The PR that backport the change to 1.13 is available now: #16725. Would you mind reviewing it if you got any free

[GitHub] [flink] Thesharing edited a comment on pull request #16935: [FLINK-23172][docs] Fix broken links to Task Failure Recovery page on Configuration page

2021-08-23 Thread GitBox
Thesharing edited a comment on pull request #16935: URL: https://github.com/apache/flink/pull/16935#issuecomment-904279770 > @Thesharing can you also create a PR to fix the link in 1.13? Thank you for helping me merge this PR. The PR that backport the change to 1.13 is available

[GitHub] [flink] flinkbot commented on pull request #16949: [FLINK-23242][docs-zh] Translate the page of "Handling Application Parameters" into Chinese

2021-08-23 Thread GitBox
flinkbot commented on pull request #16949: URL: https://github.com/apache/flink/pull/16949#issuecomment-904279749 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] Thesharing commented on pull request #16935: [FLINK-23172][docs] Fix broken links to Task Failure Recovery page on Configuration page

2021-08-23 Thread GitBox
Thesharing commented on pull request #16935: URL: https://github.com/apache/flink/pull/16935#issuecomment-904279770 > @Thesharing can you also create a PR to fix the link in 1.13? Thank you for helping me merge this PR. The PR that backport the change to 1.13 is available now:

[GitHub] [flink] flinkbot commented on pull request #16948: [FLINK-23929][python] Operator with multiple outputs should not chain with one of the outputs

2021-08-23 Thread GitBox
flinkbot commented on pull request #16948: URL: https://github.com/apache/flink/pull/16948#issuecomment-904279762 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] zuoniduimian commented on pull request #16949: [FLINK-23242][docs-zh] Translate the page of "Handling Application Parameters" into Chinese

2021-08-23 Thread GitBox
zuoniduimian commented on pull request #16949: URL: https://github.com/apache/flink/pull/16949#issuecomment-904279252 @PatrickRen hello,Could you help me review my PR in your spare time? thank you ! -- This is an automated message from the Apache Git Service. To respond to the

[jira] [Updated] (FLINK-23242) Translate the page of "Handling Application Parameters" into Chinese

2021-08-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23242: --- Labels: pull-request-available (was: ) > Translate the page of "Handling Application

[GitHub] [flink] zuoniduimian opened a new pull request #16949: [FLINK-23242][docs-zh] Translate the page of "Handling Application Parameters" into Chinese

2021-08-23 Thread GitBox
zuoniduimian opened a new pull request #16949: URL: https://github.com/apache/flink/pull/16949 What is the purpose of the change Translate the page of "Handling Application Parameters " into Chinese The page url of "Handling Application Parameters" is

[jira] [Updated] (FLINK-23929) Chaining optimization doesn't handle properly for transformations with multiple outputs

2021-08-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23929: --- Labels: pull-request-available (was: ) > Chaining optimization doesn't handle properly for

[GitHub] [flink] dianfu opened a new pull request #16948: [FLINK-23929][python] Operator with multiple outputs should not chain with one of the outputs

2021-08-23 Thread GitBox
dianfu opened a new pull request #16948: URL: https://github.com/apache/flink/pull/16948 ## What is the purpose of the change *This pull request ensures that operator with multiple outputs should not chain with one of the outputs* ## Verifying this change

[jira] [Updated] (FLINK-23929) Chaining optimization doesn't handle properly for transformations with multiple outputs

2021-08-23 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-23929: Summary: Chaining optimization doesn't handle properly for transformations with multiple outputs (was:

[jira] [Updated] (FLINK-23930) can not open dashboard

2021-08-23 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-23930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 钟洋洋 updated FLINK-23930: Summary: can not open dashboard (was: can not open web ui) > can not open dashboard > -- > >

[jira] [Updated] (FLINK-23930) can not open dashboard

2021-08-23 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-23930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 钟洋洋 updated FLINK-23930: Description: *I created a k8s job to deploy Flink natively on Kubernetes. But I did not deploy successfully and

[jira] [Comment Edited] (FLINK-23930) can not open web ui

2021-08-23 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-23930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17403462#comment-17403462 ] 钟洋洋 edited comment on FLINK-23930 at 8/24/21, 2:34 AM: --- *this is my k8s job yaml*

[jira] [Commented] (FLINK-23930) can not open web ui

2021-08-23 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-23930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17403462#comment-17403462 ] 钟洋洋 commented on FLINK-23930: - *this is my k8s job yaml* apiVersion: batch/v1 kind: Job metadata:

[jira] [Updated] (FLINK-23930) can not open web ui

2021-08-23 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-23930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 钟洋洋 updated FLINK-23930: Environment: (was: *this is my k8s job yaml* apiVersion: batch/v1 kind: Job metadata: labels:

[jira] [Created] (FLINK-23930) can not open web ui

2021-08-23 Thread Jira
钟洋洋 created FLINK-23930: --- Summary: can not open web ui Key: FLINK-23930 URL: https://issues.apache.org/jira/browse/FLINK-23930 Project: Flink Issue Type: Technical Debt Components:

[jira] [Commented] (FLINK-23725) HadoopFsCommitter, file rename failure

2021-08-23 Thread todd (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17403457#comment-17403457 ] todd commented on FLINK-23725: -- [~Paul Lin]   I think the target file should be deleted first instead of

[GitHub] [flink] flinkbot edited a comment on pull request #16900: [FLINK-23877][connector/pulsar] Provide an embedded pulsar broker for testing.

2021-08-23 Thread GitBox
flinkbot edited a comment on pull request #16900: URL: https://github.com/apache/flink/pull/16900#issuecomment-902199681 ## CI report: * 93ea63d1795facc130ecb8c08a6a07562cfc22d7 Azure:

[jira] [Created] (FLINK-23929) Chaining optimization doesn't handle properly for transformations with multiple inputs

2021-08-23 Thread Dian Fu (Jira)
Dian Fu created FLINK-23929: --- Summary: Chaining optimization doesn't handle properly for transformations with multiple inputs Key: FLINK-23929 URL: https://issues.apache.org/jira/browse/FLINK-23929

[jira] [Commented] (FLINK-23493) python tests hang on Azure

2021-08-23 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17403450#comment-17403450 ] Xintong Song commented on FLINK-23493: --

[jira] [Commented] (FLINK-22889) JdbcExactlyOnceSinkE2eTest.testInsert hangs on azure

2021-08-23 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17403448#comment-17403448 ] Xintong Song commented on FLINK-22889: --

[GitHub] [flink] flinkbot edited a comment on pull request #16947: update hive_function.md

2021-08-23 Thread GitBox
flinkbot edited a comment on pull request #16947: URL: https://github.com/apache/flink/pull/16947#issuecomment-904242624 ## CI report: * ea9b59c52abf8c5e2ee72c9d43e8d74e240ae19b Azure:

[GitHub] [flink-training] alpinegizmo commented on a change in pull request #31: [FLINK-23653] exercise and test rework

2021-08-23 Thread GitBox
alpinegizmo commented on a change in pull request #31: URL: https://github.com/apache/flink-training/pull/31#discussion_r694423579 ## File path: long-ride-alerts/src/test/java/org/apache/flink/training/exercises/longrides/LongRidesTest.java ## @@ -18,89 +18,150 @@ package

[GitHub] [flink] flinkbot commented on pull request #16947: update hive_function.md

2021-08-23 Thread GitBox
flinkbot commented on pull request #16947: URL: https://github.com/apache/flink/pull/16947#issuecomment-904242624 ## CI report: * ea9b59c52abf8c5e2ee72c9d43e8d74e240ae19b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] RocMarshal commented on pull request #16931: [FLINK-23909][connector-jdbc][scala-shell][yarn] Remove redundant variables and improve some style format in coding.

2021-08-23 Thread GitBox
RocMarshal commented on pull request #16931: URL: https://github.com/apache/flink/pull/16931#issuecomment-904234901 Hi, @dianfu Could you help me to review this PR? Thank you very much. -- This is an automated message from the Apache Git Service. To respond to the message, please log on

  1   2   3   4   5   6   >