fix tests

apache · Jul 30, 2024 · 4aefced · 4aefced
1 parent 794bb6a
commit 4aefced
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/...n-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/CatalogTableITCase.java b/...n-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/CatalogTableITCase.java
@@ -18,6 +18,7 @@
 
 package org.apache.paimon.flink;
 
+import org.apache.paimon.Snapshot;
 import org.apache.paimon.catalog.Catalog;
 import org.apache.paimon.table.system.AllTableOptionsTable;
 import org.apache.paimon.table.system.CatalogOptionsTable;
@@ -880,6 +881,7 @@ public void testReadOptimizedTable() {
         innerTestReadOptimizedTable();
 
         sql("DROP TABLE T");
+        Snapshot.CACHE.invalidateAll();
         sql("CREATE TABLE T (k INT, v INT, PRIMARY KEY (k) NOT ENFORCED) WITH ('bucket' = '-1')");
         innerTestReadOptimizedTable();
     }

diff --git a/...src/test/java/org/apache/paimon/flink/action/SortCompactActionForUnawareBucketITCase.java b/...src/test/java/org/apache/paimon/flink/action/SortCompactActionForUnawareBucketITCase.java
@@ -18,6 +18,7 @@
 
 package org.apache.paimon.flink.action;
 
+import org.apache.paimon.Snapshot;
 import org.apache.paimon.catalog.Identifier;
 import org.apache.paimon.data.BinaryString;
 import org.apache.paimon.data.Decimal;
@@ -311,6 +312,7 @@ public void testRandomSuffixWorks() throws Exception {
         Assertions.assertThat(files.size()).isEqualTo(3);
 
         dropTable();
+        Snapshot.CACHE.invalidateAll();
         prepareSameData(200);
         Assertions.assertThatCode(() -> zorder(Arrays.asList("f1", "f2")))
                 .doesNotThrowAnyException();