[MINOR] Fix a NPE for Option (#5461)
This commit is contained in:
@@ -394,7 +394,7 @@ public class AWSGlueCatalogSyncClient extends AbstractHiveSyncHoodieClient {
|
|||||||
public Option<String> getLastCommitTimeSynced(String tableName) {
|
public Option<String> getLastCommitTimeSynced(String tableName) {
|
||||||
try {
|
try {
|
||||||
Table table = getTable(awsGlue, databaseName, tableName);
|
Table table = getTable(awsGlue, databaseName, tableName);
|
||||||
return Option.of(table.getParameters().getOrDefault(HOODIE_LAST_COMMIT_TIME_SYNC, null));
|
return Option.ofNullable(table.getParameters().get(HOODIE_LAST_COMMIT_TIME_SYNC));
|
||||||
} catch (Exception e) {
|
} catch (Exception e) {
|
||||||
throw new HoodieGlueSyncException("Fail to get last sync commit time for " + tableId(databaseName, tableName), e);
|
throw new HoodieGlueSyncException("Fail to get last sync commit time for " + tableId(databaseName, tableName), e);
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user