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

2022-02-15 Thread GitBox
pltbkd commented on pull request #18680: URL: https://github.com/apache/flink/pull/18680#issuecomment-1041207282 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

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

2022-02-15 Thread GitBox
pltbkd commented on pull request #18680: URL: https://github.com/apache/flink/pull/18680#issuecomment-1041157963 > Thanks @pltbkd for the update! I try to fixed some tests. Also, could you have a look that if the two `*StateHandle` needs `snapshotState` ? Cleaning up of the state is

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

2022-02-11 Thread GitBox
pltbkd commented on pull request #18680: URL: https://github.com/apache/flink/pull/18680#issuecomment-1036024964 All comments so far are resolved now. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to

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

2022-02-10 Thread GitBox
pltbkd commented on pull request #18680: URL: https://github.com/apache/flink/pull/18680#issuecomment-1034821469 @gaoyunhaii Thanks for the suggestions. The commits are reorgnized to be more clear, and about 2/3 comments are resolved. I'm still working on the remaining ones. --

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

2022-02-09 Thread GitBox
pltbkd commented on pull request #18680: URL: https://github.com/apache/flink/pull/18680#issuecomment-1033636620 The branch is force pushed to add a hotfix before all commits, to fix the bug in SinkTransformationTranslator that sets parallelism of transformations added in the per-commit