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

2020-12-07 Thread wangwj (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17245062#comment-17245062 ] wangwj commented on FLINK-10644: [~QiLuo] I will look into this work. How is your progress of this work?

[GitHub] [flink] azagrebin commented on a change in pull request #14301: [FLINK-20468][minicluster] Enable leadership control in MiniCluster to test JM failover

2020-12-07 Thread GitBox
azagrebin commented on a change in pull request #14301: URL: https://github.com/apache/flink/pull/14301#discussion_r537325089 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/PerJobCheckpointRecoveryFactory.java ## @@ -29,13 +30,13 @@ * Simple

[jira] [Commented] (FLINK-10868) Flink's JobCluster ResourceManager doesn't use maximum-failed-containers as limit of resource acquirement

2020-12-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17245067#comment-17245067 ] Xintong Song commented on FLINK-10868: -- Hi [~hpeter], I've gone through the previous discussions

[jira] [Closed] (FLINK-20168) Translate page 'Flink Architecture' into Chinese

2020-12-07 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-20168. --- Fix Version/s: 1.12.1 1.13.0 Resolution: Fixed Fixed in - master (1.13.0):

[jira] [Commented] (FLINK-17208) Reduce redundant data available notification of PipelinedSubpartition

2020-12-07 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17245081#comment-17245081 ] Arvid Heise commented on FLINK-17208: - What's the status on this ticket? Aren't the scenarios so

[jira] [Updated] (FLINK-19774) Introduce Sub Partition View Version for Approximate Local Recovery

2020-12-07 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-19774: Fix Version/s: 1.13.0 > Introduce Sub Partition View Version for Approximate Local Recovery >

[jira] [Updated] (FLINK-19801) Add support for virtual channels

2020-12-07 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-19801: Fix Version/s: 1.13.0 > Add support for virtual channels > > >

[jira] [Updated] (FLINK-19895) Unify Life Cycle Management of ResultPartitionType Pipelined Family

2020-12-07 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-19895: Fix Version/s: 1.13.0 > Unify Life Cycle Management of ResultPartitionType Pipelined Family >

[GitHub] [flink] wuchong commented on a change in pull request #14316: [FLINK-20470]MissingNode can't be casted to ObjectNode when deserializing JSON

2020-12-07 Thread GitBox
wuchong commented on a change in pull request #14316: URL: https://github.com/apache/flink/pull/14316#discussion_r537334995 ## File path: flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataDeserializationSchema.java ## @@ -101,6 +102,9 @@ public

[jira] [Updated] (FLINK-18578) Add rejecting checkpoint logic in source

2020-12-07 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-18578: Component/s: Connectors / Common > Add rejecting checkpoint logic in source >

[GitHub] [flink] flinkbot edited a comment on pull request #14207: [FLINK-20250][table-runtime] NPE when invoking AsyncLookupJoinRunner#close method

2020-12-07 Thread GitBox
flinkbot edited a comment on pull request #14207: URL: https://github.com/apache/flink/pull/14207#issuecomment-733511087 ## CI report: * da25b44d59f5a02f8d780c17ee45f828fd2fd746 Azure:

[jira] [Commented] (FLINK-18577) Mail.run Blocked By the Legacy Source Thread

2020-12-07 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17245108#comment-17245108 ] Arvid Heise commented on FLINK-18577: - Sorry for the late reply. Jira is not the best place to ask -

[GitHub] [flink] flinkbot commented on pull request #14319: [FLINK-16582][runtime][test] Fix the buffer leaks in NettyBufferPoolTest

2020-12-07 Thread GitBox
flinkbot commented on pull request #14319: URL: https://github.com/apache/flink/pull/14319#issuecomment-739818509 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 edited a comment on pull request #14246: [FLINK-20273][table/kafka] Fix the Kafka round-robin behaviour when k…

2020-12-07 Thread GitBox
flinkbot edited a comment on pull request #14246: URL: https://github.com/apache/flink/pull/14246#issuecomment-734760092 ## CI report: * 9d856871e79c3bbe65054c145c51e410f83d5c65 Azure:

[GitHub] [flink] azagrebin commented on a change in pull request #14301: [FLINK-20468][minicluster] Enable leadership control in MiniCluster to test JM failover

2020-12-07 Thread GitBox
azagrebin commented on a change in pull request #14301: URL: https://github.com/apache/flink/pull/14301#discussion_r537325089 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/PerJobCheckpointRecoveryFactory.java ## @@ -29,13 +30,13 @@ * Simple

[jira] [Commented] (FLINK-20493) SQLClientSchemaRegistryITCase failed with "Could not build the flink-dist image"

2020-12-07 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17245126#comment-17245126 ] Dawid Wysakowicz commented on FLINK-20493: -- I think the problem is indeed the Timeout. All

[GitHub] [flink] flinkbot edited a comment on pull request #14245: [FLINK-18897][doc] Add document for Maxwell format

2020-12-07 Thread GitBox
flinkbot edited a comment on pull request #14245: URL: https://github.com/apache/flink/pull/14245#issuecomment-734680404 ## CI report: * c25898fd6f2e103bad60d6e05f1efd633e6fd53f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14246: [FLINK-20273][table/kafka] Fix the Kafka round-robin behaviour when k…

2020-12-07 Thread GitBox
flinkbot edited a comment on pull request #14246: URL: https://github.com/apache/flink/pull/14246#issuecomment-734760092 ## CI report: * 9d856871e79c3bbe65054c145c51e410f83d5c65 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14301: [FLINK-20468][minicluster] Enable leadership control in MiniCluster to test JM failover

2020-12-07 Thread GitBox
flinkbot edited a comment on pull request #14301: URL: https://github.com/apache/flink/pull/14301#issuecomment-738011652 ## CI report: * 7170ccf1ed3381fd6ffe951fa5de2b16f0032866 Azure:

[jira] [Updated] (FLINK-20510) Enable log4j2 monitor interval by default

2020-12-07 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20510: --- Labels: pull-request-available (was: ) > Enable log4j2 monitor interval by default >

[GitHub] [flink] zentol opened a new pull request #14321: [FLINK-20510][conf][log4j] Enable monitorInterval by default

2020-12-07 Thread GitBox
zentol opened a new pull request #14321: URL: https://github.com/apache/flink/pull/14321 This PR sets the log4j monitorInterval to 30 seconds by default, allowing the configuration to be changed at runtime. Note: I tried to do the same for logback, but it just kinda broke down and

[GitHub] [flink] flinkbot edited a comment on pull request #14320: [FLINK-20273][table/kafka] Fix the Kafka round-robin behaviour when keys are specified

2020-12-07 Thread GitBox
flinkbot edited a comment on pull request #14320: URL: https://github.com/apache/flink/pull/14320#issuecomment-739850702 ## CI report: * 2509ebe31f385834f0192751325acae4f95b0787 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14317: [FLINK-20482][python] Support General Python UDF for Map Operation in Python Table API

2020-12-07 Thread GitBox
flinkbot edited a comment on pull request #14317: URL: https://github.com/apache/flink/pull/14317#issuecomment-739722178 ## CI report: * 30da4a1bb767333e186368eb2591905eac446239 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14310: [FLINK-20486][hive] Hive temporal join shouldn't require a minimal 1h monitor interval

2020-12-07 Thread GitBox
flinkbot edited a comment on pull request #14310: URL: https://github.com/apache/flink/pull/14310#issuecomment-738741642 ## CI report: * 9a8532f2384af5fab3b187902da54c32d05b713a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14316: [FLINK-20470]MissingNode can't be casted to ObjectNode when deserializing JSON

2020-12-07 Thread GitBox
flinkbot edited a comment on pull request #14316: URL: https://github.com/apache/flink/pull/14316#issuecomment-739721953 ## CI report: * b2ba16cf998b31ec52c2bf0ebd1be8d539aafb98 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14165: [FLINK-19687][table] Support to get execution plan from StatementSet

2020-12-07 Thread GitBox
flinkbot edited a comment on pull request #14165: URL: https://github.com/apache/flink/pull/14165#issuecomment-732020040 ## CI report: * 9a54066e688f3de335b646b40b1888be88b41beb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14245: [FLINK-18897][doc] Add document for Maxwell format

2020-12-07 Thread GitBox
flinkbot edited a comment on pull request #14245: URL: https://github.com/apache/flink/pull/14245#issuecomment-734680404 ## CI report: * aed11d77062774064db10bdd6df54666a1ff98be Azure:

[GitHub] [flink] leonardBang commented on a change in pull request #14310: [FLINK-20486][hive] Hive temporal join shouldn't require a minimal 1h monitor interval

2020-12-07 Thread GitBox
leonardBang commented on a change in pull request #14310: URL: https://github.com/apache/flink/pull/14310#discussion_r537306539 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveLookupTableSource.java ## @@ -114,16 +117,16

[GitHub] [flink] SteNicholas commented on a change in pull request #14207: [FLINK-20250][table-runtime] NPE when invoking AsyncLookupJoinRunner#close method

2020-12-07 Thread GitBox
SteNicholas commented on a change in pull request #14207: URL: https://github.com/apache/flink/pull/14207#discussion_r537327673 ## File path: flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/operators/join/AsyncLookupJoinRunnerTest.java ## @@

[GitHub] [flink] wuchong commented on a change in pull request #14246: [FLINK-20273][table/kafka] Fix the Kafka round-robin behaviour when k…

2020-12-07 Thread GitBox
wuchong commented on a change in pull request #14246: URL: https://github.com/apache/flink/pull/14246#discussion_r537312778 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaOptions.java ## @@ -314,12

[jira] [Updated] (FLINK-17192) java.lang.RuntimeException: Error obtaining the sorted input: Thread 'SortMerger Reading Thread' terminated due to an exception: The record exceeds the maximum size of a

2020-12-07 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-17192: Affects Version/s: 1.12.0 > java.lang.RuntimeException: Error obtaining the sorted input: Thread

[GitHub] [flink] wuchong commented on pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion

2020-12-07 Thread GitBox
wuchong commented on pull request #6787: URL: https://github.com/apache/flink/pull/6787#issuecomment-739783961 Hi @rex-remind101 , this feature has been consumed by [FLIP-149](https://cwiki.apache.org/confluence/display/FLINK/FLIP-149%3A+Introduce+the+upsert-kafka+Connector) and

[GitHub] [flink] wuchong closed pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion

2020-12-07 Thread GitBox
wuchong closed pull request #6787: URL: https://github.com/apache/flink/pull/6787 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] SteNicholas commented on pull request #14207: [FLINK-20250][table-runtime] NPE when invoking AsyncLookupJoinRunner#close method

2020-12-07 Thread GitBox
SteNicholas commented on pull request #14207: URL: https://github.com/apache/flink/pull/14207#issuecomment-739783908 @leonardBang Thanks for your detailed review. Please review again for the commit changes about following your comments.

[jira] [Closed] (FLINK-8577) Implement proctime DataStream to Table upsert conversion.

2020-12-07 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-8577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-8577. -- Resolution: Duplicate This feature has been consumed by FLIP-149:

[jira] [Closed] (FLINK-10957) Adapt documents about DataStream to Table conversion

2020-12-07 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-10957. --- Resolution: Duplicate This feature has been consumed by FLIP-149:

[jira] [Closed] (FLINK-8578) Implement rowtime DataStream to Table upsert conversion.

2020-12-07 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-8578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-8578. -- Resolution: Duplicate This feature has been consumed by FLIP-149:

[jira] [Commented] (FLINK-20473) when get metrics option, its hard to see the full name unless u choosed

2020-12-07 Thread zlzhang0122 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17245085#comment-17245085 ] zlzhang0122 commented on FLINK-20473: - If necessary, can I take this and fix it? > when get metrics

[jira] [Updated] (FLINK-19537) Processed in-flight bytes metric is not accurate

2020-12-07 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-19537: Fix Version/s: 1.13.0 > Processed in-flight bytes metric is not accurate >

[GitHub] [flink] fsk119 commented on a change in pull request #14246: [FLINK-20273][table/kafka] Fix the Kafka round-robin behaviour when k…

2020-12-07 Thread GitBox
fsk119 commented on a change in pull request #14246: URL: https://github.com/apache/flink/pull/14246#discussion_r537352456 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaOptions.java ## @@ -314,12

[jira] [Updated] (FLINK-19016) Checksum mismatch when restore from RocksDB

2020-12-07 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-19016: Component/s: (was: Runtime / Checkpointing) Runtime / State Backends >

[jira] [Updated] (FLINK-18753) Support local recovery for Unaligned checkpoints

2020-12-07 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-18753: Fix Version/s: (was: 1.12.0) 1.13.0 > Support local recovery for Unaligned

[GitHub] [flink] godfreyhe merged pull request #14165: [FLINK-19687][table] Support to get execution plan from StatementSet

2020-12-07 Thread GitBox
godfreyhe merged pull request #14165: URL: https://github.com/apache/flink/pull/14165 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

[jira] [Updated] (FLINK-18572) Flink web UI doesn't display checkpoint configs like unaligned and tolerable-failed-checkpoints and

2020-12-07 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-18572: Component/s: (was: Runtime / Checkpointing) Runtime / Web Frontend

[GitHub] [flink] gaoyunhaii opened a new pull request #14319: [FLINK-16582][runtime][test] Fix the buffer leaks in NettyBufferPoolTest

2020-12-07 Thread GitBox
gaoyunhaii opened a new pull request #14319: URL: https://github.com/apache/flink/pull/14319 ## What is the purpose of the change This PR fixes the possible buffer leaks in `NettyBufferPoolTest`. ## Brief change log - 5028c1a894f46687d38fe91b34d096d858786772 records

[GitHub] [flink] tillrohrmann commented on a change in pull request #14305: [FLINK-20355][docs] Add new native K8s documentation page

2020-12-07 Thread GitBox
tillrohrmann commented on a change in pull request #14305: URL: https://github.com/apache/flink/pull/14305#discussion_r537395398 ## File path: docs/deployment/resource-providers/native_kubernetes.md ## @@ -24,394 +23,269 @@ specific language governing permissions and

[GitHub] [flink] flinkbot edited a comment on pull request #14246: [FLINK-20273][table/kafka] Fix the Kafka round-robin behaviour when k…

2020-12-07 Thread GitBox
flinkbot edited a comment on pull request #14246: URL: https://github.com/apache/flink/pull/14246#issuecomment-734760092 ## CI report: * 9d856871e79c3bbe65054c145c51e410f83d5c65 Azure:

[GitHub] [flink] azagrebin commented on pull request #14301: [FLINK-20468][minicluster] Enable leadership control in MiniCluster to test JM failover

2020-12-07 Thread GitBox
azagrebin commented on pull request #14301: URL: https://github.com/apache/flink/pull/14301#issuecomment-739833708 Thanks for the review @tillrohrmann I have addressed comments, the PR will be merged after the CI is green

[jira] [Created] (FLINK-20509) Refactor verifyPlan method in TableTestBase

2020-12-07 Thread godfrey he (Jira)
godfrey he created FLINK-20509: -- Summary: Refactor verifyPlan method in TableTestBase Key: FLINK-20509 URL: https://issues.apache.org/jira/browse/FLINK-20509 Project: Flink Issue Type: Sub-task

[GitHub] [flink] flinkbot commented on pull request #14320: [FLINK-20273][table/kafka] Fix the Kafka round-robin behaviour when keys are specified

2020-12-07 Thread GitBox
flinkbot commented on pull request #14320: URL: https://github.com/apache/flink/pull/14320#issuecomment-739841484 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] SteNicholas commented on pull request #14207: [FLINK-20250][table-runtime] NPE when invoking AsyncLookupJoinRunner#close method

2020-12-07 Thread GitBox
SteNicholas commented on pull request #14207: URL: https://github.com/apache/flink/pull/14207#issuecomment-739845675 @wuchong , IMO, `AsyncLookupJoinRunnerTest ` is only tested for `AsyncLookupJoinRunner`, and could be merged into `AsyncLookupJoinHarnessTest`. But does this merge follows

[jira] [Commented] (FLINK-17571) A better way to show the files used in currently checkpoints

2020-12-07 Thread Jiayi Liao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17245142#comment-17245142 ] Jiayi Liao commented on FLINK-17571: [~klion26] Is it necessary to list the checkpoint file in JM by

[jira] [Created] (FLINK-20512) Introduce getDescription, getOutputType, replaceInputEdge methods for ExecNode

2020-12-07 Thread godfrey he (Jira)
godfrey he created FLINK-20512: -- Summary: Introduce getDescription, getOutputType, replaceInputEdge methods for ExecNode Key: FLINK-20512 URL: https://issues.apache.org/jira/browse/FLINK-20512 Project:

[jira] [Commented] (FLINK-20473) when get metrics option, its hard to see the full name unless u choosed

2020-12-07 Thread Fangliang Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17245069#comment-17245069 ] Fangliang Liu commented on FLINK-20473: --- +1 > when get metrics option, its hard to see the full

[jira] [Updated] (FLINK-19988) Make Approximate Local Recovery Compatible With Unaligned Checkpoint

2020-12-07 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-19988: Affects Version/s: 1.12.0 > Make Approximate Local Recovery Compatible With Unaligned Checkpoint

[jira] [Updated] (FLINK-19938) Implement shuffle data read scheduling for sort-merge blocking shuffle

2020-12-07 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-19938: Fix Version/s: 1.13.0 > Implement shuffle data read scheduling for sort-merge blocking shuffle >

[jira] [Updated] (FLINK-19988) Make Approximate Local Recovery Compatible With Unaligned Checkpoint

2020-12-07 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-19988: Fix Version/s: 1.13.0 > Make Approximate Local Recovery Compatible With Unaligned Checkpoint >

[GitHub] [flink] flinkbot edited a comment on pull request #14207: [FLINK-20250][table-runtime] NPE when invoking AsyncLookupJoinRunner#close method

2020-12-07 Thread GitBox
flinkbot edited a comment on pull request #14207: URL: https://github.com/apache/flink/pull/14207#issuecomment-733511087 ## CI report: * da25b44d59f5a02f8d780c17ee45f828fd2fd746 Azure:

[GitHub] [flink] MyLanPangzi closed pull request #14318: 1.11.2-clickhousedialect

2020-12-07 Thread GitBox
MyLanPangzi closed pull request #14318: URL: https://github.com/apache/flink/pull/14318 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to

[jira] [Commented] (FLINK-18578) Add rejecting checkpoint logic in source

2020-12-07 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17245105#comment-17245105 ] Arvid Heise commented on FLINK-18578: - This sounds to me as if this should be implemented in the new

[jira] [Assigned] (FLINK-20493) SQLClientSchemaRegistryITCase failed with "Could not build the flink-dist image"

2020-12-07 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-20493: Assignee: Dawid Wysakowicz > SQLClientSchemaRegistryITCase failed with "Could

[GitHub] [flink] tillrohrmann commented on pull request #14305: [FLINK-20355][docs] Add new native K8s documentation page

2020-12-07 Thread GitBox
tillrohrmann commented on pull request #14305: URL: https://github.com/apache/flink/pull/14305#issuecomment-739835586 Thanks a lot for the review @zentol and @wangyang0918. I have addressed most of your comments and pushed an update.

[GitHub] [flink] flinkbot commented on pull request #14319: [FLINK-16582][runtime][test] Fix the buffer leaks in NettyBufferPoolTest

2020-12-07 Thread GitBox
flinkbot commented on pull request #14319: URL: https://github.com/apache/flink/pull/14319#issuecomment-739835572 ## CI report: * 5028c1a894f46687d38fe91b34d096d858786772 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #14320: [FLINK-20273][table/kafka] Fix the Kafka round-robin behaviour when keys are specified

2020-12-07 Thread GitBox
flinkbot commented on pull request #14320: URL: https://github.com/apache/flink/pull/14320#issuecomment-739850702 ## CI report: * 2509ebe31f385834f0192751325acae4f95b0787 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #14310: [FLINK-20486][hive] Hive temporal join shouldn't require a minimal 1h monitor interval

2020-12-07 Thread GitBox
flinkbot edited a comment on pull request #14310: URL: https://github.com/apache/flink/pull/14310#issuecomment-738741642 ## CI report: * cded2fcb5f10c8d6bdbfdece1c591fa658377f90 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14267: [FLINK-20429][kafka] Using proper watermark interval in KafkaTableITCase.testKafkaTemporalJoinChangelog test

2020-12-07 Thread GitBox
flinkbot edited a comment on pull request #14267: URL: https://github.com/apache/flink/pull/14267#issuecomment-736183950 ## CI report: * dda43957a8fed853659da60acabcd64671b2b169 Azure:

[GitHub] [flink] leonardBang commented on a change in pull request #14207: [FLINK-20250][table-runtime] NPE when invoking AsyncLookupJoinRunner#close method

2020-12-07 Thread GitBox
leonardBang commented on a change in pull request #14207: URL: https://github.com/apache/flink/pull/14207#discussion_r537301639 ## File path: flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/operators/join/AsyncLookupJoinRunnerTest.java ## @@

[GitHub] [flink] leonardBang commented on a change in pull request #14195: [FLINK-20300] Add Flink 1.12 release notes

2020-12-07 Thread GitBox
leonardBang commented on a change in pull request #14195: URL: https://github.com/apache/flink/pull/14195#discussion_r537316432 ## File path: docs/release-notes/flink-1.12.md ## @@ -0,0 +1,173 @@ +--- +title: "Release Notes - Flink 1.12" +--- + + + +These release notes discuss

[jira] [Commented] (FLINK-20505) Yarn provided lib does not work with http paths.

2020-12-07 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17245065#comment-17245065 ] zoucao commented on FLINK-20505: hi [~xintongsong] I' m willing to work on this issue. But I am not

[jira] [Commented] (FLINK-20505) Yarn provided lib does not work with http paths.

2020-12-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17245071#comment-17245071 ] Xintong Song commented on FLINK-20505: -- [~zoucao], I don't think it requires a FLIP for this

[GitHub] [flink] wuchong closed pull request #14088: [FLINK-20168][docs-zh] Translate page 'Flink Architecture' into Chinese.

2020-12-07 Thread GitBox
wuchong closed pull request #14088: URL: https://github.com/apache/flink/pull/14088 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] [Updated] (FLINK-16931) Large _metadata file lead to JobManager not responding when restart

2020-12-07 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-16931: Affects Version/s: 1.12.0 > Large _metadata file lead to JobManager not responding when restart >

[jira] [Updated] (FLINK-16945) Execute CheckpointFailureManager.FailJobCallback directly in main thread executor

2020-12-07 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-16945: Affects Version/s: 1.12.0 1.11.2 > Execute

[GitHub] [flink] V1ncentzzZ removed a comment on pull request #14165: [FLINK-19687][table] Support to get execution plan from StatementSet

2020-12-07 Thread GitBox
V1ncentzzZ removed a comment on pull request #14165: URL: https://github.com/apache/flink/pull/14165#issuecomment-739642703 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the

[jira] [Closed] (FLINK-8545) Implement upsert stream table source

2020-12-07 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-8545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-8545. -- Resolution: Fixed This feature has been consumed by FLIP-149:

[GitHub] [flink] tillrohrmann commented on a change in pull request #14305: [FLINK-20355][docs] Add new native K8s documentation page

2020-12-07 Thread GitBox
tillrohrmann commented on a change in pull request #14305: URL: https://github.com/apache/flink/pull/14305#discussion_r537386611 ## File path: docs/deployment/resource-providers/native_kubernetes.md ## @@ -24,394 +23,244 @@ specific language governing permissions and

[GitHub] [flink] tillrohrmann commented on a change in pull request #14305: [FLINK-20355][docs] Add new native K8s documentation page

2020-12-07 Thread GitBox
tillrohrmann commented on a change in pull request #14305: URL: https://github.com/apache/flink/pull/14305#discussion_r537397547 ## File path: docs/deployment/resource-providers/native_kubernetes.md ## @@ -24,394 +23,269 @@ specific language governing permissions and

[GitHub] [flink] wuchong commented on pull request #14207: [FLINK-20250][table-runtime] NPE when invoking AsyncLookupJoinRunner#close method

2020-12-07 Thread GitBox
wuchong commented on pull request #14207: URL: https://github.com/apache/flink/pull/14207#issuecomment-739829624 Could we merge `AsyncLookupJoinRunnerTest` and `AsyncLookupJoinTestBase` into `AsyncLookupJoinHarnessTest`? From my point of view, it is still an unit test for

[GitHub] [flink] tillrohrmann commented on a change in pull request #14305: [FLINK-20355][docs] Add new native K8s documentation page

2020-12-07 Thread GitBox
tillrohrmann commented on a change in pull request #14305: URL: https://github.com/apache/flink/pull/14305#discussion_r537400724 ## File path: docs/deployment/resource-providers/native_kubernetes.md ## @@ -24,394 +23,269 @@ specific language governing permissions and

[GitHub] [flink] fsk119 opened a new pull request #14320: [FLINK-20273][table/kafka] Fix the Kafka round-robin behaviour when keys are specified

2020-12-07 Thread GitBox
fsk119 opened a new pull request #14320: URL: https://github.com/apache/flink/pull/14320 ## What is the purpose of the change *Fix the kafka round-robin partition behaviour.* ## Brief change log - *Add value `'default'` for option `'sink.partitioner'`.

[jira] [Created] (FLINK-20510) Enable log4j2 monitor interval by default

2020-12-07 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-20510: Summary: Enable log4j2 monitor interval by default Key: FLINK-20510 URL: https://issues.apache.org/jira/browse/FLINK-20510 Project: Flink Issue

[GitHub] [flink] flinkbot commented on pull request #14321: [FLINK-20510][conf][log4j] Enable monitorInterval by default

2020-12-07 Thread GitBox
flinkbot commented on pull request #14321: URL: https://github.com/apache/flink/pull/14321#issuecomment-739871145 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Created] (FLINK-20508) Introduce PythonStreamGroupTableAggregateOperator

2020-12-07 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-20508: Summary: Introduce PythonStreamGroupTableAggregateOperator Key: FLINK-20508 URL: https://issues.apache.org/jira/browse/FLINK-20508 Project: Flink Issue

[GitHub] [flink] leonardBang commented on a change in pull request #14207: [FLINK-20250][table-runtime] NPE when invoking AsyncLookupJoinRunner#close method

2020-12-07 Thread GitBox
leonardBang commented on a change in pull request #14207: URL: https://github.com/apache/flink/pull/14207#discussion_r537301231 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/join/lookup/AsyncLookupJoinRunner.java ##

[GitHub] [flink] flinkbot edited a comment on pull request #14245: [FLINK-18897][doc] Add document for Maxwell format

2020-12-07 Thread GitBox
flinkbot edited a comment on pull request #14245: URL: https://github.com/apache/flink/pull/14245#issuecomment-734680404 ## CI report: * aed11d77062774064db10bdd6df54666a1ff98be Azure:

[GitHub] [flink] azagrebin commented on a change in pull request #14301: [FLINK-20468][minicluster] Enable leadership control in MiniCluster to test JM failover

2020-12-07 Thread GitBox
azagrebin commented on a change in pull request #14301: URL: https://github.com/apache/flink/pull/14301#discussion_r537330059 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniCluster.java ## @@ -938,6 +962,13 @@ private void

[GitHub] [flink] flinkbot edited a comment on pull request #14245: [FLINK-18897][doc] Add document for Maxwell format

2020-12-07 Thread GitBox
flinkbot edited a comment on pull request #14245: URL: https://github.com/apache/flink/pull/14245#issuecomment-734680404 ## CI report: * c25898fd6f2e103bad60d6e05f1efd633e6fd53f Azure:

[jira] [Updated] (FLINK-17043) Putting more information into accounting when failing a job in FailureManager

2020-12-07 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-17043: Affects Version/s: 1.13.0 > Putting more information into accounting when failing a job in

[jira] [Reopened] (FLINK-8545) Implement upsert stream table source

2020-12-07 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-8545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reopened FLINK-8545: > Implement upsert stream table source > - > > Key:

[jira] [Closed] (FLINK-8545) Implement upsert stream table source

2020-12-07 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-8545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-8545. -- Resolution: Duplicate > Implement upsert stream table source > - > >

[jira] [Commented] (FLINK-16582) NettyBufferPoolTest may have warns on NettyBuffer leak

2020-12-07 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17245091#comment-17245091 ] Yun Gao commented on FLINK-16582: - Hi [~AHeise], very sorry for the long delay, I'll open a PR for this

[jira] [Updated] (FLINK-19682) Actively timeout checkpoint barriers on the inputs

2020-12-07 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-19682: Fix Version/s: 1.13.0 > Actively timeout checkpoint barriers on the inputs >

[jira] [Updated] (FLINK-19683) Actively timeout aligned checkpoints on the output

2020-12-07 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-19683: Fix Version/s: 1.13.0 > Actively timeout aligned checkpoints on the output >

[jira] [Updated] (FLINK-18983) Job doesn't changed to failed if close function has blocked

2020-12-07 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-18983: Affects Version/s: 1.12.0 > Job doesn't changed to failed if close function has blocked >

[GitHub] [flink] flinkbot commented on pull request #14318: 1.11.2-clickhousedialect

2020-12-07 Thread GitBox
flinkbot commented on pull request #14318: URL: https://github.com/apache/flink/pull/14318#issuecomment-739803495 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-16582) NettyBufferPoolTest may have warns on NettyBuffer leak

2020-12-07 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16582: --- Labels: pull-request-available (was: ) > NettyBufferPoolTest may have warns on NettyBuffer

[GitHub] [flink] tillrohrmann commented on a change in pull request #14305: [FLINK-20355][docs] Add new native K8s documentation page

2020-12-07 Thread GitBox
tillrohrmann commented on a change in pull request #14305: URL: https://github.com/apache/flink/pull/14305#discussion_r537388052 ## File path: docs/deployment/resource-providers/native_kubernetes.md ## @@ -24,394 +23,244 @@ specific language governing permissions and

[GitHub] [flink] tillrohrmann commented on a change in pull request #14305: [FLINK-20355][docs] Add new native K8s documentation page

2020-12-07 Thread GitBox
tillrohrmann commented on a change in pull request #14305: URL: https://github.com/apache/flink/pull/14305#discussion_r537394288 ## File path: docs/deployment/resource-providers/native_kubernetes.md ## @@ -24,394 +23,269 @@ specific language governing permissions and

[GitHub] [flink] tillrohrmann commented on a change in pull request #14305: [FLINK-20355][docs] Add new native K8s documentation page

2020-12-07 Thread GitBox
tillrohrmann commented on a change in pull request #14305: URL: https://github.com/apache/flink/pull/14305#discussion_r537393647 ## File path: docs/deployment/resource-providers/native_kubernetes.md ## @@ -24,394 +23,269 @@ specific language governing permissions and

[GitHub] [flink] tillrohrmann commented on a change in pull request #14305: [FLINK-20355][docs] Add new native K8s documentation page

2020-12-07 Thread GitBox
tillrohrmann commented on a change in pull request #14305: URL: https://github.com/apache/flink/pull/14305#discussion_r537399899 ## File path: docs/deployment/resource-providers/native_kubernetes.md ## @@ -24,394 +23,269 @@ specific language governing permissions and

  1   2   3   4   5   6   7   8   >