Address review + add concurrency fix

apache · Jan 13, 2022 · d723cb4 · d723cb4
1 parent 14767b1
commit d723cb4
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...istration/src/main/java/org/apache/gobblin/hive/metastore/HiveMetaStoreBasedRegister.java b/...istration/src/main/java/org/apache/gobblin/hive/metastore/HiveMetaStoreBasedRegister.java
@@ -479,7 +479,8 @@ private void createOrAlterTable(IMetaStoreClient client, Table table, HiveSpec s
   }
 
   public boolean existsTable(String dbName, String tableName, IMetaStoreClient client) throws IOException {
-    if (this.optimizedChecks && this.tableAndDbExistenceCache.getIfPresent(dbName + ":" + tableName ) != null ) {
+    Boolean tableExits = this.tableAndDbExistenceCache.getIfPresent(dbName + ":" + tableName );
+    if (this.optimizedChecks && tableExits != null && tableExits) {
       return true;
     }
     try {