From 33581b8f4abc0da8c43a2ebf11e6b5d31cfb5c27 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 9ceb0066d30837..8cca71e64916d5 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(