From 8ad0bb97453ee2d625cf2b41374d781d186aef5d Mon Sep 17 00:00:00 2001 From: Xingcan Cui Date: Fri, 13 May 2022 00:20:40 -0400 Subject: [PATCH] [MINOR] Fix a NPE for Option (#5461) --- .../java/org/apache/hudi/aws/sync/AWSGlueCatalogSyncClient.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/hudi-aws/src/main/java/org/apache/hudi/aws/sync/AWSGlueCatalogSyncClient.java b/hudi-aws/src/main/java/org/apache/hudi/aws/sync/AWSGlueCatalogSyncClient.java index 81c05ed13..e5a23a9a5 100644 --- a/hudi-aws/src/main/java/org/apache/hudi/aws/sync/AWSGlueCatalogSyncClient.java +++ b/hudi-aws/src/main/java/org/apache/hudi/aws/sync/AWSGlueCatalogSyncClient.java @@ -394,7 +394,7 @@ public class AWSGlueCatalogSyncClient extends AbstractHiveSyncHoodieClient { public Option getLastCommitTimeSynced(String tableName) { try { 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) { throw new HoodieGlueSyncException("Fail to get last sync commit time for " + tableId(databaseName, tableName), e); }