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));
}