This is an automated email from the ASF dual-hosted git repository.
gaoyunhaii pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 106a45e [FLINK-26583][runtime] Adds log message for when a Job is
submitted that is already marked as cleaned
add b4e2690 [FLINK-26580][connectors/filesystem] Fix the bug that
FileSink CompactCoordinator adds in-progress committable as toCompacted
add fafac08 [FLINK-26580][connectors/filesystem]
CompactorOperatorStateHandler can accept multiple remaining in-progress files
from different buckets.
add 8d7194a [hotfix][connectors/filesystem] Rename the operatorName in
topology of the state handler operators.
add b8e7fc3 [hotfix][connectors/filesystem] Make the compactor tests to
extend TestLogger.
No new revisions were added by this update.
Summary of changes:
.../apache/flink/connector/file/sink/FileSink.java | 4 +-
.../compactor/operator/CompactCoordinator.java | 8 +-
.../operator/CompactorOperatorStateHandler.java | 86 +++-------------------
.../file/sink/BatchCompactingFileSinkITCase.java | 3 +-
...FileSinkCommittableSerializerMigrationTest.java | 3 +-
.../file/sink/FileSinkCompactionSwitchITCase.java | 7 +-
.../flink/connector/file/sink/FileSinkITBase.java | 30 +-------
.../sink/StreamingCompactingFileSinkITCase.java | 3 +-
.../sink/compactor/AbstractCompactTestBase.java | 3 +-
.../sink/compactor/CompactCoordinatorTest.java | 3 +
.../file/sink/compactor/CompactorOperatorTest.java | 5 --
.../utils/PartSizeAndCheckpointRollingPolicy.java} | 37 ++++++----
...treamBasedPartFileRecoverableMigrationTest.java | 3 +-
...dingFileRecoverableSerializerMigrationTest.java | 3 +-
14 files changed, 60 insertions(+), 138 deletions(-)
copy
flink-connectors/{flink-file-sink-common/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/rollingpolicies/OnCheckpointRollingPolicy.java
=>
flink-connector-files/src/test/java/org/apache/flink/connector/file/sink/utils/PartSizeAndCheckpointRollingPolicy.java}
(57%)
