(hudi) branch master updated: [HUDI-8950] Explicitly set base path in sync config #12754

[wombatukun]

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

wombatukun 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 e95b5c0a815 [HUDI-8950] Explicitly set base path in sync config #12754
e95b5c0a815 is described below

commit e95b5c0a815ebdd87f2a30435a0181681fd33a29
Author: Shawn Chang <42792772+c...@users.noreply.github.com>
AuthorDate: Sun Feb 2 18:59:51 2025 -0800

    [HUDI-8950] Explicitly set base path in sync config #12754
---
 .../src/main/java/org/apache/hudi/sync/common/util/SyncUtilHelpers.java | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/hudi-sync/hudi-sync-common/src/main/java/org/apache/hudi/sync/common/util/SyncUtilHelpers.java
 
b/hudi-sync/hudi-sync-common/src/main/java/org/apache/hudi/sync/common/util/SyncUtilHelpers.java
index 80032ae6077..080dd2c1891 100644
--- 
a/hudi-sync/hudi-sync-common/src/main/java/org/apache/hudi/sync/common/util/SyncUtilHelpers.java
+++ 
b/hudi-sync/hudi-sync-common/src/main/java/org/apache/hudi/sync/common/util/SyncUtilHelpers.java
@@ -38,6 +38,7 @@ import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.locks.Lock;
 import java.util.concurrent.locks.ReentrantLock;
 
+import static org.apache.hudi.common.config.HoodieCommonConfig.BASE_PATH;
 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_TABLE_NAME;
@@ -119,6 +120,7 @@ public class SyncUtilHelpers {
                                                        
Option<HoodieTableMetaClient> metaClient) {
     TypedProperties properties = new TypedProperties();
     properties.putAll(props);
+    properties.put(BASE_PATH.key(), targetBasePath);
     properties.put(META_SYNC_BASE_PATH.key(), targetBasePath);
     properties.put(META_SYNC_BASE_FILE_FORMAT.key(), baseFileFormat);
     if (properties.containsKey(META_SYNC_TABLE_NAME.key())) {