[GitHub] flink issue #2859: [FLINK-5147] Prevent NPE in LocalFS#delete()
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2859 @rmetzger ty for review, merging. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---
[GitHub] flink issue #2859: [FLINK-5147] Prevent NPE in LocalFS#delete()
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2859 +1 to merge --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---
[GitHub] flink issue #2859: [FLINK-5147] Prevent NPE in LocalFS#delete()
Github user BorisOsipov commented on the issue: https://github.com/apache/flink/pull/2859 @zentol Thank you! Sorry for off topic. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---
[GitHub] flink issue #2859: [FLINK-5147] Prevent NPE in LocalFS#delete()
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2859 Because synchronization issues would still occur if the output path targets a distributed file system. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---
[GitHub] flink issue #2859: [FLINK-5147] Prevent NPE in LocalFS#delete()
Github user BorisOsipov commented on the issue: https://github.com/apache/flink/pull/2859 @zentol I'd like to ask you, why FileSystem#initOutPathLocalFS() is not properly synchronized? Recently I faced with issues like FLINK-4798, FLINK-5077. In such issues one thread removes files with the results of other threads because of lack of synchronization in FileSystem#initOutPathLocalFS() --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---