[jira] [Assigned] (FLINK-4540) Detached job execution may prevent cluster shutdown

[ https://issues.apache.org/jira/browse/FLINK-4540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Maier reassigned FLINK-4540: -- Assignee: Roman Maier > Detached job execution may prevent cluster shutdown >

[jira] [Assigned] (FLINK-5390) input should be closed in finally block in YarnFlinkApplicationMasterRunner#loadJobGraph()

[ https://issues.apache.org/jira/browse/FLINK-5390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Maier reassigned FLINK-5390: -- Assignee: Roman Maier > input should be closed in finally block in >

[jira] [Commented] (FLINK-5086) Clean dead snapshot files produced by the tasks failing to acknowledge checkpoints

[ https://issues.apache.org/jira/browse/FLINK-5086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15777957#comment-15777957 ] Roman Maier commented on FLINK-5086: Hi, Till, I agree with you, I will take less complicated task.

[jira] [Updated] (FLINK-5086) Clean dead snapshot files produced by the tasks failing to acknowledge checkpoints

[ https://issues.apache.org/jira/browse/FLINK-5086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Maier updated FLINK-5086: --- Assignee: (was: Roman Maier) > Clean dead snapshot files produced by the tasks failing to

[jira] [Commented] (FLINK-5086) Clean dead snapshot files produced by the tasks failing to acknowledge checkpoints

[ https://issues.apache.org/jira/browse/FLINK-5086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15769671#comment-15769671 ] Roman Maier commented on FLINK-5086: Hi Till Rohrmann, I do not have a concrete plan yet. I see

[jira] [Assigned] (FLINK-5086) Clean dead snapshot files produced by the tasks failing to acknowledge checkpoints

[ https://issues.apache.org/jira/browse/FLINK-5086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Maier reassigned FLINK-5086: -- Assignee: Roman Maier > Clean dead snapshot files produced by the tasks failing to acknowledge

[jira] [Assigned] (FLINK-4616) Kafka consumer doesn't store last emmited watermarks per partition in state

[ https://issues.apache.org/jira/browse/FLINK-4616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Maier reassigned FLINK-4616: -- Assignee: Roman Maier > Kafka consumer doesn't store last emmited watermarks per partition in

[jira] [Assigned] (FLINK-3787) Yarn client does not report unfulfillable container constraints

[ https://issues.apache.org/jira/browse/FLINK-3787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Maier reassigned FLINK-3787: -- Assignee: Roman Maier > Yarn client does not report unfulfillable container constraints >

[jira] [Assigned] (FLINK-4741) WebRuntimeMonitor does not shut down all of it's threads (EventLoopGroups) on exit.

[ https://issues.apache.org/jira/browse/FLINK-4741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Maier reassigned FLINK-4741: -- Assignee: Roman Maier > WebRuntimeMonitor does not shut down all of it's threads

[jira] [Commented] (FLINK-5002) Lack of synchronization in LocalBufferPool#getNumberOfUsedBuffers

[ https://issues.apache.org/jira/browse/FLINK-5002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15682680#comment-15682680 ] Roman Maier commented on FLINK-5002: Here is a link to the commit:

[jira] [Commented] (FLINK-5002) Lack of synchronization in LocalBufferPool#getNumberOfUsedBuffers

[ https://issues.apache.org/jira/browse/FLINK-5002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15676805#comment-15676805 ] Roman Maier commented on FLINK-5002: Please check the implementation of this issue: