[jira] [Commented] (FLINK-10129) Flink job IDs are not getting deleted automatically from zookeeper metadata after canceling flink job in flink HA cluster

2018-08-13 Thread Keshav Lodhi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578019#comment-16578019 ] Keshav Lodhi commented on FLINK-10129: -- Hi [~srichter], We are using 1.5.1 flink version... >

[jira] [Created] (FLINK-10130) How to define two hdfs name-node IPs in flink-conf.yaml file

2018-08-13 Thread Keshav Lodhi (JIRA)
Keshav Lodhi created FLINK-10130: Summary: How to define two hdfs name-node IPs in flink-conf.yaml file Key: FLINK-10130 URL: https://issues.apache.org/jira/browse/FLINK-10130 Project: Flink

[jira] [Created] (FLINK-10129) Flink job IDs are not getting deleted automatically from zookeeper metadata after canceling flink job in flink HA cluster

2018-08-13 Thread Keshav Lodhi (JIRA)
Keshav Lodhi created FLINK-10129: Summary: Flink job IDs are not getting deleted automatically from zookeeper metadata after canceling flink job in flink HA cluster Key: FLINK-10129 URL:

[jira] [Commented] (FLINK-10018) Want to have stop command with checkpointing

2018-08-13 Thread Keshav Lodhi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577875#comment-16577875 ] Keshav Lodhi commented on FLINK-10018: -- My scenarios are: * I have implemented *StoppableFunction*

[jira] [Updated] (FLINK-10018) Want to have stop command with checkpointing

2018-08-13 Thread Keshav Lodhi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Keshav Lodhi updated FLINK-10018: - Attachment: Flink stop command.png > Want to have stop command with checkpointing >

[jira] [Created] (FLINK-10018) Want to have stop command with checkpointing

2018-08-01 Thread Keshav Lodhi (JIRA)
Keshav Lodhi created FLINK-10018: Summary: Want to have stop command with checkpointing Key: FLINK-10018 URL: https://issues.apache.org/jira/browse/FLINK-10018 Project: Flink Issue Type: