fix

apache · Nov 18, 2024 · 92baf51 · 92baf51
1 parent 67e8bbf
commit 92baf51
Showing 1 changed file with 14 additions and 2 deletions.
diff --git a/paimon-core/src/test/java/org/apache/paimon/table/PrimaryKeyColumnTypeFileDataTest.java b/paimon-core/src/test/java/org/apache/paimon/table/PrimaryKeyColumnTypeFileDataTest.java
@@ -46,6 +46,10 @@ public void testTableSplitFilterNormalFields() throws Exception {
         writeAndCheckFileResultForColumnType(
                 schemas -> {
                     FileStoreTable table = createFileStoreTable(schemas);
+                    /*
+                     * Changelog with key table doesn't support filter in value, it will scan all
+                     * data.
+                     */
                     Predicate predicate =
                             new PredicateBuilder(table.schema().logicalRowType())
                                     .between(6, 200L, 500L);
@@ -59,12 +63,17 @@ public void testTableSplitFilterNormalFields() throws Exception {
                     assertThat(getResult(table.newRead(), splits, fieldGetterList))
                             .containsExactlyInAnyOrder(
                                     "2|200|201|202.00|203|204|205|206.0|207.0|208|1970-07-29T00:00|210",
-                                    "2|300|301|302.00|303|304|305|306.0|307.0|308|1970-11-06T00:00|310");
+                                    "2|300|301|302.00|303|304|305|306.0|307.0|308|1970-11-06T00:00|310",
+                                    "1|100|101|102.00|103|104|105|106.0|107.0|108|1970-04-20T00:00|110");
                     return null;
                 },
                 (files, schemas) -> {
                     FileStoreTable table = createFileStoreTable(schemas);
 
+                    /*
+                     * Changelog with key table doesn't support filter in value, it will scan all
+                     * data.
+                     */
                     List<Split> splits =
                             toSplits(
                                     table.newSnapshotReader()
@@ -79,7 +88,10 @@ public void testTableSplitFilterNormalFields() throws Exception {
                             .containsExactlyInAnyOrder(
                                     "2|200|201|202.0|203|204.00|205.0|206.0|207.00|208|209|210",
                                     "2|300|301|302.0|303|304.00|305.0|306.0|307.00|308|309|310",
-                                    "2|400|401|402.0|403|404.00|405.0|406.0|407.00|408|409|410");
+                                    "2|400|401|402.0|403|404.00|405.0|406.0|407.00|408|409|410",
+                                    "1|100|101|102.0|103|104.00|105.0|106.0|107.00|108|109|110",
+                                    "1|500|501|502.0|503|504.00|505.0|506.0|507.00|508|509|510",
+                                    "1|600|601|602.0|603|604.00|605.0|606.0|607.00|608|609|610");
                 },
                 getPrimaryKeyNames(),
                 tableConfig,