[Fix](transactional-hive) Fix hive transactional table return empty r…

…esult.
apache · Dec 20, 2023 · 66c4305 · 66c4305
1 parent c16be3c
commit 66c4305
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/HiveMetaStoreCache.java b/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/HiveMetaStoreCache.java
@@ -793,7 +793,7 @@ public List<FileCacheValue> getFilesByTransaction(List<HivePartition> partitions
                     directory = AcidUtils.getAcidState(new Path(partition.getPath()), jobConf, validWriteIds, false,
                             true);
                 }
-                if (directory == null || directory.getBaseDirectory() == null) {
+                if (directory == null) {
                     return Collections.emptyList();
                 }
                 if (!directory.getOriginalFiles().isEmpty()) {
@@ -809,6 +809,9 @@ public List<FileCacheValue> getFilesByTransaction(List<HivePartition> partitions
                     Path baseOrDeltaPath = directory.getBaseDirectory() != null ? directory.getBaseDirectory() :
                             !directory.getCurrentDirectories().isEmpty() ? directory.getCurrentDirectories().get(0)
                                     .getPath() : null;
+                    if (baseOrDeltaPath == null) {
+                        return Collections.emptyList();
+                    }
                     String acidVersionPath = new Path(baseOrDeltaPath, "_orc_acid_version").toUri().toString();
                     RemoteFileSystem fs = Env.getCurrentEnv().getExtMetaCacheMgr().getFsCache().getRemoteFileSystem(
                             new FileSystemCache.FileSystemCacheKey(