[GitHub] flink pull request #6281: [FLINK-9750] Add new StreamingFileSink with Resuma...

Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/6281#discussion_r202574665 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/StreamingFileSink.java --- @@ -0,0 +1,397 @@ +/*

[GitHub] flink pull request #6281: [FLINK-9750] Add new StreamingFileSink with Resuma...

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/6281#discussion_r202556032 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/StreamingFileSink.java --- @@ -0,0 +1,397 @@

[GitHub] flink pull request #6281: [FLINK-9750] Add new StreamingFileSink with Resuma...

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/6281#discussion_r201374783 --- Diff: flink-core/src/test/java/org/apache/flink/core/fs/local/LocalFileSystemResumableWriterTest.java --- @@ -0,0 +1,45 @@ +/* + * Licensed

[GitHub] flink pull request #6281: [FLINK-9750] Add new StreamingFileSink with Resuma...

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/6281#discussion_r201400623 --- Diff: flink-core/src/test/java/org/apache/flink/core/fs/AbstractResumableWriterTest.java --- @@ -0,0 +1,326 @@ +/* + * Licensed to the

[GitHub] flink pull request #6281: [FLINK-9750] Add new StreamingFileSink with Resuma...

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/6281#discussion_r201369555 --- Diff: flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopRecoverableFsDataOutputStream.java --- @@ -253,4

[GitHub] flink pull request #6281: [FLINK-9750] Add new StreamingFileSink with Resuma...

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/6281#discussion_r201374633 --- Diff: flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopRecoverableFsDataOutputStream.java --- @@ -253,4

[GitHub] flink pull request #6281: [FLINK-9750] Add new StreamingFileSink with Resuma...

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/6281#discussion_r201375290 --- Diff: flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/util/HadoopUtils.java --- @@ -130,7 +130,7 @@ public static boolean

[GitHub] flink pull request #6281: [FLINK-9750] Add new StreamingFileSink with Resuma...

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/6281#discussion_r201401033 --- Diff: flink-core/src/test/java/org/apache/flink/core/fs/AbstractResumableWriterTest.java --- @@ -0,0 +1,326 @@ +/* + * Licensed to the

[GitHub] flink pull request #6281: [FLINK-9750] Add new StreamingFileSink with Resuma...

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/6281#discussion_r201375170 --- Diff: flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopRecoverableFsDataOutputStream.java --- @@ -41,6 +44,8

[GitHub] flink pull request #6281: [FLINK-9750] Add new StreamingFileSink with Resuma...

Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/6281#discussion_r201342618 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/StreamingFileSink.java --- @@ -0,0 +1,397 @@ +/*

[GitHub] flink pull request #6281: [FLINK-9750] Add new StreamingFileSink with Resuma...

Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/6281#discussion_r201059374 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/Bucket.java --- @@ -0,0 +1,297 @@ +/* + *

[GitHub] flink pull request #6281: [FLINK-9750] Add new StreamingFileSink with Resuma...

Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/6281#discussion_r201059444 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/Bucket.java --- @@ -0,0 +1,297 @@ +/* + *

[GitHub] flink pull request #6281: [FLINK-9750] Add new StreamingFileSink with Resuma...

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/6281#discussion_r201058746 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/Bucket.java --- @@ -0,0 +1,297 @@ +/* + *

[GitHub] flink pull request #6281: [FLINK-9750] Add new StreamingFileSink with Resuma...

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/6281#discussion_r201058329 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/Bucket.java --- @@ -0,0 +1,297 @@ +/* + *

[GitHub] flink pull request #6281: [FLINK-9750] Add new StreamingFileSink with Resuma...

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/6281#discussion_r201042618 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/StreamingFileSink.java --- @@ -0,0 +1,397 @@ +/*

[GitHub] flink pull request #6281: [FLINK-9750] Add new StreamingFileSink with Resuma...

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/6281#discussion_r201042180 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/StreamingFileSink.java --- @@ -0,0 +1,397 @@ +/*

[GitHub] flink pull request #6281: [FLINK-9750] Add new StreamingFileSink with Resuma...

Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/6281#discussion_r200909011 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/serialization/Writer.java --- @@ -0,0 +1,36 @@ +/* + * Licensed to the Apache Software

[GitHub] flink pull request #6281: [FLINK-9750] Add new StreamingFileSink with Resuma...

Github user yanghua commented on a diff in the pull request: https://github.com/apache/flink/pull/6281#discussion_r200835177 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/serialization/Writer.java --- @@ -0,0 +1,36 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request #6281: [FLINK-9750] Add new StreamingFileSink with Resuma...

GitHub user kl0u opened a pull request: https://github.com/apache/flink/pull/6281 [FLINK-9750] Add new StreamingFileSink with ResumableWriter. ## What is the purpose of the change This PR is the first step towards introducing a new Streaming Filesystem sink that works on