[GitHub] [flink] GJL closed pull request #9783: [FLINK-14040][travis] Enable MiniCluster tests based on schedulerNG in Flink cron build

GJL closed pull request #9783: [FLINK-14040][travis] Enable MiniCluster tests based on schedulerNG in Flink cron build URL: https://github.com/apache/flink/pull/9783 This is an automated message from the Apache Git Service.

[jira] [Updated] (FLINK-14040) Enable NG scheduler testing in per-commit tests

[ https://issues.apache.org/jira/browse/FLINK-14040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-14040: - Fix Version/s: 1.10.0 > Enable NG scheduler testing in per-commit tests >

[jira] [Updated] (FLINK-14040) Enable NG scheduler testing in per-commit tests

[ https://issues.apache.org/jira/browse/FLINK-14040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-14040: - Description: Before making {{SchedulerNG}} the default scheduler, we need to guarantee all the

[GitHub] [flink] flinkbot edited a comment on issue #9960: [FLINK-14476] Extend PartitionTracker to support promotions

flinkbot edited a comment on issue #9960: [FLINK-14476] Extend PartitionTracker to support promotions URL: https://github.com/apache/flink/pull/9960#issuecomment-544551169 ## CI report: * 2cf1a8e029da523cdf2df9504f4d6f44da31ceb1 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9920: [FLINK-14389][runtime] Restore task state before restarting tasks in DefaultScheduler

flinkbot edited a comment on issue #9920: [FLINK-14389][runtime] Restore task state before restarting tasks in DefaultScheduler URL: https://github.com/apache/flink/pull/9920#issuecomment-542997479 ## CI report: * c7e058ec893217ef5c8c3cf3ae5e893a7ccf4b8f : SUCCESS

[GitHub] [flink] zhuzhurk opened a new pull request #10007: [FLINK-14060][runtime] Set slot sharing groups according to logical pipelined regions

zhuzhurk opened a new pull request #10007: [FLINK-14060][runtime] Set slot sharing groups according to logical pipelined regions URL: https://github.com/apache/flink/pull/10007 ## What is the purpose of the change This PR is to set vertex slot sharing groups according to logical

[jira] [Updated] (FLINK-14060) Set slot sharing groups according to pipelined regions

[ https://issues.apache.org/jira/browse/FLINK-14060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14060: --- Labels: pull-request-available (was: ) > Set slot sharing groups according to pipelined

[GitHub] [flink] flinkbot commented on issue #10006: [FLINK-14312][runtime] Support building logical pipelined regions from JobGraph

flinkbot commented on issue #10006: [FLINK-14312][runtime] Support building logical pipelined regions from JobGraph URL: https://github.com/apache/flink/pull/10006#issuecomment-546671910 ## CI report: * 0697f19b0cce32ea7e70e0c13abe5a4a53d5 : UNKNOWN Bot commands

[GitHub] [flink] flinkbot edited a comment on issue #10006: [FLINK-14312][runtime] Support building logical pipelined regions from JobGraph

flinkbot edited a comment on issue #10006: [FLINK-14312][runtime] Support building logical pipelined regions from JobGraph URL: https://github.com/apache/flink/pull/10006#issuecomment-546671910 ## CI report: * 0697f19b0cce32ea7e70e0c13abe5a4a53d5 : CANCELED

[GitHub] [flink] flinkbot edited a comment on issue #10007: [FLINK-14060][runtime] Set slot sharing groups according to logical pipelined regions

flinkbot edited a comment on issue #10007: [FLINK-14060][runtime] Set slot sharing groups according to logical pipelined regions URL: https://github.com/apache/flink/pull/10007#issuecomment-546673889 ## CI report: * 2f64299fb74a59f77f14f20bed87191389f58317 : FAILURE

[GitHub] [flink] Myasuka commented on issue #10008: [FLINK-14403] Remove uesless NotifyCheckpointComplete and TriggerCheckpoint

Myasuka commented on issue #10008: [FLINK-14403] Remove uesless NotifyCheckpointComplete and TriggerCheckpoint URL: https://github.com/apache/flink/pull/10008#issuecomment-546718936 CC @tillrohrmann This is an automated

[GitHub] [flink] flinkbot commented on issue #10008: [FLINK-14403] Remove uesless NotifyCheckpointComplete and TriggerCheckpoint

flinkbot commented on issue #10008: [FLINK-14403] Remove uesless NotifyCheckpointComplete and TriggerCheckpoint URL: https://github.com/apache/flink/pull/10008#issuecomment-546719029 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[jira] [Updated] (FLINK-14499) MetricRegistry#getMetricQueryServiceGatewayRpcAddress is Nonnull

[ https://issues.apache.org/jira/browse/FLINK-14499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14499: --- Component/s: Runtime / Metrics > MetricRegistry#getMetricQueryServiceGatewayRpcAddress is

[jira] [Updated] (FLINK-14495) Add documentation for memory control of RocksDB state backend with writebuffer manager

[ https://issues.apache.org/jira/browse/FLINK-14495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14495: --- Component/s: Runtime / State Backends > Add documentation for memory control of RocksDB

[jira] [Created] (FLINK-14536) Make clear the way to aggregate specified cpuCores resources

Zhu Zhu created FLINK-14536: --- Summary: Make clear the way to aggregate specified cpuCores resources Key: FLINK-14536 URL: https://issues.apache.org/jira/browse/FLINK-14536 Project: Flink Issue

[jira] [Commented] (FLINK-14482) Bump up rocksdb version to support WriteBufferManager

[ https://issues.apache.org/jira/browse/FLINK-14482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16960649#comment-16960649 ] Yun Tang commented on FLINK-14482: -- [~trohrmann] Yes, we first plan to upgrade the base RocksDB version

[GitHub] [flink] flinkbot commented on issue #10007: [FLINK-14060][runtime] Set slot sharing groups according to logical pipelined regions

flinkbot commented on issue #10007: [FLINK-14060][runtime] Set slot sharing groups according to logical pipelined regions URL: https://github.com/apache/flink/pull/10007#issuecomment-546672088 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] [flink] flinkbot edited a comment on issue #10006: [FLINK-14312][runtime] Support building logical pipelined regions from JobGraph

flinkbot edited a comment on issue #10006: [FLINK-14312][runtime] Support building logical pipelined regions from JobGraph URL: https://github.com/apache/flink/pull/10006#issuecomment-546671910 ## CI report: * 0697f19b0cce32ea7e70e0c13abe5a4a53d5 : CANCELED

[GitHub] [flink] flinkbot edited a comment on issue #9944: [FLINK-14454] [test-stability] Usages of SavepointSerializers.setFailWhenLegacyStateDetected are never reverted

flinkbot edited a comment on issue #9944: [FLINK-14454] [test-stability] Usages of SavepointSerializers.setFailWhenLegacyStateDetected are never reverted URL: https://github.com/apache/flink/pull/9944#issuecomment-544242701 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #9920: [FLINK-14389][runtime] Restore task state before restarting tasks in DefaultScheduler

flinkbot edited a comment on issue #9920: [FLINK-14389][runtime] Restore task state before restarting tasks in DefaultScheduler URL: https://github.com/apache/flink/pull/9920#issuecomment-542997479 ## CI report: * c7e058ec893217ef5c8c3cf3ae5e893a7ccf4b8f : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9920: [FLINK-14389][runtime] Restore task state before restarting tasks in DefaultScheduler

flinkbot edited a comment on issue #9920: [FLINK-14389][runtime] Restore task state before restarting tasks in DefaultScheduler URL: https://github.com/apache/flink/pull/9920#issuecomment-542997479 ## CI report: * c7e058ec893217ef5c8c3cf3ae5e893a7ccf4b8f : SUCCESS

[GitHub] [flink] flinkbot commented on issue #10008: [FLINK-14403] Remove uesless NotifyCheckpointComplete and TriggerCheckpoint

flinkbot commented on issue #10008: [FLINK-14403] Remove uesless NotifyCheckpointComplete and TriggerCheckpoint URL: https://github.com/apache/flink/pull/10008#issuecomment-546719490 ## CI report: * 4e9fe99659cd1826b676b87a1029453fc46edccb : UNKNOWN Bot commands

[jira] [Updated] (FLINK-14312) Support building logical pipelined regions from JobGraph

[ https://issues.apache.org/jira/browse/FLINK-14312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-14312: Description: Logical pipelined region partitioning is needed by FLINK-14060 to determine JobVertex slot

[GitHub] [flink] buptljy commented on issue #9944: [FLINK-14454] [test-stability] Usages of SavepointSerializers.setFailWhenLegacyStateDetected are never reverted

buptljy commented on issue #9944: [FLINK-14454] [test-stability] Usages of SavepointSerializers.setFailWhenLegacyStateDetected are never reverted URL: https://github.com/apache/flink/pull/9944#issuecomment-546682172 @flinkbot run travis

[jira] [Updated] (FLINK-14536) Make clear the way to aggregate specified cpuCores resources

[ https://issues.apache.org/jira/browse/FLINK-14536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-14536: Description: I'm raising this question because I find {{cpuCores}} in {{ResourceSpec#merge}} are

[GitHub] [flink] flinkbot edited a comment on issue #9960: [FLINK-14476] Extend PartitionTracker to support promotions

flinkbot edited a comment on issue #9960: [FLINK-14476] Extend PartitionTracker to support promotions URL: https://github.com/apache/flink/pull/9960#issuecomment-544551169 ## CI report: * 2cf1a8e029da523cdf2df9504f4d6f44da31ceb1 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9960: [FLINK-14476] Extend PartitionTracker to support promotions

flinkbot edited a comment on issue #9960: [FLINK-14476] Extend PartitionTracker to support promotions URL: https://github.com/apache/flink/pull/9960#issuecomment-544551169 ## CI report: * 2cf1a8e029da523cdf2df9504f4d6f44da31ceb1 : SUCCESS

[GitHub] [flink] zhuzhurk opened a new pull request #10006: [FLINK-14312][runtime] Support building logical pipelined regions from JobGraph

zhuzhurk opened a new pull request #10006: [FLINK-14312][runtime] Support building logical pipelined regions from JobGraph URL: https://github.com/apache/flink/pull/10006 ## What is the purpose of the change Logical pipelined region partitioning is needed by FLINK-14060 to

[jira] [Updated] (FLINK-14312) Support building logical pipelined regions from JobGraph

[ https://issues.apache.org/jira/browse/FLINK-14312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14312: --- Labels: pull-request-available (was: ) > Support building logical pipelined regions from

[GitHub] [flink] flinkbot commented on issue #10006: [FLINK-14312][runtime] Support building logical pipelined regions from JobGraph

flinkbot commented on issue #10006: [FLINK-14312][runtime] Support building logical pipelined regions from JobGraph URL: https://github.com/apache/flink/pull/10006#issuecomment-546671159 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[jira] [Updated] (FLINK-14531) Add Kafka Metrics Reporter

[ https://issues.apache.org/jira/browse/FLINK-14531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14531: --- Component/s: Runtime / Metrics > Add Kafka Metrics Reporter >

[GitHub] [flink] zentol commented on issue #9960: [FLINK-14476] Extend PartitionTracker to support promotions

zentol commented on issue #9960: [FLINK-14476] Extend PartitionTracker to support promotions URL: https://github.com/apache/flink/pull/9960#issuecomment-546687353 @tillrohrmann the PR is ready for a second round This is an

[GitHub] [flink] flinkbot edited a comment on issue #9944: [FLINK-14454] [test-stability] Usages of SavepointSerializers.setFailWhenLegacyStateDetected are never reverted

flinkbot edited a comment on issue #9944: [FLINK-14454] [test-stability] Usages of SavepointSerializers.setFailWhenLegacyStateDetected are never reverted URL: https://github.com/apache/flink/pull/9944#issuecomment-544242701 ## CI report: *

[jira] [Commented] (FLINK-12526) Remove STATE_UPDATER in ExecutionGraph

[ https://issues.apache.org/jira/browse/FLINK-12526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16960531#comment-16960531 ] Gary Yao commented on FLINK-12526: -- I think we won't change the execution graph significantly in the

[GitHub] [flink] GJL commented on issue #9783: [FLINK-14040][travis] Enable MiniCluster tests based on schedulerNG in Flink cron build

GJL commented on issue #9783: [FLINK-14040][travis] Enable MiniCluster tests based on schedulerNG in Flink cron build URL: https://github.com/apache/flink/pull/9783#issuecomment-546672499 Merging This is an automated message

[GitHub] [flink] flinkbot commented on issue #10007: [FLINK-14060][runtime] Set slot sharing groups according to logical pipelined regions

flinkbot commented on issue #10007: [FLINK-14060][runtime] Set slot sharing groups according to logical pipelined regions URL: https://github.com/apache/flink/pull/10007#issuecomment-546673889 ## CI report: * 2f64299fb74a59f77f14f20bed87191389f58317 : UNKNOWN Bot

[GitHub] [flink] flinkbot edited a comment on issue #10006: [FLINK-14312][runtime] Support building logical pipelined regions from JobGraph

flinkbot edited a comment on issue #10006: [FLINK-14312][runtime] Support building logical pipelined regions from JobGraph URL: https://github.com/apache/flink/pull/10006#issuecomment-546671910 ## CI report: * 0697f19b0cce32ea7e70e0c13abe5a4a53d5 : PENDING

[jira] [Commented] (FLINK-12526) Remove STATE_UPDATER in ExecutionGraph

[ https://issues.apache.org/jira/browse/FLINK-12526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16960538#comment-16960538 ] Zhu Zhu commented on FLINK-12526: - Agreed with Gary. I think it's fine start this work. [~yanghua] >

[jira] [Updated] (FLINK-14403) Remove uesless NotifyCheckpointComplete and TriggerCheckpoint

[ https://issues.apache.org/jira/browse/FLINK-14403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14403: --- Component/s: Runtime / Task > Remove uesless NotifyCheckpointComplete and TriggerCheckpoint

[jira] [Updated] (FLINK-14328) JobCluster cannot reach TaskManager in K8s

[ https://issues.apache.org/jira/browse/FLINK-14328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14328: --- Component/s: Deployment / Kubernetes > JobCluster cannot reach TaskManager in K8s >

[jira] [Updated] (FLINK-14460) Active Kubernetes integration phase2 - Production Optimization

[ https://issues.apache.org/jira/browse/FLINK-14460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14460: --- Component/s: Deployment / Kubernetes > Active Kubernetes integration phase2 - Production

[jira] [Updated] (FLINK-14463) Merge Handover in flink-connector-kafka and flink-connector-kafka-0.9

[ https://issues.apache.org/jira/browse/FLINK-14463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14463: --- Component/s: Connectors / Kafka > Merge Handover in flink-connector-kafka and

[GitHub] [flink] flinkbot edited a comment on issue #9960: [FLINK-14476] Extend PartitionTracker to support promotions

flinkbot edited a comment on issue #9960: [FLINK-14476] Extend PartitionTracker to support promotions URL: https://github.com/apache/flink/pull/9960#issuecomment-544551169 ## CI report: * 2cf1a8e029da523cdf2df9504f4d6f44da31ceb1 : SUCCESS

[jira] [Closed] (FLINK-14040) Enable NG scheduler testing in per-commit tests

[ https://issues.apache.org/jira/browse/FLINK-14040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao closed FLINK-14040. Resolution: Fixed 1.10: b1b4e00c158a9e3e7bd855e82075308c1279097b > Enable NG scheduler testing in

[GitHub] [flink] walterddr commented on a change in pull request #9733: [FLINK-14154][ml] Add the class for multivariate Gaussian Distribution.

walterddr commented on a change in pull request #9733: [FLINK-14154][ml] Add the class for multivariate Gaussian Distribution. URL: https://github.com/apache/flink/pull/9733#discussion_r339354650 ## File path:

[GitHub] [flink] walterddr commented on a change in pull request #9733: [FLINK-14154][ml] Add the class for multivariate Gaussian Distribution.

walterddr commented on a change in pull request #9733: [FLINK-14154][ml] Add the class for multivariate Gaussian Distribution. URL: https://github.com/apache/flink/pull/9733#discussion_r339354617 ## File path:

[GitHub] [flink] walterddr commented on a change in pull request #9733: [FLINK-14154][ml] Add the class for multivariate Gaussian Distribution.

walterddr commented on a change in pull request #9733: [FLINK-14154][ml] Add the class for multivariate Gaussian Distribution. URL: https://github.com/apache/flink/pull/9733#discussion_r339354266 ## File path:

[GitHub] [flink] walterddr commented on a change in pull request #9733: [FLINK-14154][ml] Add the class for multivariate Gaussian Distribution.

walterddr commented on a change in pull request #9733: [FLINK-14154][ml] Add the class for multivariate Gaussian Distribution. URL: https://github.com/apache/flink/pull/9733#discussion_r339354278 ## File path:

[GitHub] [flink] walterddr commented on a change in pull request #9733: [FLINK-14154][ml] Add the class for multivariate Gaussian Distribution.

walterddr commented on a change in pull request #9733: [FLINK-14154][ml] Add the class for multivariate Gaussian Distribution. URL: https://github.com/apache/flink/pull/9733#discussion_r339354298 ## File path:

[jira] [Updated] (FLINK-14403) Remove uesless NotifyCheckpointComplete and TriggerCheckpoint

[ https://issues.apache.org/jira/browse/FLINK-14403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14403: --- Labels: pull-request-available (was: ) > Remove uesless NotifyCheckpointComplete and

[GitHub] [flink] Myasuka opened a new pull request #10008: [FLINK-14403] Remove uesless NotifyCheckpointComplete and TriggerCheckpoint

Myasuka opened a new pull request #10008: [FLINK-14403] Remove uesless NotifyCheckpointComplete and TriggerCheckpoint URL: https://github.com/apache/flink/pull/10008 ## What is the purpose of the change After FLINK-12322 fixed, we have removed legacy ActorTaskManagerGateway and the

[GitHub] [flink] wuchong edited a comment on issue #10001: [FLINK-14535][table-planner-blink] Fix distinct key type for DecimalT…

wuchong edited a comment on issue #10001: [FLINK-14535][table-planner-blink] Fix distinct key type for DecimalT… URL: https://github.com/apache/flink/pull/10001#issuecomment-546767439 Hi @docete , thanks for the contribution. The change looks good to me. I think we can improve the

[GitHub] [flink] wuchong commented on issue #10001: [FLINK-14535][table-planner-blink] Fix distinct key type for DecimalT…

wuchong commented on issue #10001: [FLINK-14535][table-planner-blink] Fix distinct key type for DecimalT… URL: https://github.com/apache/flink/pull/10001#issuecomment-546767439 Hi @docete , thanks for the contribution. The change looks good to me. I think we can improve the tests a bit

[GitHub] [flink] zhuzhurk commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever

zhuzhurk commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever URL: https://github.com/apache/flink/pull/9950#discussion_r339385051 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9915: [FLINK-14415][table-common] ValueLiteralExpression#equals should take array value into account

flinkbot edited a comment on issue #9915: [FLINK-14415][table-common] ValueLiteralExpression#equals should take array value into account URL: https://github.com/apache/flink/pull/9915#issuecomment-542752172 ## CI report: * d6f66852e76bac070b37e7e9c7365423e5b66853 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #10001: [FLINK-14535][table-planner-blink] Fix distinct key type for DecimalT…

flinkbot edited a comment on issue #10001: [FLINK-14535][table-planner-blink] Fix distinct key type for DecimalT… URL: https://github.com/apache/flink/pull/10001#issuecomment-546558980 ## CI report: * 74748e2c09f1b2b0b9bfb3c1850cd71696d30df8 : FAILURE

[GitHub] [flink] KurtYoung commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects

KurtYoung commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects URL: https://github.com/apache/flink/pull/9971#discussion_r339394157 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10007: [FLINK-14060][runtime] Set slot sharing groups according to logical pipelined regions

flinkbot edited a comment on issue #10007: [FLINK-14060][runtime] Set slot sharing groups according to logical pipelined regions URL: https://github.com/apache/flink/pull/10007#issuecomment-546673889 ## CI report: * 2f64299fb74a59f77f14f20bed87191389f58317 : FAILURE

[jira] [Comment Edited] (FLINK-10435) Client sporadically hangs after Ctrl + C

[ https://issues.apache.org/jira/browse/FLINK-10435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16960738#comment-16960738 ] Yang Wang edited comment on FLINK-10435 at 10/28/19 4:14 AM: - I have tested

[GitHub] [flink] wangyang0918 opened a new pull request #10010: [FLINK-10435][yarn]Client sporadically hangs after Ctrl + C

wangyang0918 opened a new pull request #10010: [FLINK-10435][yarn]Client sporadically hangs after Ctrl + C URL: https://github.com/apache/flink/pull/10010 ## What is the purpose of the change This PR is to fix the bug when deploying on yarn in attach mode that flink client

[jira] [Updated] (FLINK-10435) Client sporadically hangs after Ctrl + C

[ https://issues.apache.org/jira/browse/FLINK-10435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10435: --- Labels: pull-request-available (was: ) > Client sporadically hangs after Ctrl + C >

[jira] [Updated] (FLINK-14538) Metrics of Status.JVM.Memory.NonHeap.Max is always -1

[ https://issues.apache.org/jira/browse/FLINK-14538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuwen Zhou updated FLINK-14538: Description: I'm collecting JobManager and TaskManager status metrics to DataDog. While all

[jira] [Updated] (FLINK-14538) Metrics of Status.JVM.Memory.NonHeap.Max is always -1

[ https://issues.apache.org/jira/browse/FLINK-14538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuwen Zhou updated FLINK-14538: Summary: Metrics of Status.JVM.Memory.NonHeap.Max is always -1 (was: Metrics of TaskManager

[jira] [Updated] (FLINK-14538) Metrics of TaskManager Status.JVM.Memory.NonHeap.Max is always -1

[ https://issues.apache.org/jira/browse/FLINK-14538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuwen Zhou updated FLINK-14538: Description: I'm collecting TaskManager status metrics to DataDog. While all metrics of

[GitHub] [flink] flinkbot commented on issue #10010: [FLINK-10435][yarn]Client sporadically hangs after Ctrl + C

flinkbot commented on issue #10010: [FLINK-10435][yarn]Client sporadically hangs after Ctrl + C URL: https://github.com/apache/flink/pull/10010#issuecomment-546787757 ## CI report: * 4b0f9efdc169d3b6375d469cd3512e87e98f0f19 : UNKNOWN Bot commands The @flinkbot

[GitHub] [flink] flinkbot edited a comment on issue #10008: [FLINK-14403] Remove uesless NotifyCheckpointComplete and TriggerCheckpoint

flinkbot edited a comment on issue #10008: [FLINK-14403] Remove uesless NotifyCheckpointComplete and TriggerCheckpoint URL: https://github.com/apache/flink/pull/10008#issuecomment-546719490 ## CI report: * 4e9fe99659cd1826b676b87a1029453fc46edccb : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #10009: [FLINK-14304] WIP -- Avoid task starvation with mailbox

flinkbot edited a comment on issue #10009: [FLINK-14304] WIP -- Avoid task starvation with mailbox URL: https://github.com/apache/flink/pull/10009#issuecomment-546724255 ## CI report: * 2b39236d76b1c56d240f2476c535568f0614c577 : CANCELED

[jira] [Assigned] (FLINK-14535) Fix distinct key type for DecimalType in DistinctInfo

[ https://issues.apache.org/jira/browse/FLINK-14535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-14535: --- Assignee: Zhenghua Gao > Fix distinct key type for DecimalType in DistinctInfo >

[GitHub] [flink] sunhaibotb edited a comment on issue #9854: [FLINK-14230][task] Change the endInput call of the downstream operator to after the upstream operator closes

sunhaibotb edited a comment on issue #9854: [FLINK-14230][task] Change the endInput call of the downstream operator to after the upstream operator closes URL: https://github.com/apache/flink/pull/9854#issuecomment-546785241 I've addressed the lastest comments and added some detailed

[GitHub] [flink] zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#discussion_r339398713 ## File path:

[GitHub] [flink] Henvealf commented on a change in pull request #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese

Henvealf commented on a change in pull request #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese URL: https://github.com/apache/flink/pull/9805#discussion_r339399783 ## File path: docs/dev/stream/state/checkpointing.zh.md ## @@ -173,30

[GitHub] [flink] flinkbot edited a comment on issue #10010: [FLINK-10435][yarn]Client sporadically hangs after Ctrl + C

flinkbot edited a comment on issue #10010: [FLINK-10435][yarn]Client sporadically hangs after Ctrl + C URL: https://github.com/apache/flink/pull/10010#issuecomment-546787757 ## CI report: * 4b0f9efdc169d3b6375d469cd3512e87e98f0f19 : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #10007: [FLINK-14060][runtime] Set slot sharing groups according to logical pipelined regions

flinkbot edited a comment on issue #10007: [FLINK-14060][runtime] Set slot sharing groups according to logical pipelined regions URL: https://github.com/apache/flink/pull/10007#issuecomment-546673889 ## CI report: * 2f64299fb74a59f77f14f20bed87191389f58317 : FAILURE

[GitHub] [flink] JingsongLi commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit

JingsongLi commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit URL: https://github.com/apache/flink/pull/9876#discussion_r339405733 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit

JingsongLi commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit URL: https://github.com/apache/flink/pull/9876#discussion_r339405733 ## File path:

[GitHub] [flink] flinkbot commented on issue #10009: [FLINK-14304] WIP -- Avoid task starvation with mailbox

flinkbot commented on issue #10009: [FLINK-14304] WIP -- Avoid task starvation with mailbox URL: https://github.com/apache/flink/pull/10009#issuecomment-546723463 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[GitHub] [flink] flinkbot edited a comment on issue #10009: [FLINK-14304] WIP -- Avoid task starvation with mailbox

flinkbot edited a comment on issue #10009: [FLINK-14304] WIP -- Avoid task starvation with mailbox URL: https://github.com/apache/flink/pull/10009#issuecomment-546724255 ## CI report: * 2b39236d76b1c56d240f2476c535568f0614c577 : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #10008: [FLINK-14403] Remove uesless NotifyCheckpointComplete and TriggerCheckpoint

flinkbot edited a comment on issue #10008: [FLINK-14403] Remove uesless NotifyCheckpointComplete and TriggerCheckpoint URL: https://github.com/apache/flink/pull/10008#issuecomment-546719490 ## CI report: * 4e9fe99659cd1826b676b87a1029453fc46edccb : SUCCESS

[GitHub] [flink] lirui-apache commented on issue #9927: [FLINK-14397][hive] Failed to run Hive UDTF with array arguments

lirui-apache commented on issue #9927: [FLINK-14397][hive] Failed to run Hive UDTF with array arguments URL: https://github.com/apache/flink/pull/9927#issuecomment-546766553 @bowenli86 Has this one been merged? This is an

[GitHub] [flink] flinkbot edited a comment on issue #9796: [FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only when dynamic partition insert

flinkbot edited a comment on issue #9796: [FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only when dynamic partition insert URL: https://github.com/apache/flink/pull/9796#issuecomment-536253430 ## CI report: * 3b84408bb5ee764b1a64103b1f4df3e0ceacaba7

[GitHub] [flink] flinkbot edited a comment on issue #9804: [FLINK-14239] Fix the max watermark in StreamSource may arrive the downstream operator early

flinkbot edited a comment on issue #9804: [FLINK-14239] Fix the max watermark in StreamSource may arrive the downstream operator early URL: https://github.com/apache/flink/pull/9804#issuecomment-536287116 ## CI report: * cb5b4da4d8b5d877e296dd84095a328208263c15 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9796: [FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only when dynamic partition insert

flinkbot edited a comment on issue #9796: [FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only when dynamic partition insert URL: https://github.com/apache/flink/pull/9796#issuecomment-536253430 ## CI report: * 3b84408bb5ee764b1a64103b1f4df3e0ceacaba7

[GitHub] [flink] flinkbot edited a comment on issue #9796: [FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only when dynamic partition insert

flinkbot edited a comment on issue #9796: [FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only when dynamic partition insert URL: https://github.com/apache/flink/pull/9796#issuecomment-536253430 ## CI report: * 3b84408bb5ee764b1a64103b1f4df3e0ceacaba7

[GitHub] [flink] zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#discussion_r339397163 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10007: [FLINK-14060][runtime] Set slot sharing groups according to logical pipelined regions

flinkbot edited a comment on issue #10007: [FLINK-14060][runtime] Set slot sharing groups according to logical pipelined regions URL: https://github.com/apache/flink/pull/10007#issuecomment-546673889 ## CI report: * 2f64299fb74a59f77f14f20bed87191389f58317 : FAILURE

[jira] [Commented] (FLINK-14264) Expose CheckpointBackend in checkpoint config RestAPI

[ https://issues.apache.org/jira/browse/FLINK-14264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16960752#comment-16960752 ] Congxian Qiu(klion26) commented on FLINK-14264: --- Kindly ping [~aljoscha]. If this is

[GitHub] [flink] flinkbot edited a comment on issue #9854: [FLINK-14230][task] Change the endInput call of the downstream operator to after the upstream operator closes

flinkbot edited a comment on issue #9854: [FLINK-14230][task] Change the endInput call of the downstream operator to after the upstream operator closes URL: https://github.com/apache/flink/pull/9854#issuecomment-539497852 ## CI report: * 9adcb150ed88bfa077642f6f590ec4ae9183baf5

[GitHub] [flink] flinkbot commented on issue #10009: [FLINK-14304] WIP -- Avoid task starvation with mailbox

flinkbot commented on issue #10009: [FLINK-14304] WIP -- Avoid task starvation with mailbox URL: https://github.com/apache/flink/pull/10009#issuecomment-546724255 ## CI report: * 2b39236d76b1c56d240f2476c535568f0614c577 : UNKNOWN Bot commands The @flinkbot bot

[GitHub] [flink] flinkbot edited a comment on issue #10001: [FLINK-14535][table-planner-blink] Fix distinct key type for DecimalT…

flinkbot edited a comment on issue #10001: [FLINK-14535][table-planner-blink] Fix distinct key type for DecimalT… URL: https://github.com/apache/flink/pull/10001#issuecomment-546558980 ## CI report: * 74748e2c09f1b2b0b9bfb3c1850cd71696d30df8 : FAILURE

[GitHub] [flink] wuchong commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit

wuchong commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit URL: https://github.com/apache/flink/pull/9876#discussion_r339395859 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit

wuchong commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit URL: https://github.com/apache/flink/pull/9876#discussion_r339389965 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit

wuchong commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit URL: https://github.com/apache/flink/pull/9876#discussion_r339392752 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects

JingsongLi commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects URL: https://github.com/apache/flink/pull/9971#discussion_r339395831 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects

JingsongLi commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects URL: https://github.com/apache/flink/pull/9971#discussion_r339393920 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects

JingsongLi commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects URL: https://github.com/apache/flink/pull/9971#discussion_r339392415 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects

JingsongLi commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects URL: https://github.com/apache/flink/pull/9971#discussion_r339392857 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects

JingsongLi commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects URL: https://github.com/apache/flink/pull/9971#discussion_r339393982 ## File path:

[GitHub] [flink] KurtYoung commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects

KurtYoung commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects URL: https://github.com/apache/flink/pull/9971#discussion_r339396074 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit

wuchong commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit URL: https://github.com/apache/flink/pull/9876#discussion_r339395422 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit

wuchong commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit URL: https://github.com/apache/flink/pull/9876#discussion_r339393494 ## File path:

  1   2   >