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 14c947b51f1ad..95048dd8a71ca 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 @@ -294,7 +294,7 @@ private boolean syncSchema(String tableName, boolean tableExists, boolean useRea boolean schemaChanged = false; // Check and sync schema if (!tableExists) { - LOG.info("Hive table " + tableName + " is not found. Creating it"); + LOG.info("Hive table {} is not found. Creating it with schema {}.", tableName, schema); HoodieFileFormat baseFileFormat = HoodieFileFormat.valueOf(config.getStringOrDefault(META_SYNC_BASE_FILE_FORMAT).toUpperCase()); String inputFormatClassName = HoodieInputFormatUtils.getInputFormatClassName(baseFileFormat, useRealTimeInputFormat); @@ -320,7 +320,7 @@ private boolean syncSchema(String tableName, boolean tableExists, boolean useRea SchemaDifference schemaDiff = HiveSchemaUtil.getSchemaDifference(schema, tableSchema, config.getSplitStrings(META_SYNC_PARTITION_FIELDS), config.getBooleanOrDefault(HIVE_SUPPORT_TIMESTAMP_TYPE)); if (!schemaDiff.isEmpty()) { - LOG.info("Schema difference found for " + tableName); + LOG.info("Schema difference found for {}. Updated schema: {}", tableName, schema); syncClient.updateTableSchema(tableName, schema); // Sync the table properties if the schema has changed if (config.getString(HIVE_TABLE_PROPERTIES) != null || config.getBoolean(HIVE_SYNC_AS_DATA_SOURCE_TABLE)) { @@ -330,7 +330,7 @@ private boolean syncSchema(String tableName, boolean tableExists, boolean useRea } schemaChanged = true; } else { - LOG.info("No Schema difference for " + tableName); + LOG.info("No Schema difference for {}\nMessageType: {}", tableName, schema); } }