[GitHub] [flink] pltbkd commented on a change in pull request #18680: [FLINK-25583] Support compacting small files for FileSink.

pltbkd commented on a change in pull request #18680: URL: https://github.com/apache/flink/pull/18680#discussion_r804491562 ## File path: flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/sink/FileSink.java ## @@ -177,6 +189,45 @@ private

[GitHub] [flink] pltbkd commented on a change in pull request #18680: [FLINK-25583] Support compacting small files for FileSink.

pltbkd commented on a change in pull request #18680: URL: https://github.com/apache/flink/pull/18680#discussion_r804489417 ## File path: flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/sink/FileSink.java ## @@ -177,6 +189,45 @@ private

[GitHub] [flink] pltbkd commented on a change in pull request #18680: [FLINK-25583] Support compacting small files for FileSink.

pltbkd commented on a change in pull request #18680: URL: https://github.com/apache/flink/pull/18680#discussion_r804460785 ## File path: flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/sink/compactor/FileCompactStrategy.java ## @@ -0,0

[GitHub] [flink] pltbkd commented on a change in pull request #18680: [FLINK-25583] Support compacting small files for FileSink.

pltbkd commented on a change in pull request #18680: URL: https://github.com/apache/flink/pull/18680#discussion_r804458284 ## File path: flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/sink/compactor/operator/CompactCoordinator.java ## @@

[GitHub] [flink] pltbkd commented on a change in pull request #18680: [FLINK-25583] Support compacting small files for FileSink.

pltbkd commented on a change in pull request #18680: URL: https://github.com/apache/flink/pull/18680#discussion_r804443649 ## File path: flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/sink/FileSink.java ## @@ -177,6 +189,45 @@ private

[GitHub] [flink] pltbkd commented on a change in pull request #18680: [FLINK-25583] Support compacting small files for FileSink.

pltbkd commented on a change in pull request #18680: URL: https://github.com/apache/flink/pull/18680#discussion_r804373669 ## File path: flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/sink/compactor/FileCompactStrategy.java ## @@ -0,0

[GitHub] [flink] pltbkd commented on a change in pull request #18680: [FLINK-25583] Support compacting small files for FileSink.

pltbkd commented on a change in pull request #18680: URL: https://github.com/apache/flink/pull/18680#discussion_r804337678 ## File path: flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/sink/compactor/operator/CompactorOperator.java ## @@

[GitHub] [flink] pltbkd commented on a change in pull request #18680: [FLINK-25583] Support compacting small files for FileSink.

pltbkd commented on a change in pull request #18680: URL: https://github.com/apache/flink/pull/18680#discussion_r804334220 ## File path: flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/sink/compactor/ConcatFileCompactor.java ## @@ -0,0

[GitHub] [flink] pltbkd commented on a change in pull request #18680: [FLINK-25583] Support compacting small files for FileSink.

pltbkd commented on a change in pull request #18680: URL: https://github.com/apache/flink/pull/18680#discussion_r803584223 ## File path: flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/sink/compactor/operator/CompactorOperator.java ## @@

[GitHub] [flink] pltbkd commented on a change in pull request #18680: [FLINK-25583] Support compacting small files for FileSink.

pltbkd commented on a change in pull request #18680: URL: https://github.com/apache/flink/pull/18680#discussion_r803478421 ## File path: flink-connectors/flink-file-sink-common/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/BucketWriter.java ## @@