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 2196694dbea [HUDI-6813] Support table name for meta sync in bootstrap 
(#9600)
2196694dbea is described below

commit 2196694dbeac29fda86fa977fd90634474d4a50a
Author: Jing Zhang <[email protected]>
AuthorDate: Sat Sep 2 09:38:31 2023 +0800

    [HUDI-6813] Support table name for meta sync in bootstrap (#9600)
---
 .../src/main/java/org/apache/hudi/cli/BootstrapExecutorUtils.java       | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/hudi-spark-datasource/hudi-spark/src/main/java/org/apache/hudi/cli/BootstrapExecutorUtils.java
 
b/hudi-spark-datasource/hudi-spark/src/main/java/org/apache/hudi/cli/BootstrapExecutorUtils.java
index 7ea1ccdc745..90ab2f9cbab 100644
--- 
a/hudi-spark-datasource/hudi-spark/src/main/java/org/apache/hudi/cli/BootstrapExecutorUtils.java
+++ 
b/hudi-spark-datasource/hudi-spark/src/main/java/org/apache/hudi/cli/BootstrapExecutorUtils.java
@@ -73,6 +73,7 @@ import static 
org.apache.hudi.keygen.constant.KeyGeneratorOptions.URL_ENCODE_PAR
 import static 
org.apache.hudi.sync.common.HoodieSyncConfig.META_SYNC_BASE_FILE_FORMAT;
 import static org.apache.hudi.sync.common.HoodieSyncConfig.META_SYNC_BASE_PATH;
 import static 
org.apache.hudi.sync.common.HoodieSyncConfig.META_SYNC_DATABASE_NAME;
+import static 
org.apache.hudi.sync.common.HoodieSyncConfig.META_SYNC_TABLE_NAME;
 
 /**
  * Performs bootstrap from a non-hudi source.
@@ -194,6 +195,7 @@ public class BootstrapExecutorUtils implements Serializable 
{
       TypedProperties metaProps = new TypedProperties();
       metaProps.putAll(props);
       metaProps.put(META_SYNC_DATABASE_NAME.key(), cfg.database);
+      metaProps.put(META_SYNC_TABLE_NAME.key(), cfg.tableName);
       metaProps.put(META_SYNC_BASE_PATH.key(), cfg.basePath);
       metaProps.put(META_SYNC_BASE_FILE_FORMAT.key(), cfg.baseFileFormat);
       if (props.getBoolean(HIVE_SYNC_BUCKET_SYNC.key(), 
HIVE_SYNC_BUCKET_SYNC.defaultValue())) {

Reply via email to