[jira] [Commented] (FLINK-11835) ZooKeeperLeaderElectionITCase.testJobExecutionOnClusterWithLeaderChange failed

[ https://issues.apache.org/jira/browse/FLINK-11835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16972997#comment-16972997 ] chunpinghe commented on FLINK-11835: {{As JobManagerRunner::closeAsync}} runs asynch

[jira] [Updated] (FLINK-11929) remove useless transientBlobCache in ClusterEntrypoint

[ https://issues.apache.org/jira/browse/FLINK-11929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chunpinghe updated FLINK-11929: --- Component/s: Runtime / Coordination > remove useless transientBlobCache in ClusterEntrypoint > -

[jira] [Created] (FLINK-11929) remove useless transientBlobCache in ClusterEntrypoint

chunpinghe created FLINK-11929: -- Summary: remove useless transientBlobCache in ClusterEntrypoint Key: FLINK-11929 URL: https://issues.apache.org/jira/browse/FLINK-11929 Project: Flink Issue Type

[jira] [Updated] (FLINK-11929) remove useless transientBlobCache in ClusterEntrypoint

[ https://issues.apache.org/jira/browse/FLINK-11929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chunpinghe updated FLINK-11929: --- External issue ID: FLINK-10411 > remove useless transientBlobCache in ClusterEntrypoint > --

[jira] [Updated] (FLINK-11929) remove useless transientBlobCache in ClusterEntrypoint

[ https://issues.apache.org/jira/browse/FLINK-11929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chunpinghe updated FLINK-11929: --- Description: the transientBlobCache in ClusterEntrypoint is initialized using commonRpcService's Ad

[jira] [Updated] (FLINK-11929) remove useless transientBlobCache in ClusterEntrypoint

[ https://issues.apache.org/jira/browse/FLINK-11929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chunpinghe updated FLINK-11929: --- External issue ID: (was: FLINK-10411) > remove useless transientBlobCache in ClusterEntrypoint > -

[jira] [Updated] (FLINK-11897) ExecutionGraphSuspendTest.testSuspendedOutOfRunning failed

[ https://issues.apache.org/jira/browse/FLINK-11897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chunpinghe updated FLINK-11897: --- Component/s: (was: Runtime / Operators) Runtime / Coordination > ExecutionGraph

[jira] [Updated] (FLINK-11897) ExecutionGraphSuspendTest.testSuspendedOutOfRunning failed

[ https://issues.apache.org/jira/browse/FLINK-11897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chunpinghe updated FLINK-11897: --- Labels: test-stability (was: ) > ExecutionGraphSuspendTest.testSuspendedOutOfRunning failed >

[jira] [Created] (FLINK-11897) ExecutionGraphSuspendTest.testSuspendedOutOfRunning failed

chunpinghe created FLINK-11897: -- Summary: ExecutionGraphSuspendTest.testSuspendedOutOfRunning failed Key: FLINK-11897 URL: https://issues.apache.org/jira/browse/FLINK-11897 Project: Flink Issu

[jira] [Updated] (FLINK-11886) update the output of cluster management script in jobmanager_high_availability doc

[ https://issues.apache.org/jira/browse/FLINK-11886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chunpinghe updated FLINK-11886: --- Attachment: ha_doc_updated.png > update the output of cluster management script in > jobmanager_hig

[jira] [Updated] (FLINK-11886) update the output of cluster management script in jobmanager_high_availability doc

[ https://issues.apache.org/jira/browse/FLINK-11886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chunpinghe updated FLINK-11886: --- Attachment: ha_doc.png > update the output of cluster management script in > jobmanager_high_availa

[jira] [Updated] (FLINK-11886) update the output of cluster management script in jobmanager_high_availability doc

[ https://issues.apache.org/jira/browse/FLINK-11886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chunpinghe updated FLINK-11886: --- Attachment: (was: jira_cluster.sh.png) > update the output of cluster management script in > jo

[jira] [Created] (FLINK-11886) update the output of cluster management script in jobmanager_high_availability doc

chunpinghe created FLINK-11886: -- Summary: update the output of cluster management script in jobmanager_high_availability doc Key: FLINK-11886 URL: https://issues.apache.org/jira/browse/FLINK-11886 Projec

[jira] [Commented] (FLINK-11835) ZooKeeperLeaderElectionITCase#testJobExecutionOnClusterWithLeaderChange failed

[ https://issues.apache.org/jira/browse/FLINK-11835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16790135#comment-16790135 ] chunpinghe commented on FLINK-11835: i can't reproduce this bug. > ZooKeeperLeaderE

[jira] [Issue Comment Deleted] (FLINK-11835) ZooKeeperLeaderElectionITCase#testJobExecutionOnClusterWithLeaderChange failed

[ https://issues.apache.org/jira/browse/FLINK-11835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chunpinghe updated FLINK-11835: --- Comment: was deleted (was: is it possible that the recoveryOperation hasn't  finished  which causes

[jira] [Comment Edited] (FLINK-11835) ZooKeeperLeaderElectionITCase#testJobExecutionOnClusterWithLeaderChange failed

[ https://issues.apache.org/jira/browse/FLINK-11835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16789411#comment-16789411 ] chunpinghe edited comment on FLINK-11835 at 3/12/19 1:14 AM: -

[jira] [Commented] (FLINK-11835) ZooKeeperLeaderElectionITCase#testJobExecutionOnClusterWithLeaderChange failed

[ https://issues.apache.org/jira/browse/FLINK-11835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16789411#comment-16789411 ] chunpinghe commented on FLINK-11835: is it possible that the recoveryOperation wasn'

[jira] [Issue Comment Deleted] (FLINK-10884) Flink on yarn TM container will be killed by nodemanager because of the exceeded physical memory.

[ https://issues.apache.org/jira/browse/FLINK-10884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chunpinghe updated FLINK-10884: --- Comment: was deleted (was: what's your solution? yarn will check the physical memory used by contai

[jira] [Commented] (FLINK-11852) Improve Processing function example

[ https://issues.apache.org/jira/browse/FLINK-11852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16786624#comment-16786624 ] chunpinghe commented on FLINK-11852: you are right,it's meaningful! > Improve Proce

[jira] [Commented] (FLINK-10884) Flink on yarn TM container will be killed by nodemanager because of the exceeded physical memory.

[ https://issues.apache.org/jira/browse/FLINK-10884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16687577#comment-16687577 ] chunpinghe commented on FLINK-10884: what's your solution? yarn will check the phys