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

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

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

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

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

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

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

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

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

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