fix

apache · Nov 7, 2024 · cb36eb2 · cb36eb2
1 parent 3f1b0d1
commit cb36eb2
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 18 deletions.
diff --git a/paimon-core/src/main/java/org/apache/paimon/table/system/SchemasTable.java b/paimon-core/src/main/java/org/apache/paimon/table/system/SchemasTable.java
@@ -239,12 +239,7 @@ public InnerTableRead withFilter(Predicate predicate) {
                                     schemaIds.add((Long) ((LeafPredicate) p).literals().get(0));
                                 }
                             },
-                            (Predicate p) -> {
-                                if (schemaIds != null) {
-                                    schemaIds.clear();
-                                    schemaIds = null;
-                                }
-                            });
+                            (Predicate p) -> schemaIds = null);
                 }
             } else {
                 handleLeafPredicate(predicate, leafName);

diff --git a/paimon-core/src/main/java/org/apache/paimon/table/system/SnapshotsTable.java b/paimon-core/src/main/java/org/apache/paimon/table/system/SnapshotsTable.java
@@ -242,12 +242,7 @@ public InnerTableRead withFilter(Predicate predicate) {
                                     snapshotIds.add((Long) ((LeafPredicate) p).literals().get(0));
                                 }
                             },
-                            (Predicate p) -> {
-                                if (snapshotIds != null) {
-                                    snapshotIds.clear();
-                                    snapshotIds = null;
-                                }
-                            });
+                            (Predicate p) -> snapshotIds = null);
                 }
             } else {
                 handleLeafPredicate(predicate, leafName);

diff --git a/paimon-core/src/main/java/org/apache/paimon/table/system/TagsTable.java b/paimon-core/src/main/java/org/apache/paimon/table/system/TagsTable.java
@@ -250,12 +250,7 @@ public RecordReader<InternalRow> createReader(Split split) {
                                         predicateMap.put(equalValue, tagManager.tag(equalValue));
                                     }
                                 },
-                                (Predicate p) -> {
-                                    if (predicateMap != null) {
-                                        predicateMap.clear();
-                                        predicateMap = null;
-                                    }
-                                });
+                                (Predicate p) -> predicateMap = null);
                     }
                 }
             }