[GitHub] [flink] zentol commented on a change in pull request #11667: [FLINK-15936] Harden TaskExecutorTest#testSlotAcceptance

zentol commented on a change in pull request #11667: [FLINK-15936] Harden TaskExecutorTest#testSlotAcceptance URL: https://github.com/apache/flink/pull/11667#discussion_r405987107 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/TaskExecutorTest.java

[GitHub] [flink] zhuzhurk commented on a change in pull request #11647: [FLINK-16960][runtime] Add PipelinedRegion interface

zhuzhurk commented on a change in pull request #11647: [FLINK-16960][runtime] Add PipelinedRegion interface URL: https://github.com/apache/flink/pull/11647#discussion_r405991335 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/topology/ILogicalPipelinedRe

[GitHub] [flink] zhuzhurk commented on a change in pull request #11647: [FLINK-16960][runtime] Add PipelinedRegion interface

zhuzhurk commented on a change in pull request #11647: [FLINK-16960][runtime] Add PipelinedRegion interface URL: https://github.com/apache/flink/pull/11647#discussion_r405991335 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/topology/ILogicalPipelinedRe

[jira] [Commented] (FLINK-17059) flink-shaded-hadoop-2-uber:2.8.3-10.0 has invalid pom in Gradle

[ https://issues.apache.org/jira/browse/FLINK-17059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17078985#comment-17078985 ] Chesnay Schepler commented on FLINK-17059: -- [~johnlon] flink-shaded 11 hasn't b

[jira] [Comment Edited] (FLINK-17059) flink-shaded-hadoop-2-uber:2.8.3-10.0 has invalid pom in Gradle

[ https://issues.apache.org/jira/browse/FLINK-17059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17078985#comment-17078985 ] Chesnay Schepler edited comment on FLINK-17059 at 4/9/20, 6:48 AM: ---

[GitHub] [flink] flinkbot edited a comment on issue #11679: [FLINK-16864][metrics] Add IdleTime metric for task.

flinkbot edited a comment on issue #11679: [FLINK-16864][metrics] Add IdleTime metric for task. URL: https://github.com/apache/flink/pull/11679#issuecomment-611318400 ## CI report: * 9cd7e32a68f82470bc05735009c1c0377d066d44 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci

[GitHub] [flink] zhuzhurk commented on a change in pull request #11647: [FLINK-16960][runtime] Add PipelinedRegion interface

zhuzhurk commented on a change in pull request #11647: [FLINK-16960][runtime] Add PipelinedRegion interface URL: https://github.com/apache/flink/pull/11647#discussion_r405987424 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/topology/SimpleTopology.java ###

[GitHub] [flink] flinkbot edited a comment on issue #11448: [FLINK-16666][python][table] Introduce Python dependency config options

flinkbot edited a comment on issue #11448: [FLINK-1][python][table] Introduce Python dependency config options URL: https://github.com/apache/flink/pull/11448#issuecomment-601042255 ## CI report: * 4e319d5b9d7f686b01d7691ec11c3b9303b9a693 UNKNOWN * 459be57c0b44fcc27c5e475e

[GitHub] [flink] wenlong88 commented on issue #11679: [FLINK-16864][metrics] Add IdleTime metric for task.

wenlong88 commented on issue #11679: [FLINK-16864][metrics] Add IdleTime metric for task. URL: https://github.com/apache/flink/pull/11679#issuecomment-611357905 @pnowojski thanks for reviewing again. Tests on Travis have passed, so I merged the two commits. --

[GitHub] [flink] hequn8128 commented on a change in pull request #11670: [FLINK-16761][python]Return JobExecutionResult for Python ExecutionEnvironment and TableEnvironment

hequn8128 commented on a change in pull request #11670: [FLINK-16761][python]Return JobExecutionResult for Python ExecutionEnvironment and TableEnvironment URL: https://github.com/apache/flink/pull/11670#discussion_r405980452 ## File path: flink-python/pyflink/common/job_execution_

[GitHub] [flink] hequn8128 commented on a change in pull request #11670: [FLINK-16761][python]Return JobExecutionResult for Python ExecutionEnvironment and TableEnvironment

hequn8128 commented on a change in pull request #11670: [FLINK-16761][python]Return JobExecutionResult for Python ExecutionEnvironment and TableEnvironment URL: https://github.com/apache/flink/pull/11670#discussion_r405970221 ## File path: flink-python/pyflink/common/job_execution_

[GitHub] [flink] hequn8128 commented on a change in pull request #11670: [FLINK-16761][python]Return JobExecutionResult for Python ExecutionEnvironment and TableEnvironment

hequn8128 commented on a change in pull request #11670: [FLINK-16761][python]Return JobExecutionResult for Python ExecutionEnvironment and TableEnvironment URL: https://github.com/apache/flink/pull/11670#discussion_r405975388 ## File path: flink-python/pyflink/common/job_execution_

[GitHub] [flink] hequn8128 commented on a change in pull request #11670: [FLINK-16761][python]Return JobExecutionResult for Python ExecutionEnvironment and TableEnvironment

hequn8128 commented on a change in pull request #11670: [FLINK-16761][python]Return JobExecutionResult for Python ExecutionEnvironment and TableEnvironment URL: https://github.com/apache/flink/pull/11670#discussion_r405973457 ## File path: flink-python/pyflink/common/job_execution_

[GitHub] [flink] hequn8128 commented on a change in pull request #11670: [FLINK-16761][python]Return JobExecutionResult for Python ExecutionEnvironment and TableEnvironment

hequn8128 commented on a change in pull request #11670: [FLINK-16761][python]Return JobExecutionResult for Python ExecutionEnvironment and TableEnvironment URL: https://github.com/apache/flink/pull/11670#discussion_r405980452 ## File path: flink-python/pyflink/common/job_execution_

[GitHub] [flink] hequn8128 commented on a change in pull request #11670: [FLINK-16761][python]Return JobExecutionResult for Python ExecutionEnvironment and TableEnvironment

hequn8128 commented on a change in pull request #11670: [FLINK-16761][python]Return JobExecutionResult for Python ExecutionEnvironment and TableEnvironment URL: https://github.com/apache/flink/pull/11670#discussion_r405981673 ## File path: flink-python/pyflink/common/job_execution_

[GitHub] [flink] AHeise commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

AHeise commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#discussion_r405985420 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/i

[GitHub] [flink] zhuzhurk commented on a change in pull request #11647: [FLINK-16960][runtime] Add PipelinedRegion interface

zhuzhurk commented on a change in pull request #11647: [FLINK-16960][runtime] Add PipelinedRegion interface URL: https://github.com/apache/flink/pull/11647#discussion_r405984395 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/topology/Topology.java ## @

[jira] [Commented] (FLINK-14278) Pass in ioExecutor into AbstractDispatcherResourceManagerComponentFactory

[ https://issues.apache.org/jira/browse/FLINK-14278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17078975#comment-17078975 ] Chesnay Schepler commented on FLINK-14278: -- 1.9: ed8ff011a5696779a1df2fb41b7f5b

[GitHub] [flink] zhuzhurk commented on a change in pull request #11647: [FLINK-16960][runtime] Add PipelinedRegion interface

zhuzhurk commented on a change in pull request #11647: [FLINK-16960][runtime] Add PipelinedRegion interface URL: https://github.com/apache/flink/pull/11647#discussion_r405984395 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/topology/Topology.java ## @

[jira] [Updated] (FLINK-14278) Pass in ioExecutor into AbstractDispatcherResourceManagerComponentFactory

[ https://issues.apache.org/jira/browse/FLINK-14278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-14278: - Fix Version/s: 1.9.3 > Pass in ioExecutor into AbstractDispatcherResourceManagerComponen

[jira] [Comment Edited] (FLINK-15812) HistoryServer archiving is done in Dispatcher main thread

[ https://issues.apache.org/jira/browse/FLINK-15812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17078694#comment-17078694 ] Chesnay Schepler edited comment on FLINK-15812 at 4/9/20, 6:34 AM: ---

[GitHub] [flink] zentol merged pull request #11677: [1.9][FLINK-15812][runtime] Archive jobs asynchronously

zentol merged pull request #11677: [1.9][FLINK-15812][runtime] Archive jobs asynchronously URL: https://github.com/apache/flink/pull/11677 This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] flinkbot edited a comment on issue #11545: [FLINK-16742][runtime][dist] Extend and use BashJavaUtils to start JM JVM process and pass JVM memory args

flinkbot edited a comment on issue #11545: [FLINK-16742][runtime][dist] Extend and use BashJavaUtils to start JM JVM process and pass JVM memory args URL: https://github.com/apache/flink/pull/11545#issuecomment-604848813 ## CI report: * d8814c3aed36cea34b5069b2a270df8033d29956 Tr

[GitHub] [flink] flinkbot edited a comment on issue #11673: [FLINK-17047] Simplify SchedulingStrategy#onPartitionConsumable(...) parameters

flinkbot edited a comment on issue #11673: [FLINK-17047] Simplify SchedulingStrategy#onPartitionConsumable(...) parameters URL: https://github.com/apache/flink/pull/11673#issuecomment-611013893 ## CI report: * 53754d0e0bf61c727c3cee87f82025826e298d28 Travis: [SUCCESS](https://tr

[GitHub] [flink] flinkbot edited a comment on issue #11545: [FLINK-16742][runtime][dist] Extend and use BashJavaUtils to start JM JVM process and pass JVM memory args

flinkbot edited a comment on issue #11545: [FLINK-16742][runtime][dist] Extend and use BashJavaUtils to start JM JVM process and pass JVM memory args URL: https://github.com/apache/flink/pull/11545#issuecomment-604848813 ## CI report: * d8814c3aed36cea34b5069b2a270df8033d29956 Tr

[GitHub] [flink] flinkbot edited a comment on issue #11679: [FLINK-16864][metrics] Add IdleTime metric for task.

flinkbot edited a comment on issue #11679: [FLINK-16864][metrics] Add IdleTime metric for task. URL: https://github.com/apache/flink/pull/11679#issuecomment-611318400 ## CI report: * 9cd7e32a68f82470bc05735009c1c0377d066d44 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci

[GitHub] [flink] xintongsong commented on issue #11323: [FLINK-16439][k8s] Make KubernetesResourceManager starts workers using WorkerResourceSpec requested by SlotManager

xintongsong commented on issue #11323: [FLINK-16439][k8s] Make KubernetesResourceManager starts workers using WorkerResourceSpec requested by SlotManager URL: https://github.com/apache/flink/pull/11323#issuecomment-611341817 @tillrohrmann I've addressed your comments in #11353 rela

[GitHub] [flink] pnowojski commented on issue #11679: [FLINK-16864][metrics] Add IdleTime metric for task.

pnowojski commented on issue #11679: [FLINK-16864][metrics] Add IdleTime metric for task. URL: https://github.com/apache/flink/pull/11679#issuecomment-611341172 Thanks for the quick fix @wenlong88. Let's wait for the Azure/Travis to complete. Also before merging we should squash those two

[GitHub] [flink] xintongsong commented on issue #11545: [FLINK-16742][runtime][dist] Extend and use BashJavaUtils to start JM JVM process and pass JVM memory args

xintongsong commented on issue #11545: [FLINK-16742][runtime][dist] Extend and use BashJavaUtils to start JM JVM process and pass JVM memory args URL: https://github.com/apache/flink/pull/11545#issuecomment-611340674 @azagrebin I've addressed your comments. Please take a look at your co

[GitHub] [flink] flinkbot edited a comment on issue #11651: [FLINK-16995][table-common] Add new data structure interfaces in table-common

flinkbot edited a comment on issue #11651: [FLINK-16995][table-common] Add new data structure interfaces in table-common URL: https://github.com/apache/flink/pull/11651#issuecomment-610151078 ## CI report: * d13c6fac2cb9688d3c8577744d7a3279cf805491 Travis: [SUCCESS](https://trav

[GitHub] [flink] flinkbot edited a comment on issue #11589: [FLINK-15486][tests] Remove timeout of LocalInputChannelTest#testConcurrentConsumeMultiplePartitions to avoid potential timeout problem on s

flinkbot edited a comment on issue #11589: [FLINK-15486][tests] Remove timeout of LocalInputChannelTest#testConcurrentConsumeMultiplePartitions to avoid potential timeout problem on slow machine. URL: https://github.com/apache/flink/pull/11589#issuecomment-607063006 ## CI report:

[GitHub] [flink] flinkbot edited a comment on issue #11448: [FLINK-16666][python][table] Introduce Python dependency config options

flinkbot edited a comment on issue #11448: [FLINK-1][python][table] Introduce Python dependency config options URL: https://github.com/apache/flink/pull/11448#issuecomment-601042255 ## CI report: * 4e319d5b9d7f686b01d7691ec11c3b9303b9a693 UNKNOWN * 1feab8b38ae9ca048972ea1e

[jira] [Commented] (FLINK-16921) "kubernetes session test" is unstable

[ https://issues.apache.org/jira/browse/FLINK-16921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17078928#comment-17078928 ] Yang Wang commented on FLINK-16921: --- Unfortunately, adding the connection timeout for

[GitHub] [flink] wangyang0918 commented on issue #11427: [FLINK-15790][k8s] Make FlinkKubeClient and its implementations asynchronous

wangyang0918 commented on issue #11427: [FLINK-15790][k8s] Make FlinkKubeClient and its implementations asynchronous URL: https://github.com/apache/flink/pull/11427#issuecomment-611331869 @flinkbot run azure This is an automa

[GitHub] [flink] flinkbot edited a comment on issue #11589: [FLINK-15486][tests] Remove timeout of LocalInputChannelTest#testConcurrentConsumeMultiplePartitions to avoid potential timeout problem on s

flinkbot edited a comment on issue #11589: [FLINK-15486][tests] Remove timeout of LocalInputChannelTest#testConcurrentConsumeMultiplePartitions to avoid potential timeout problem on slow machine. URL: https://github.com/apache/flink/pull/11589#issuecomment-607063006 ## CI report:

[GitHub] [flink] flinkbot edited a comment on issue #11448: [FLINK-16666][python][table] Introduce Python dependency config options

flinkbot edited a comment on issue #11448: [FLINK-1][python][table] Introduce Python dependency config options URL: https://github.com/apache/flink/pull/11448#issuecomment-601042255 ## CI report: * 4e319d5b9d7f686b01d7691ec11c3b9303b9a693 UNKNOWN * 1feab8b38ae9ca048972ea1e

[GitHub] [flink] flinkbot edited a comment on issue #11481: [FLINK-13691][Table]Remove deprecated query config

flinkbot edited a comment on issue #11481: [FLINK-13691][Table]Remove deprecated query config URL: https://github.com/apache/flink/pull/11481#issuecomment-602174011 ## CI report: * ee3e10ccd76d55290ea7639b6808f108ce8311dc Travis: [FAILURE](https://travis-ci.com/github/flink-ci/f

[GitHub] [flink] flinkbot edited a comment on issue #11674: [FLINK-16887][table-planner-blink] Refactor retraction rules to support inferring ChangelogMode

flinkbot edited a comment on issue #11674: [FLINK-16887][table-planner-blink] Refactor retraction rules to support inferring ChangelogMode URL: https://github.com/apache/flink/pull/11674#issuecomment-611092822 ## CI report: * 59ab8cedf26f3b55602b448951fa18e8e7997bb5 Travis: [FAI

[GitHub] [flink] wangyang0918 commented on a change in pull request #11639: [FLINK-16626][runtime] Prevent REST handler from being closed more than once

wangyang0918 commented on a change in pull request #11639: [FLINK-16626][runtime] Prevent REST handler from being closed more than once URL: https://github.com/apache/flink/pull/11639#discussion_r405952615 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/hand

[GitHub] [flink] wuchong commented on a change in pull request #11663: [FLINK-16820][jdbc] support reading timestamp, data, and time in JDBCTableSource

wuchong commented on a change in pull request #11663: [FLINK-16820][jdbc] support reading timestamp, data, and time in JDBCTableSource URL: https://github.com/apache/flink/pull/11663#discussion_r405950353 ## File path: flink-connectors/flink-jdbc/src/test/java/org/apache/flink/api/

[GitHub] [flink] wuchong commented on a change in pull request #11663: [FLINK-16820][jdbc] support reading timestamp, data, and time in JDBCTableSource

wuchong commented on a change in pull request #11663: [FLINK-16820][jdbc] support reading timestamp, data, and time in JDBCTableSource URL: https://github.com/apache/flink/pull/11663#discussion_r405948279 ## File path: flink-connectors/flink-jdbc/src/test/java/org/apache/flink/api/

[GitHub] [flink] wuchong commented on a change in pull request #11663: [FLINK-16820][jdbc] support reading timestamp, data, and time in JDBCTableSource

wuchong commented on a change in pull request #11663: [FLINK-16820][jdbc] support reading timestamp, data, and time in JDBCTableSource URL: https://github.com/apache/flink/pull/11663#discussion_r405949916 ## File path: flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/

[GitHub] [flink] wuchong commented on a change in pull request #11663: [FLINK-16820][jdbc] support reading timestamp, data, and time in JDBCTableSource

wuchong commented on a change in pull request #11663: [FLINK-16820][jdbc] support reading timestamp, data, and time in JDBCTableSource URL: https://github.com/apache/flink/pull/11663#discussion_r405944872 ## File path: flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/

[GitHub] [flink] flinkbot edited a comment on issue #11674: [FLINK-16887][table-planner-blink] Refactor retraction rules to support inferring ChangelogMode

flinkbot edited a comment on issue #11674: [FLINK-16887][table-planner-blink] Refactor retraction rules to support inferring ChangelogMode URL: https://github.com/apache/flink/pull/11674#issuecomment-611092822 ## CI report: * 59ab8cedf26f3b55602b448951fa18e8e7997bb5 Travis: [FAI

[GitHub] [flink] flinkbot edited a comment on issue #11679: [FLINK-16864][metrics] Add IdleTime metric for task.

flinkbot edited a comment on issue #11679: [FLINK-16864][metrics] Add IdleTime metric for task. URL: https://github.com/apache/flink/pull/11679#issuecomment-611318400 ## CI report: * 9cd7e32a68f82470bc05735009c1c0377d066d44 Travis: [PENDING](https://travis-ci.com/github/flink-ci

[GitHub] [flink] flinkbot edited a comment on issue #11323: [FLINK-16439][k8s] Make KubernetesResourceManager starts workers using WorkerResourceSpec requested by SlotManager

flinkbot edited a comment on issue #11323: [FLINK-16439][k8s] Make KubernetesResourceManager starts workers using WorkerResourceSpec requested by SlotManager URL: https://github.com/apache/flink/pull/11323#issuecomment-595267888 ## CI report: * edd2f98c2a607655aef8823024753fcceb

[GitHub] [flink] zhengcanbin commented on issue #11672: [FLINK-15817][k8s] Clean up residual resources when failed to deploy a Flink cluster

zhengcanbin commented on issue #11672: [FLINK-15817][k8s] Clean up residual resources when failed to deploy a Flink cluster URL: https://github.com/apache/flink/pull/11672#issuecomment-611321065 cc @tillrohrmann. Could you help take a look at this PR? It's a trivial improvement. -

[GitHub] [flink] flinkbot edited a comment on issue #11674: [FLINK-16887][table-planner-blink] Refactor retraction rules to support inferring ChangelogMode

flinkbot edited a comment on issue #11674: [FLINK-16887][table-planner-blink] Refactor retraction rules to support inferring ChangelogMode URL: https://github.com/apache/flink/pull/11674#issuecomment-611092822 ## CI report: * 6813ce29fd9023e8cba34f9539ed09b080401ba1 Travis: [FAI

[GitHub] [flink] flinkbot commented on issue #11679: [FLINK-16864][metrics] Add IdleTime metric for task.

flinkbot commented on issue #11679: [FLINK-16864][metrics] Add IdleTime metric for task. URL: https://github.com/apache/flink/pull/11679#issuecomment-611318400 ## CI report: * 9cd7e32a68f82470bc05735009c1c0377d066d44 UNKNOWN Bot commands The @flinkbot bot supports

[GitHub] [flink] flinkbot edited a comment on issue #11673: [FLINK-17047] Simplify SchedulingStrategy#onPartitionConsumable(...) parameters

flinkbot edited a comment on issue #11673: [FLINK-17047] Simplify SchedulingStrategy#onPartitionConsumable(...) parameters URL: https://github.com/apache/flink/pull/11673#issuecomment-611013893 ## CI report: * fd54e769bcf790e72cdfe4b2253059df1b12b6aa Travis: [FAILURE](https://tr

[GitHub] [flink] flinkbot edited a comment on issue #11674: [FLINK-16887][table-planner-blink] Refactor retraction rules to support inferring ChangelogMode

flinkbot edited a comment on issue #11674: [FLINK-16887][table-planner-blink] Refactor retraction rules to support inferring ChangelogMode URL: https://github.com/apache/flink/pull/11674#issuecomment-611092822 ## CI report: * 6813ce29fd9023e8cba34f9539ed09b080401ba1 Travis: [FAI

[GitHub] [flink] flinkbot commented on issue #11679: [FLINK-16864][metrics] Add IdleTime metric for task.

flinkbot commented on issue #11679: [FLINK-16864][metrics] Add IdleTime metric for task. URL: https://github.com/apache/flink/pull/11679#issuecomment-611314262 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull req

[GitHub] [flink] flinkbot edited a comment on issue #11651: [FLINK-16995][table-common] Add new data structure interfaces in table-common

flinkbot edited a comment on issue #11651: [FLINK-16995][table-common] Add new data structure interfaces in table-common URL: https://github.com/apache/flink/pull/11651#issuecomment-610151078 ## CI report: * 6b67024e06b0de3fc6fa79ce7e1296151e992819 Travis: [SUCCESS](https://trav

[GitHub] [flink] flinkbot edited a comment on issue #11673: [FLINK-17047] Simplify SchedulingStrategy#onPartitionConsumable(...) parameters

flinkbot edited a comment on issue #11673: [FLINK-17047] Simplify SchedulingStrategy#onPartitionConsumable(...) parameters URL: https://github.com/apache/flink/pull/11673#issuecomment-611013893 ## CI report: * fd54e769bcf790e72cdfe4b2253059df1b12b6aa Travis: [FAILURE](https://tr

[GitHub] [flink] flinkbot edited a comment on issue #11481: [FLINK-13691][Table]Remove deprecated query config

flinkbot edited a comment on issue #11481: [FLINK-13691][Table]Remove deprecated query config URL: https://github.com/apache/flink/pull/11481#issuecomment-602174011 ## CI report: * 7496b16e60235e78f93bb3a8538a1aaf5a5cb0ea Travis: [FAILURE](https://travis-ci.com/github/flink-ci/f

[GitHub] [flink] flinkbot edited a comment on issue #11323: [FLINK-16439][k8s] Make KubernetesResourceManager starts workers using WorkerResourceSpec requested by SlotManager

flinkbot edited a comment on issue #11323: [FLINK-16439][k8s] Make KubernetesResourceManager starts workers using WorkerResourceSpec requested by SlotManager URL: https://github.com/apache/flink/pull/11323#issuecomment-595267888 ## CI report: * edd2f98c2a607655aef8823024753fcceb

[GitHub] [flink] wenlong88 opened a new pull request #11679: [FLINK-16864][metrics] Add IdleTime metric for task.

wenlong88 opened a new pull request #11679: [FLINK-16864][metrics] Add IdleTime metric for task. URL: https://github.com/apache/flink/pull/11679 ## What is the purpose of the change This pr adds an IdleTime metric which measures idle time of a task including the time cost for mail proce

[jira] [Commented] (FLINK-15362) Bump Kafka client version to 2.4.0 for universal Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-15362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17078886#comment-17078886 ] Jiangjie Qin commented on FLINK-15362: -- [~pnowojski] I think it is possible. Let me

[GitHub] [flink] flinkbot edited a comment on issue #11651: [FLINK-16995][table-common] Add new data structure interfaces in table-common

flinkbot edited a comment on issue #11651: [FLINK-16995][table-common] Add new data structure interfaces in table-common URL: https://github.com/apache/flink/pull/11651#issuecomment-610151078 ## CI report: * 6b67024e06b0de3fc6fa79ce7e1296151e992819 Travis: [SUCCESS](https://trav

[GitHub] [flink] flinkbot edited a comment on issue #11481: [FLINK-13691][Table]Remove deprecated query config

flinkbot edited a comment on issue #11481: [FLINK-13691][Table]Remove deprecated query config URL: https://github.com/apache/flink/pull/11481#issuecomment-602174011 ## CI report: * 7496b16e60235e78f93bb3a8538a1aaf5a5cb0ea Travis: [FAILURE](https://travis-ci.com/github/flink-ci/f

[GitHub] [flink] flinkbot edited a comment on issue #11448: [FLINK-16666][python][table] Introduce Python dependency config options

flinkbot edited a comment on issue #11448: [FLINK-1][python][table] Introduce Python dependency config options URL: https://github.com/apache/flink/pull/11448#issuecomment-601042255 ## CI report: * 4e319d5b9d7f686b01d7691ec11c3b9303b9a693 UNKNOWN * 1feab8b38ae9ca048972ea1e

[GitHub] [flink] wuchong commented on issue #11651: [FLINK-16995][table-common] Add new data structure interfaces in table-common

wuchong commented on issue #11651: [FLINK-16995][table-common] Add new data structure interfaces in table-common URL: https://github.com/apache/flink/pull/11651#issuecomment-611305663 Rebased and added `GenericRowData`, `GenericMapData`, `GenericArrayData` because they are all public APIs

[GitHub] [flink] flinkbot edited a comment on issue #11323: [FLINK-16439][k8s] Make KubernetesResourceManager starts workers using WorkerResourceSpec requested by SlotManager

flinkbot edited a comment on issue #11323: [FLINK-16439][k8s] Make KubernetesResourceManager starts workers using WorkerResourceSpec requested by SlotManager URL: https://github.com/apache/flink/pull/11323#issuecomment-595267888 ## CI report: * edd2f98c2a607655aef8823024753fcceb

[GitHub] [flink] flinkbot edited a comment on issue #11672: [FLINK-15817][k8s] Clean up residual resources when failed to deploy a Flink cluster

flinkbot edited a comment on issue #11672: [FLINK-15817][k8s] Clean up residual resources when failed to deploy a Flink cluster URL: https://github.com/apache/flink/pull/11672#issuecomment-610981433 ## CI report: * f1faad82681c9b5c2fbda6c2cda5af3dd207ecdb Travis: [SUCCESS](https

[GitHub] [flink] flinkbot edited a comment on issue #11674: [FLINK-16887][table-planner-blink] Refactor retraction rules to support inferring ChangelogMode

flinkbot edited a comment on issue #11674: [FLINK-16887][table-planner-blink] Refactor retraction rules to support inferring ChangelogMode URL: https://github.com/apache/flink/pull/11674#issuecomment-611092822 ## CI report: * 6813ce29fd9023e8cba34f9539ed09b080401ba1 Travis: [FAI

[GitHub] [flink] flinkbot edited a comment on issue #11323: [FLINK-16439][k8s] Make KubernetesResourceManager starts workers using WorkerResourceSpec requested by SlotManager

flinkbot edited a comment on issue #11323: [FLINK-16439][k8s] Make KubernetesResourceManager starts workers using WorkerResourceSpec requested by SlotManager URL: https://github.com/apache/flink/pull/11323#issuecomment-595267888 ## CI report: * edd2f98c2a607655aef8823024753fcceb

[GitHub] [flink] flinkbot edited a comment on issue #11674: [FLINK-16887][table-planner-blink] Refactor retraction rules to support inferring ChangelogMode

flinkbot edited a comment on issue #11674: [FLINK-16887][table-planner-blink] Refactor retraction rules to support inferring ChangelogMode URL: https://github.com/apache/flink/pull/11674#issuecomment-611092822 ## CI report: * d8447d9c54212a7625a656a7ac3f03ae86e8c9b5 Travis: [FAI

[GitHub] [flink] flinkbot edited a comment on issue #11448: [FLINK-16666][python][table] Introduce Python dependency config options

flinkbot edited a comment on issue #11448: [FLINK-1][python][table] Introduce Python dependency config options URL: https://github.com/apache/flink/pull/11448#issuecomment-601042255 ## CI report: * 4e319d5b9d7f686b01d7691ec11c3b9303b9a693 UNKNOWN * b5183f0647bded85cec001dc

[GitHub] [flink] xintongsong commented on a change in pull request #11353: [FLINK-16438][yarn] Make YarnResourceManager starts workers using WorkerResourceSpec requested by SlotManager

xintongsong commented on a change in pull request #11353: [FLINK-16438][yarn] Make YarnResourceManager starts workers using WorkerResourceSpec requested by SlotManager URL: https://github.com/apache/flink/pull/11353#discussion_r405923606 ## File path: flink-kubernetes/src/main/jav

[jira] [Created] (FLINK-17061) Unset process/flink memory size from configuration once dynamic worker resource is activated.

Xintong Song created FLINK-17061: Summary: Unset process/flink memory size from configuration once dynamic worker resource is activated. Key: FLINK-17061 URL: https://issues.apache.org/jira/browse/FLINK-17061

[GitHub] [flink] flinkbot edited a comment on issue #11674: [FLINK-16887][table-planner-blink] Refactor retraction rules to support inferring ChangelogMode

flinkbot edited a comment on issue #11674: [FLINK-16887][table-planner-blink] Refactor retraction rules to support inferring ChangelogMode URL: https://github.com/apache/flink/pull/11674#issuecomment-611092822 ## CI report: * d8447d9c54212a7625a656a7ac3f03ae86e8c9b5 Travis: [FAI

[GitHub] [flink] flinkbot edited a comment on issue #11448: [FLINK-16666][python][table] Introduce Python dependency config options

flinkbot edited a comment on issue #11448: [FLINK-1][python][table] Introduce Python dependency config options URL: https://github.com/apache/flink/pull/11448#issuecomment-601042255 ## CI report: * 4e319d5b9d7f686b01d7691ec11c3b9303b9a693 UNKNOWN * b5183f0647bded85cec001dc

[GitHub] [flink] flinkbot edited a comment on issue #11672: [FLINK-15817][k8s] Clean up residual resources when failed to deploy a Flink cluster

flinkbot edited a comment on issue #11672: [FLINK-15817][k8s] Clean up residual resources when failed to deploy a Flink cluster URL: https://github.com/apache/flink/pull/11672#issuecomment-610981433 ## CI report: * f1faad82681c9b5c2fbda6c2cda5af3dd207ecdb Travis: [PENDING](https

[GitHub] [flink] flinkbot edited a comment on issue #11672: [FLINK-15817][k8s] Clean up residual resources when failed to deploy a Flink cluster

flinkbot edited a comment on issue #11672: [FLINK-15817][k8s] Clean up residual resources when failed to deploy a Flink cluster URL: https://github.com/apache/flink/pull/11672#issuecomment-610981433 ## CI report: * f1faad82681c9b5c2fbda6c2cda5af3dd207ecdb Travis: [PENDING](https

[jira] [Commented] (FLINK-15656) Support user-specified pod templates

[ https://issues.apache.org/jira/browse/FLINK-15656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17078853#comment-17078853 ] Canbin Zheng commented on FLINK-15656: -- [~ouyangwuli], [~fly_in_gis] The built-in i

[GitHub] [flink] xintongsong commented on issue #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity.

xintongsong commented on issue #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity. URL: https://github.com/apache/flink/pull/11320#issuecomment-611279664 @tillrohrmann I've addressed your comments, except for one about return

[GitHub] [flink] zhengcanbin commented on issue #11672: [FLINK-15817][k8s] Clean up residual resources when failed to deploy a Flink cluster

zhengcanbin commented on issue #11672: [FLINK-15817][k8s] Clean up residual resources when failed to deploy a Flink cluster URL: https://github.com/apache/flink/pull/11672#issuecomment-611276891 @flinkbot run travis This is a

[jira] [Commented] (FLINK-17055) List jobs via bin/flink throws FlinkException indicating no cluster id was specified

[ https://issues.apache.org/jira/browse/FLINK-17055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17078847#comment-17078847 ] Canbin Zheng commented on FLINK-17055: -- Thanks for the explanation [~tison], [~kkl0

[jira] [Closed] (FLINK-17055) List jobs via bin/flink throws FlinkException indicating no cluster id was specified

[ https://issues.apache.org/jira/browse/FLINK-17055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng closed FLINK-17055. Resolution: Not A Problem > List jobs via bin/flink throws FlinkException indicating no cluster id

[jira] [Commented] (FLINK-15170) WebFrontendITCase.testCancelYarn fails on travis

[ https://issues.apache.org/jira/browse/FLINK-15170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17078844#comment-17078844 ] Dian Fu commented on FLINK-15170: - Another instance from master: https://api.travis-ci.o

[jira] [Commented] (FLINK-17059) flink-shaded-hadoop-2-uber:2.8.3-10.0 has invalid pom in Gradle

[ https://issues.apache.org/jira/browse/FLINK-17059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17078842#comment-17078842 ] John Lonergan commented on FLINK-17059: --- Hi what release version is available? Tha

[jira] [Commented] (FLINK-15540) flink-shaded-hadoop-2-uber bundles wrong dependency versions

[ https://issues.apache.org/jira/browse/FLINK-15540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17078839#comment-17078839 ] John Lonergan commented on FLINK-15540: --- Is a working version released? > flink-s

[jira] [Issue Comment Deleted] (FLINK-15540) flink-shaded-hadoop-2-uber bundles wrong dependency versions

[ https://issues.apache.org/jira/browse/FLINK-15540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Lonergan updated FLINK-15540: -- Comment: was deleted (was: Is a working version released?) > flink-shaded-hadoop-2-uber bundl

[jira] [Created] (FLINK-17060) "{flink}" isn't being replaced by the Apache Flink trademark in Stateful Functions docs

Tzu-Li (Gordon) Tai created FLINK-17060: --- Summary: "{flink}" isn't being replaced by the Apache Flink trademark in Stateful Functions docs Key: FLINK-17060 URL: https://issues.apache.org/jira/browse/FLINK-17

[GitHub] [flink] flinkbot edited a comment on issue #11678: [hotfix] [docs] Fix english typo in stream file sinks rolling policy section

flinkbot edited a comment on issue #11678: [hotfix] [docs] Fix english typo in stream file sinks rolling policy section URL: https://github.com/apache/flink/pull/11678#issuecomment-611237489 ## CI report: * 550b062a8da862659e63a7b5cbbe7ca567a9cfcb Travis: [SUCCESS](https://travi

[GitHub] [flink] flinkbot edited a comment on issue #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints

flinkbot edited a comment on issue #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints URL: https://github.com/apache/flink/pull/11515#issuecomment-604128992 ## CI report: * 22e12ad32ac71e45f7c40fd08ad0cc4498664613 UNKNOWN * 72c7b7dd1776d3

[GitHub] [flink] flinkbot edited a comment on issue #11675: [FLINK-16745] Use JobManagerProcessUtils to start JM container and pass JVM memory args

flinkbot edited a comment on issue #11675: [FLINK-16745] Use JobManagerProcessUtils to start JM container and pass JVM memory args URL: https://github.com/apache/flink/pull/11675#issuecomment-6 ## CI report: * 7bbe43688038441aa0592ee4ef2c8f81e8aef4c8 Travis: [SUCCESS](ht

[GitHub] [flink] flinkbot edited a comment on issue #11676: [FLINK-17011][tests] Introduce Builder to AbstractStreamOperatorTestHarness for testing

flinkbot edited a comment on issue #11676: [FLINK-17011][tests] Introduce Builder to AbstractStreamOperatorTestHarness for testing URL: https://github.com/apache/flink/pull/11676#issuecomment-69058 ## CI report: * f9a52c887d310f4175960dc54a710ccdf467836f Travis: [SUCCESS](h

[GitHub] [flink] flinkbot edited a comment on issue #11541: [FLINK-15416][network] add task manager netty client retry mechenism

flinkbot edited a comment on issue #11541: [FLINK-15416][network] add task manager netty client retry mechenism URL: https://github.com/apache/flink/pull/11541#issuecomment-604812212 ## CI report: * b5ef19285000d692d6b1b8b0aa7a37ce35c216f5 UNKNOWN * baf2c55f7bb0b9df7bdef94083c

[GitHub] [flink] flinkbot edited a comment on issue #11677: [1.9][FLINK-15812][runtime] Archive jobs asynchronously

flinkbot edited a comment on issue #11677: [1.9][FLINK-15812][runtime] Archive jobs asynchronously URL: https://github.com/apache/flink/pull/11677#issuecomment-611194258 ## CI report: * 1980340e552912f3ee135f930f6567e457680139 Travis: [SUCCESS](https://travis-ci.com/github/flin

[GitHub] [flink] flinkbot edited a comment on issue #11678: [hotfix] [docs] Fix english typo in stream file sinks rolling policy section

flinkbot edited a comment on issue #11678: [hotfix] [docs] Fix english typo in stream file sinks rolling policy section URL: https://github.com/apache/flink/pull/11678#issuecomment-611237489 ## CI report: * 550b062a8da862659e63a7b5cbbe7ca567a9cfcb Travis: [PENDING](https://travi

[GitHub] [flink] flinkbot edited a comment on issue #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints

flinkbot edited a comment on issue #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints URL: https://github.com/apache/flink/pull/11515#issuecomment-604128992 ## CI report: * 22e12ad32ac71e45f7c40fd08ad0cc4498664613 UNKNOWN * 102a8f1f7c4926

[GitHub] [flink] flinkbot commented on issue #11678: [hotfix] [docs] Fix english typo in stream file sinks rolling policy section

flinkbot commented on issue #11678: [hotfix] [docs] Fix english typo in stream file sinks rolling policy section URL: https://github.com/apache/flink/pull/11678#issuecomment-611237489 ## CI report: * 550b062a8da862659e63a7b5cbbe7ca567a9cfcb UNKNOWN Bot commands Th

[GitHub] [flink] flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero

flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero URL: https://github.com/apache/flink/pull/11351#issuecomment-596351676 ## CI report: * 715889a35cfcc3aaf1b17f39dadaa86f755cc75d UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints

flinkbot edited a comment on issue #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints URL: https://github.com/apache/flink/pull/11515#issuecomment-604128992 ## CI report: * 22e12ad32ac71e45f7c40fd08ad0cc4498664613 UNKNOWN * 102a8f1f7c4926

[GitHub] [flink] flinkbot commented on issue #11678: [hotfix] [docs] Fix english typo in stream file sinks rolling policy section

flinkbot commented on issue #11678: [hotfix] [docs] Fix english typo in stream file sinks rolling policy section URL: https://github.com/apache/flink/pull/11678#issuecomment-611236019 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] ecmarsh opened a new pull request #11678: [hotfix] [docs] Fix english typo in stream file sinks rolling policy section

ecmarsh opened a new pull request #11678: [hotfix] [docs] Fix english typo in stream file sinks rolling policy section URL: https://github.com/apache/flink/pull/11678 This is an automated message from the Apache Git Serv

[GitHub] [flink] flinkbot edited a comment on issue #11541: [FLINK-15416][network] add task manager netty client retry mechenism

flinkbot edited a comment on issue #11541: [FLINK-15416][network] add task manager netty client retry mechenism URL: https://github.com/apache/flink/pull/11541#issuecomment-604812212 ## CI report: * b5ef19285000d692d6b1b8b0aa7a37ce35c216f5 UNKNOWN * baf2c55f7bb0b9df7bdef94083c

[GitHub] [flink] flinkbot edited a comment on issue #11541: [FLINK-15416][network] add task manager netty client retry mechenism

flinkbot edited a comment on issue #11541: [FLINK-15416][network] add task manager netty client retry mechenism URL: https://github.com/apache/flink/pull/11541#issuecomment-604812212 ## CI report: * b5ef19285000d692d6b1b8b0aa7a37ce35c216f5 UNKNOWN * baf2c55f7bb0b9df7bdef94083c

[GitHub] [flink] flinkbot edited a comment on issue #11647: [FLINK-16960][runtime] Add PipelinedRegion interface

flinkbot edited a comment on issue #11647: [FLINK-16960][runtime] Add PipelinedRegion interface URL: https://github.com/apache/flink/pull/11647#issuecomment-609754761 ## CI report: * 883520ef68d44fb7691e692992d03f40d1f1 Travis: [FAILURE](https://travis-ci.com/github/flink-ci

  1   2   3   4   5   6   7   >