Skip to content

Commit 2a24946

Browse files
author
yuzelin
committed
fix comment
1 parent 5264dd2 commit 2a24946

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/LookupDataTableScan.java

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,6 @@
3939

4040
import javax.annotation.Nullable;
4141

42-
import java.util.Collections;
4342
import java.util.List;
4443

4544
import static org.apache.paimon.CoreOptions.StartupMode;
@@ -57,7 +56,7 @@ public class LookupDataTableScan extends DataTableStreamScan {
5756
private final StartupMode startupMode;
5857
private final LookupStreamScanMode lookupScanMode;
5958

60-
private List<BinaryRow> scanPartitions = Collections.emptyList();
59+
@Nullable private List<BinaryRow> scanPartitions = null;
6160

6261
public LookupDataTableScan(
6362
FileStoreTable table,
@@ -105,7 +104,7 @@ protected SnapshotReader.Plan handleOverwriteSnapshot(Snapshot snapshot) {
105104
}
106105

107106
private boolean shouldReopen(Snapshot snapshot) {
108-
if (scanPartitions.isEmpty()) {
107+
if (scanPartitions == null) {
109108
return true;
110109
}
111110

0 commit comments

Comments
 (0)