[jira] [Commented] (BEAM-5816) Flink portable bundles can fail to close with "Already closed" exception

2018-10-23 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-5816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16660270#comment-16660270 ] Maximilian Michels commented on BEAM-5816: -- [~thw] Didn't we already move the shutdown of the SDK

[jira] [Commented] (BEAM-5816) Flink portable bundles can fail to close with "Already closed" exception

2018-10-22 Thread Thomas Weise (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-5816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16659697#comment-16659697 ] Thomas Weise commented on BEAM-5816: Underlying (larger) issue is that DoFnOperator.dispose can