[GitHub] flink pull request #5811: [FLINK-9113] [connectors] Fix flushing behavior of...

2018-04-06 Thread twalthr
Github user twalthr closed the pull request at: https://github.com/apache/flink/pull/5811 ---

[GitHub] flink pull request #5811: [FLINK-9113] [connectors] Fix flushing behavior of...

2018-04-06 Thread pnowojski
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] flink pull request #5811: [FLINK-9113] [connectors] Fix flushing behavior of...

2018-04-04 Thread twalthr
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