database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[Fix](multi-catalog) fix NPE for FileCacheValue. (#21441)

Browse Source 
FileCacheValue.files may be null if there is not any files exists for some partitions.
This commit is contained in:
Xiangyu Wang
2023-07-03 23:38:58 +08:00
committed by GitHub
parent 5e6242e235
commit 11e18f4c98
1 changed files with 2 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
fe/fe-core/src/main/java/org/apache/doris/datasource/hive/HiveMetaStoreCache.java
View File

@ -917,9 +917,9 @@ public class HiveMetaStoreCache {
@Data
public static class FileCacheValue {
// File Cache for self splitter.
private List<HiveFileStatus> files;
private final List<HiveFileStatus> files = Lists.newArrayList();
// File split cache for old splitter. This is a temp variable.
private List<Split> splits;
private final List<Split> splits = Lists.newArrayList();
private boolean isSplittable;
// The values of partitions.
// e.g for file : hdfs://path/to/table/part1=a/part2=b/datafile
@ -929,9 +929,6 @@ public class HiveMetaStoreCache {
private AcidInfo acidInfo;
public void addFile(RemoteFile file) {
if (files == null) {
files = Lists.newArrayList();
}
HiveFileStatus status = new HiveFileStatus();
status.setBlockLocations(file.getBlockLocations());
status.setPath(file.getPath());
@ -942,9 +939,6 @@ public class HiveMetaStoreCache {
}
public void addSplit(Split split) {
if (splits == null) {
splits = Lists.newArrayList();
}
splits.add(split);
}