We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 075d22a commit 5264dd2Copy full SHA for 5264dd2
paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/FullCacheLookupTable.java
@@ -55,6 +55,7 @@
55
import java.io.File;
56
import java.io.IOException;
57
import java.util.ArrayList;
58
+import java.util.Collections;
59
import java.util.HashSet;
60
import java.util.Iterator;
61
import java.util.List;
@@ -92,7 +93,7 @@ public abstract class FullCacheLookupTable implements LookupTable {
92
93
private final FileStoreTable table;
94
private Future<?> refreshFuture;
95
private LookupStreamingReader reader;
- private List<BinaryRow> scanPartitions;
96
+ private List<BinaryRow> scanPartitions = Collections.emptyList();
97
@Nullable private Predicate partitionFilter;
98
@Nullable private Filter<InternalRow> cacheRowFilter;
99
0 commit comments