This is an automated email from the ASF dual-hosted git repository. yihua pushed a commit to branch release-1.1.0 in repository https://gitbox.apache.org/repos/asf/hudi.git
commit 64ce0a370fa5ecdf11bd78bbda757840f93d8615 Author: voonhous <[email protected]> AuthorDate: Thu Nov 6 07:20:17 2025 +0800 refactor: change access level of flushRemaining for flink-cdc requirements (#14206) --- .../src/main/java/org/apache/hudi/sink/StreamWriteFunction.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteFunction.java b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteFunction.java index 1d5ff28aaf84..4564ddb81607 100644 --- a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteFunction.java +++ b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteFunction.java @@ -381,7 +381,7 @@ public class StreamWriteFunction extends AbstractStreamWriteFunction<HoodieFlink return true; } - private void flushRemaining(boolean endInput) { + public void flushRemaining(boolean endInput) { writeMetrics.startDataFlush(); this.currentInstant = instantToWrite(hasData()); if (this.currentInstant == null) {
