diff --git a/hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/HiveSyncTool.java b/hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/HiveSyncTool.java index 5fd9c9c300098..47d45005ea7fe 100644 --- a/hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/HiveSyncTool.java +++ b/hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/HiveSyncTool.java @@ -114,8 +114,6 @@ public void syncHoodieTable() { private void syncHoodieTable(String tableName, boolean useRealtimeInputFormat) { LOG.info("Trying to sync hoodie table " + tableName + " with base path " + hoodieHiveClient.getBasePath() + " of type " + hoodieHiveClient.getTableType()); - // Check if the necessary table exists - boolean tableExists = hoodieHiveClient.doesTableExist(tableName); // check if the database exists else create it if (cfg.autoCreateDatabase) { @@ -131,6 +129,9 @@ private void syncHoodieTable(String tableName, boolean useRealtimeInputFormat) { } } + // Check if the necessary table exists + boolean tableExists = hoodieHiveClient.doesTableExist(tableName); + // Get the parquet schema for this table looking at the latest commit MessageType schema = hoodieHiveClient.getDataSchema(); // Sync schema if needed