[jira] [Comment Edited] (FLINK-9043) Introduce a friendly way to resume the job from externalized checkpoints automatically

[ https://issues.apache.org/jira/browse/FLINK-9043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16596318#comment-16596318 ] godfrey johnson edited comment on FLINK-9043 at 8/30/18 1:54 AM: --

[jira] [Comment Edited] (FLINK-9043) Introduce a friendly way to resume the job from externalized checkpoints automatically

[ https://issues.apache.org/jira/browse/FLINK-9043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16596318#comment-16596318 ] godfrey johnson edited comment on FLINK-9043 at 8/29/18 1:29 PM: --

[jira] [Comment Edited] (FLINK-9043) Introduce a friendly way to resume the job from externalized checkpoints automatically

[ https://issues.apache.org/jira/browse/FLINK-9043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16596318#comment-16596318 ] godfrey johnson edited comment on FLINK-9043 at 8/29/18 1:28 PM: --

[jira] [Commented] (FLINK-9043) Introduce a friendly way to resume the job from externalized checkpoints automatically

[ https://issues.apache.org/jira/browse/FLINK-9043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16596318#comment-16596318 ] godfrey johnson commented on FLINK-9043: [https://github.com/GodfreyJohnson/flink

[jira] [Closed] (FLINK-9906) Flink Job not running with no resource

[ https://issues.apache.org/jira/browse/FLINK-9906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey johnson closed FLINK-9906. -- Resolution: Fixed Fix Version/s: 1.6.0 > Flink Job not running with no resource > --

[jira] [Commented] (FLINK-9906) Flink Job not running with no resource

[ https://issues.apache.org/jira/browse/FLINK-9906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16554033#comment-16554033 ] godfrey johnson commented on FLINK-9906: https://issues.apache.org/jira/browse/FL

[jira] [Commented] (FLINK-9906) Flink Job not running with no resource

[ https://issues.apache.org/jira/browse/FLINK-9906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16552246#comment-16552246 ] godfrey johnson commented on FLINK-9906: [^taskmanager.log] Actually, containers

[jira] [Comment Edited] (FLINK-9906) Flink Job not running with no resource

[ https://issues.apache.org/jira/browse/FLINK-9906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16552246#comment-16552246 ] godfrey johnson edited comment on FLINK-9906 at 7/23/18 3:31 AM: --

[jira] [Updated] (FLINK-9906) Flink Job not running with no resource

[ https://issues.apache.org/jira/browse/FLINK-9906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey johnson updated FLINK-9906: --- Attachment: taskmanager.log > Flink Job not running with no resource > --

[jira] [Created] (FLINK-9906) Flink Job not running with no resource

godfrey johnson created FLINK-9906: -- Summary: Flink Job not running with no resource Key: FLINK-9906 URL: https://issues.apache.org/jira/browse/FLINK-9906 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-9652) Metrics for upstream and downstream

godfrey johnson created FLINK-9652: -- Summary: Metrics for upstream and downstream Key: FLINK-9652 URL: https://issues.apache.org/jira/browse/FLINK-9652 Project: Flink Issue Type: Task

[jira] [Commented] (FLINK-9043) Introduce a friendly way to resume the job from externalized checkpoints automatically

[ https://issues.apache.org/jira/browse/FLINK-9043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16475149#comment-16475149 ] godfrey johnson commented on FLINK-9043: [~sihuazhou] Thanks for your commits.  

[jira] [Commented] (FLINK-9175) Flink CEP with Checkpointing alway failed

[ https://issues.apache.org/jira/browse/FLINK-9175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16449172#comment-16449172 ] godfrey johnson commented on FLINK-9175: [~kkl0u] [~sihuazhou][^CEPCal.java] Th

[jira] [Updated] (FLINK-9175) Flink CEP with Checkpointing alway failed

[ https://issues.apache.org/jira/browse/FLINK-9175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey johnson updated FLINK-9175: --- Attachment: CEPCal.java > Flink CEP with Checkpointing alway failed >

[jira] [Commented] (FLINK-9175) Flink CEP with Checkpointing alway failed

[ https://issues.apache.org/jira/browse/FLINK-9175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16442101#comment-16442101 ] godfrey johnson commented on FLINK-9175: [~kkl0u] I changed to Flink 1.4.2 with in

[jira] [Updated] (FLINK-9175) Flink CEP with Checkpointing alway failed

[ https://issues.apache.org/jira/browse/FLINK-9175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey johnson updated FLINK-9175: --- Attachment: (was: jobmanager.log) > Flink CEP with Checkpointing alway failed > --

[jira] [Updated] (FLINK-9175) Flink CEP with Checkpointing alway failed

[ https://issues.apache.org/jira/browse/FLINK-9175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey johnson updated FLINK-9175: --- Attachment: jobmanager.log checkpoint failed.png taskmanager.lo

[jira] [Updated] (FLINK-9175) Flink CEP with Checkpointing alway failed

[ https://issues.apache.org/jira/browse/FLINK-9175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey johnson updated FLINK-9175: --- Attachment: (was: taskmanager.log) > Flink CEP with Checkpointing alway failed > -

[jira] [Updated] (FLINK-9175) Flink CEP with Checkpointing alway failed

[ https://issues.apache.org/jira/browse/FLINK-9175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey johnson updated FLINK-9175: --- Environment: * Checkpoint Interval: 1min * Checkpoint Timeout: 2min * Checkpoint Pause: 5s

[jira] [Created] (FLINK-9175) Flink CEP with Checkpointing alway failed

godfrey johnson created FLINK-9175: -- Summary: Flink CEP with Checkpointing alway failed Key: FLINK-9175 URL: https://issues.apache.org/jira/browse/FLINK-9175 Project: Flink Issue Type: Impro

[jira] [Commented] (FLINK-9043) Flink recover from checkpoint like Spark Streaming

[ https://issues.apache.org/jira/browse/FLINK-9043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16409219#comment-16409219 ] godfrey johnson commented on FLINK-9043: [~StephanEwen] [~aljoscha], bin/flink run

[jira] [Created] (FLINK-9043) Flink recover from checkpoint like Spark Streaming

godfrey johnson created FLINK-9043: -- Summary: Flink recover from checkpoint like Spark Streaming Key: FLINK-9043 URL: https://issues.apache.org/jira/browse/FLINK-9043 Project: Flink Issue T

[jira] [Commented] (FLINK-8895) Job failed when one kafka broker shutdown

[ https://issues.apache.org/jira/browse/FLINK-8895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16393973#comment-16393973 ] godfrey johnson commented on FLINK-8895: [~StephanEwen] After the partition leader

[jira] [Commented] (FLINK-8895) Job failed when one kafka broker shutdown

[ https://issues.apache.org/jira/browse/FLINK-8895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16391079#comment-16391079 ] godfrey johnson commented on FLINK-8895: [~StephanEwen] It's a good way to add Soc

[jira] [Created] (FLINK-8895) Job failed when one kafka broker shutdown

godfrey johnson created FLINK-8895: -- Summary: Job failed when one kafka broker shutdown Key: FLINK-8895 URL: https://issues.apache.org/jira/browse/FLINK-8895 Project: Flink Issue Type: Bug