You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@fluss.apache.org by yu...@apache.org on 2026/04/13 03:01:28 UTC
(fluss) branch main updated: chore: fix main with Long[] -> int[] issue (#3060)
This is an automated email from the ASF dual-hosted git repository.
yunhong pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/fluss.git
The following commit(s) were added to refs/heads/main by this push:
new 342e61032 chore: fix main with Long[] -> int[] issue (#3060)
342e61032 is described below
commit 342e6103279163deaa3511c4bc52925ea82df2aa
Author: Anton Borisov <14...@users.noreply.github.com>
AuthorDate: Mon Apr 13 04:01:23 2026 +0100
chore: fix main with Long[] -> int[] issue (#3060)
---
.../apache/fluss/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 f8d972154..66f3d29c2 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 @@ public class FlinkTableSourceFilterPushDownTest {
// 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 @@ public class FlinkTableSourceFilterPushDownTest {
// 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(