From c257d4fef68923f54d5dd9d105600979a01fe613 Mon Sep 17 00:00:00 2001 From: Anton Borisov Date: Mon, 13 Apr 2026 02:54:31 +0100 Subject: [PATCH] chore: fix main with Long[] -> int[] issue --- .../flink/source/FlinkTableSourceFilterPushDownTest.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/source/FlinkTableSourceFilterPushDownTest.java b/fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/source/FlinkTableSourceFilterPushDownTest.java index f8d972154b..66f3d29c27 100644 --- a/fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/source/FlinkTableSourceFilterPushDownTest.java +++ b/fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/source/FlinkTableSourceFilterPushDownTest.java @@ -242,7 +242,7 @@ void testLogTableRecordBatchFilterPushdown() { // Verify the predicate evaluates correctly against statistics. // Schema: id(INT), name(STRING), value(BIGINT), region(STRING) // Filter: region = 'HangZhou' AND value > 1000 - Long[] noNulls = new Long[] {0L, 0L, 0L, 0L}; + int[] noNulls = new int[] {0, 0, 0, 0}; // Batch with value range [2000, 5000] and region ['HangZhou', 'HangZhou'] // → should match @@ -312,7 +312,7 @@ void testLogTableRangeFilterPushdown() { // Verify the predicate actually evaluates correctly against statistics. // Schema: id(INT), name(STRING), value(BIGINT), region(STRING) // Filter: id > 3 AND id < 10 - Long[] noNulls = new Long[] {0L, 0L, 0L, 0L}; + int[] noNulls = new int[] {0, 0, 0, 0}; // Batch with id range [5, 8] → should match (5 > 3 is possible, 8 < 10 is possible) assertThat(