minor fix

apache · Nov 7, 2024 · 1698c93 · 1698c93
1 parent d973c87
commit 1698c93
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 0 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
@@ -242,6 +242,7 @@ public InnerTableRead withFilter(Predicate predicate) {
                                 }
                             },
                             (Predicate p) -> {
+                                schemaIds.clear();
                                 schemaIds = null;
                             });
                 }

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
@@ -243,6 +243,7 @@ public InnerTableRead withFilter(Predicate predicate) {
                                 }
                             },
                             (Predicate p) -> {
+                                snapshotIds.clear();
                                 snapshotIds = null;
                             });
                 }

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
@@ -251,6 +251,7 @@ public RecordReader<InternalRow> createReader(Split split) {
                                     }
                                 },
                                 (Predicate p) -> {
+                                    predicateMap.clear();
                                     predicateMap = null;
                                 });
                     }
-Original file line number
+Diff line change
@@ Expand Up / @@ -242,6 +242,7 @@ public InnerTableRead withFilter(Predicate predicate) { @@
                                     }
                                 },
                                 (Predicate p) -> {
+                                    schemaIds.clear();
                                     schemaIds = null;
                                 });
                     }
@@ Expand Down @@