[hudi] branch master updated: [MINOR] Add table name and range msg for streaming reads logs (#9912)

[yihua]

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 250456f3fba [MINOR] Add table name and range msg for streaming reads 
logs (#9912)
250456f3fba is described below

commit 250456f3fba70d35a0cc8445d143d187bd3abd7e
Author: zhuanshenbsj1 <34104400+zhuanshenb...@users.noreply.github.com>
AuthorDate: Thu Oct 26 02:06:24 2023 +0800

    [MINOR] Add table name and range msg for streaming reads logs (#9912)
---
 .../main/java/org/apache/hudi/common/table/log/InstantRange.java | 9 +++++++++
 .../org/apache/hudi/source/StreamReadMonitoringFunction.java     | 3 ++-
 2 files changed, 11 insertions(+), 1 deletion(-)

diff --git 
a/hudi-common/src/main/java/org/apache/hudi/common/table/log/InstantRange.java 
b/hudi-common/src/main/java/org/apache/hudi/common/table/log/InstantRange.java
index 6609ad085ef..96c7b0c0ddf 100644
--- 
a/hudi-common/src/main/java/org/apache/hudi/common/table/log/InstantRange.java
+++ 
b/hudi-common/src/main/java/org/apache/hudi/common/table/log/InstantRange.java
@@ -57,6 +57,15 @@ public abstract class InstantRange implements Serializable {
 
   public abstract boolean isInRange(String instant);
 
+  @Override
+  public String toString() {
+    return "InstantRange{"
+        + "startInstant='" + startInstant == null ? "null" : startInstant + 
'\''
+        + ", endInstant='" + endInstant == null ? "null" : endInstant + '\''
+        + ", rangeType='" + this.getClass().getSimpleName() + '\''
+        + '}';
+  }
+
   // -------------------------------------------------------------------------
   //  Inner Class
   // -------------------------------------------------------------------------
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 6f0fd9253e2..86e32fe5a0a 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
@@ -226,9 +226,10 @@ public class StreamReadMonitoringFunction
     this.issuedOffset = result.getOffset();
     LOG.info("\n"
             + "------------------------------------------------------------\n"
+            + "---------- table: {}\n"
             + "---------- consumed to instant: {}\n"
             + "------------------------------------------------------------",
-        this.issuedInstant);
+        conf.getString(FlinkOptions.TABLE_NAME), this.issuedInstant);
   }
 
   @Override