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

vbalaji 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 d0929341d0a [MINOR] StreamerUtil prints wrong table path (#10706)
d0929341d0a is described below

commit d0929341d0ad25b3ce587d7f229d2fcdf7796768
Author: zhuanshenbsj1 <[email protected]>
AuthorDate: Mon Feb 26 03:09:50 2024 +0800

    [MINOR] StreamerUtil prints wrong table path (#10706)
    
    * update print
    
    * Update 
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/StreamerUtil.java
    
    Co-authored-by: Y Ethan Guo <[email protected]>
    
    ---------
    
    Co-authored-by: Y Ethan Guo <[email protected]>
---
 .../hudi-flink/src/main/java/org/apache/hudi/util/StreamerUtil.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/StreamerUtil.java
 
b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/StreamerUtil.java
index 064e59cc751..d9770743947 100644
--- 
a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/StreamerUtil.java
+++ 
b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/StreamerUtil.java
@@ -265,7 +265,7 @@ public class StreamerUtil {
           .initTable(hadoopConf, basePath);
       LOG.info("Table initialized under base path {}", basePath);
     } else {
-      LOG.info("Table [{}/{}] already exists, no need to initialize the table",
+      LOG.info("Table [path={}, name={}] already exists, no need to initialize 
the table",
           basePath, conf.getString(FlinkOptions.TABLE_NAME));
     }
 

Reply via email to