You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by kx...@apache.org on 2023/12/20 04:40:11 UTC
(doris) branch branch-2.0 updated: [Fix](transactional-hive) Fix hive transactional table return empty result. #28518 (#28694)
This is an automated email from the ASF dual-hosted git repository.
kxiao pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.0 by this push:
new 3a87caff0b1 [Fix](transactional-hive) Fix hive transactional table return empty result. #28518 (#28694)
3a87caff0b1 is described below
commit 3a87caff0b1cba6d0f952567378b0a90bf6648c7
Author: Qi Chen <ka...@gmail.com>
AuthorDate: Wed Dec 20 12:40:04 2023 +0800
[Fix](transactional-hive) Fix hive transactional table return empty result. #28518 (#28694)
---
.../java/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 0ab5179ffa5..cc0a12e922c 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 class HiveMetaStoreCache {
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 class HiveMetaStoreCache {
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(
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org