(hudi) branch master updated: [HUDI-9768] further improve of HUDI-8863 (#13789)

[danny0405]

This is an automated email from the ASF dual-hosted git repository.

danny0405 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 040719434317 [HUDI-9768] further improve of HUDI-8863 (#13789)
040719434317 is described below

commit 040719434317ad8c7a28756796efddb91579fc05
Author: fhan <aaron.han.1...@gmail.com>
AuthorDate: Thu Aug 28 09:38:07 2025 +0800

    [HUDI-9768] further improve of HUDI-8863 (#13789)
    
    Co-authored-by: fhan <yfhan...@jd.com>
---
 .../java/org/apache/hudi/source/StreamReadMonitoringFunction.java  | 7 +++----
 1 file changed, 3 insertions(+), 4 deletions(-)

diff --git 
a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/StreamReadMonitoringFunction.java
 
b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/StreamReadMonitoringFunction.java
index 197c1f8ee4fc..bc7ec45e7311 100644
--- 
a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/StreamReadMonitoringFunction.java
+++ 
b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/StreamReadMonitoringFunction.java
@@ -252,7 +252,6 @@ public class StreamReadMonitoringFunction
     }
 
     List<MergeOnReadInputSplit> inputSplits = result.getInputSplits();
-    LOG.info("Table {} : Read {} inputsplits for current instant", 
conf.get(FlinkOptions.TABLE_NAME), inputSplits.size());
     int endIndex = Math.min(splitsLimit, inputSplits.size());
     for (int index = 0; index < endIndex; index++) {
       context.collect(inputSplits.get(index));
@@ -266,14 +265,14 @@ public class StreamReadMonitoringFunction
     this.issuedInstant = result.getEndInstant();
     this.issuedOffset = result.getOffset();
     int sentSplits = totalSplits - remainingSplits.size();
-    double sentPercent = totalSplits == 0 ? 0 : (1 - remainingSplits.size() / 
(double) totalSplits) * 100;
+    double sentPercentage = totalSplits == 0 ? 0 : (1 - remainingSplits.size() 
/ (double) totalSplits) * 100;
     LOG.info("\n"
             + "------------------------------------------------------------\n"
             + "---------- table: {}\n"
             + "---------- consumed to instant: {}\n"
-            + "---------- total sent {} inputsplits out of {}, percent is 
{}%\n"
+            + "---------- sent {} inputsplits out of {}, percentage is {}%\n"
             + "------------------------------------------------------------",
-        conf.get(FlinkOptions.TABLE_NAME), this.issuedInstant, sentSplits, 
totalSplits, sentPercent);
+        conf.get(FlinkOptions.TABLE_NAME), this.issuedInstant, sentSplits, 
totalSplits, sentPercentage);
     if (result.isEmpty()) {
       LOG.warn("No new files to read for current run.");
     }