You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by yi...@apache.org on 2025/11/10 18:13:43 UTC
(hudi) 06/16: refactor: change access level of flushRemaining for flink-cdc requirements (#14206)
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 <vo...@gmail.com>
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) {