lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[MINOR] hive sync checks for table after creating db if auto create is true (#2591)

Browse Source
This commit is contained in:
Ankush Kanungo
2021-02-23 10:35:14 -08:00
committed by GitHub
parent d2f360f5dd
commit 3b8d0f3b1f
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/HiveSyncTool.java
View File

@@ -114,8 +114,6 @@ public class HiveSyncTool extends AbstractSyncTool {
private void syncHoodieTable(String tableName, boolean useRealtimeInputFormat) { private void syncHoodieTable(String tableName, boolean useRealtimeInputFormat) {
LOG.info("Trying to sync hoodie table " + tableName + " with base path " + hoodieHiveClient.getBasePath() LOG.info("Trying to sync hoodie table " + tableName + " with base path " + hoodieHiveClient.getBasePath()
+ " of type " + hoodieHiveClient.getTableType()); + " of type " + hoodieHiveClient.getTableType());
// Check if the necessary table exists
boolean tableExists = hoodieHiveClient.doesTableExist(tableName);
// check if the database exists else create it // check if the database exists else create it
if (cfg.autoCreateDatabase) { if (cfg.autoCreateDatabase) {
@@ -131,6 +129,9 @@ public class HiveSyncTool extends AbstractSyncTool {
} }
} }
// Check if the necessary table exists
boolean tableExists = hoodieHiveClient.doesTableExist(tableName);
// Get the parquet schema for this table looking at the latest commit // Get the parquet schema for this table looking at the latest commit
MessageType schema = hoodieHiveClient.getDataSchema(); MessageType schema = hoodieHiveClient.getDataSchema();
// Sync schema if needed // Sync schema if needed