This is an automated email from the ASF dual-hosted git repository.
yihua pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
The following commit(s) were added to refs/heads/master by this push:
new b78f162f8b5c refactor: change access level of flushRemaining for
flink-cdc requirements (#14206)
b78f162f8b5c is described below
commit b78f162f8b5c6ccc738b85efad958818a022602e
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) {
