You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by vb...@apache.org on 2024/02/25 19:09:55 UTC
(hudi) branch master updated: [MINOR] StreamerUtil prints wrong table path (#10706)
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 <34...@users.noreply.github.com>
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 <et...@gmail.com>
---------
Co-authored-by: Y Ethan Guo <et...@gmail.com>
---
.../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));
}