From 66c43056aca70568b94a6510f4f4bc7fd3d66005 Mon Sep 17 00:00:00 2001 From: kaka11chen Date: Sat, 16 Dec 2023 19:38:32 +0800 Subject: [PATCH] [Fix](transactional-hive) Fix hive transactional table return empty result. --- .../org/apache/doris/datasource/hive/HiveMetaStoreCache.java | 5 ++++- 1 file changed, 4 insertions(+), 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 index 0ab5179ffa5b89..cc0a12e922cd2b 100644 --- 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 getFilesByTransaction(List 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 getFilesByTransaction(List 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(