(fluss) 10/12: WIP

[jark]

This is an automated email from the ASF dual-hosted git repository.

jark pushed a commit to branch ci-rename-to-apache
in repository https://gitbox.apache.org/repos/asf/fluss.git

commit 89a426d78c3e018bc0a61a3ae236e6f7f996eebc
Author: Jark Wu <j...@apache.org>
AuthorDate: Mon Aug 25 15:02:36 2025 +0800

    WIP
---
 .../src/test/java/org/apache/fluss/predicate/PredicateTest.java         | 1 +
 .../src/test/java/org/apache/fluss/row/arrow/ArrowReaderWriterTest.java | 1 +
 .../src/test/java/org/apache/fluss/rpc/protocol/RequestChannelTest.java | 2 ++
 .../test/java/org/apache/fluss/server/kv/wal/ArrowWalBuilderTest.java   | 1 +
 4 files changed, 5 insertions(+)

diff --git 
a/fluss-common/src/test/java/org/apache/fluss/predicate/PredicateTest.java 
b/fluss-common/src/test/java/org/apache/fluss/predicate/PredicateTest.java
index ad04985d7..5899a4425 100644
--- a/fluss-common/src/test/java/org/apache/fluss/predicate/PredicateTest.java
+++ b/fluss-common/src/test/java/org/apache/fluss/predicate/PredicateTest.java
@@ -31,6 +31,7 @@ import java.util.List;
 import static org.apache.fluss.predicate.PredicateBuilderTest.test;
 import static org.apache.fluss.row.BinaryString.fromString;
 import static org.apache.fluss.testutils.DataTestUtils.row;
+import static org.assertj.core.api.Assertions.assertThat;
 
 /** Test for {@link Predicate}s. */
 public class PredicateTest {
diff --git 
a/fluss-common/src/test/java/org/apache/fluss/row/arrow/ArrowReaderWriterTest.java
 
b/fluss-common/src/test/java/org/apache/fluss/row/arrow/ArrowReaderWriterTest.java
index f94f147fe..cedaadcbd 100644
--- 
a/fluss-common/src/test/java/org/apache/fluss/row/arrow/ArrowReaderWriterTest.java
+++ 
b/fluss-common/src/test/java/org/apache/fluss/row/arrow/ArrowReaderWriterTest.java
@@ -49,6 +49,7 @@ import static org.apache.fluss.record.TestData.DATA1;
 import static org.apache.fluss.record.TestData.DATA1_ROW_TYPE;
 import static org.apache.fluss.testutils.DataTestUtils.row;
 import static org.apache.fluss.testutils.InternalRowAssert.assertThatRow;
+import static org.assertj.core.api.Assertions.assertThat;
 import static org.assertj.core.api.Assertions.assertThatThrownBy;
 
 /** Tests for {@link ArrowReader} and {@link ArrowWriter}. */
diff --git 
a/fluss-rpc/src/test/java/org/apache/fluss/rpc/protocol/RequestChannelTest.java 
b/fluss-rpc/src/test/java/org/apache/fluss/rpc/protocol/RequestChannelTest.java
index a76df2d2a..7509df095 100644
--- 
a/fluss-rpc/src/test/java/org/apache/fluss/rpc/protocol/RequestChannelTest.java
+++ 
b/fluss-rpc/src/test/java/org/apache/fluss/rpc/protocol/RequestChannelTest.java
@@ -31,6 +31,8 @@ import java.util.ArrayList;
 import java.util.List;
 import java.util.concurrent.CompletableFuture;
 
+import static org.assertj.core.api.Assertions.assertThat;
+
 /** The test for {@link RequestChannel}. */
 public class RequestChannelTest {
 
diff --git 
a/fluss-server/src/test/java/org/apache/fluss/server/kv/wal/ArrowWalBuilderTest.java
 
b/fluss-server/src/test/java/org/apache/fluss/server/kv/wal/ArrowWalBuilderTest.java
index 72e6441cd..16a079421 100644
--- 
a/fluss-server/src/test/java/org/apache/fluss/server/kv/wal/ArrowWalBuilderTest.java
+++ 
b/fluss-server/src/test/java/org/apache/fluss/server/kv/wal/ArrowWalBuilderTest.java
@@ -46,6 +46,7 @@ import static 
org.apache.fluss.record.TestData.DATA1_TABLE_ID_PK;
 import static org.apache.fluss.record.TestData.DEFAULT_SCHEMA_ID;
 import static 
org.apache.fluss.testutils.DataTestUtils.assertLogRecordsEqualsWithRowKind;
 import static org.apache.fluss.testutils.DataTestUtils.row;
+import static org.assertj.core.api.Assertions.assertThat;
 
 /** Test for {@link ArrowWalBuilder}. */
 class ArrowWalBuilderTest {