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 <kaka11.c...@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-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
