Github user twalthr closed the pull request at:
https://github.com/apache/flink/pull/5811
---
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5811#discussion_r179743870
--- Diff:
flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSink.java
---
@@ -366,6 +3
GitHub user twalthr opened a pull request:
https://github.com/apache/flink/pull/5811
[FLINK-9113] [connectors] Fix flushing behavior of bucketing sink for local
filesystems
## What is the purpose of the change
This PR changes the flushing behavior for HDFS' local filesystem