lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[MINOR] Optimize variable names and logs (#4581)

Browse Source
This commit is contained in:
董可伦
2022-01-16 16:09:22 +08:00
committed by GitHub
parent 5e0171a5ee
commit 822230d9ea
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/HoodieHiveClient.java
View File

@@ -261,23 +261,23 @@ public class HoodieHiveClient extends AbstractSyncHoodieClient {
public Option<String> getLastCommitTimeSynced(String tableName) { public Option<String> getLastCommitTimeSynced(String tableName) {
// Get the last commit time from the TBLproperties // Get the last commit time from the TBLproperties
try { try {
Table database = client.getTable(syncConfig.databaseName, tableName); Table table = client.getTable(syncConfig.databaseName, tableName);
return Option.ofNullable(database.getParameters().getOrDefault(HOODIE_LAST_COMMIT_TIME_SYNC, null)); return Option.ofNullable(table.getParameters().getOrDefault(HOODIE_LAST_COMMIT_TIME_SYNC, null));
} catch (Exception e) { } catch (Exception e) {
throw new HoodieHiveSyncException("Failed to get the last commit time synced from the database", e); throw new HoodieHiveSyncException("Failed to get the last commit time synced from the table " + tableName, e);
} }
} }
public Option<String> getLastReplicatedTime(String tableName) { public Option<String> getLastReplicatedTime(String tableName) {
// Get the last replicated time from the TBLproperties // Get the last replicated time from the TBLproperties
try { try {
Table database = client.getTable(syncConfig.databaseName, tableName); Table table = client.getTable(syncConfig.databaseName, tableName);
return Option.ofNullable(database.getParameters().getOrDefault(GLOBALLY_CONSISTENT_READ_TIMESTAMP, null)); return Option.ofNullable(table.getParameters().getOrDefault(GLOBALLY_CONSISTENT_READ_TIMESTAMP, null));
} catch (NoSuchObjectException e) { } catch (NoSuchObjectException e) {
LOG.warn("the said table not found in hms " + syncConfig.databaseName + "." + tableName); LOG.warn("the said table not found in hms " + syncConfig.databaseName + "." + tableName);
return Option.empty(); return Option.empty();
} catch (Exception e) { } catch (Exception e) {
throw new HoodieHiveSyncException("Failed to get the last replicated time from the database", e); throw new HoodieHiveSyncException("Failed to get the last replicated time from the table " + tableName, e);
} }
} }