flink git commit: [hotfix] Making arguments in BroadcastProcessFunction final.

Repository: flink Updated Branches: refs/heads/release-1.5 7ae8e41d8 -> 53fb4f737 [hotfix] Making arguments in BroadcastProcessFunction final. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/53fb4f73 Tree: http://git-wip-u

flink git commit: [hotfix] Making arguments in BroadcastProcessFunction final.

Repository: flink Updated Branches: refs/heads/master d519eb78e -> fb254763c [hotfix] Making arguments in BroadcastProcessFunction final. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fb254763 Tree: http://git-wip-us.apa

[2/2] flink git commit: [FLINK-9113] [connectors] Use raw local file system for bucketing sink to prevent data loss

[FLINK-9113] [connectors] Use raw local file system for bucketing sink to prevent data loss This change replaces Hadoop's LocalFileSystem (which is a checksumming filesystem) with the RawFileSystem implementation. For performing checksums the default filesystem only flushes in 512 byte interval

[1/2] flink git commit: [FLINK-8600] Allow disabling truncate() check in BucketingSink

Repository: flink Updated Branches: refs/heads/release-1.4 ba8d72ab5 -> 896797be7 [FLINK-8600] Allow disabling truncate() check in BucketingSink The test was failing when using PrestoS3FileSystem because it doesn't use an absolute/qualified path. Project: http://git-wip-us.apache.org/repos/a