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 57db00ab98e0..e7d61f96cff8 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 @@ -71,9 +71,12 @@ static HoodieSyncTool instantiateMetaSyncTool(String syncToolClassName, properties.putAll(props); properties.put(HoodieSyncConfig.META_SYNC_BASE_PATH.key(), targetBasePath); properties.put(HoodieSyncConfig.META_SYNC_BASE_FILE_FORMAT.key(), baseFileFormat); - String tableName = properties.getString(HoodieSyncConfig.META_SYNC_TABLE_NAME.key()); - if (!tableName.equals(tableName.toLowerCase())) { - LOG.warn("Table name \"" + tableName + "\" contains capital letters. Your metastore may automatically convert this to lower case and can cause table not found errors during subsequent syncs."); + if (properties.containsKey(HoodieSyncConfig.META_SYNC_TABLE_NAME.key())) { + String tableName = properties.getString(HoodieSyncConfig.META_SYNC_TABLE_NAME.key()); + if (!tableName.equals(tableName.toLowerCase())) { + LOG.warn( + "Table name \"" + tableName + "\" contains capital letters. Your metastore may automatically convert this to lower case and can cause table not found errors during subsequent syncs."); + } } if (ReflectionUtils.hasConstructor(syncToolClassName,