(fluss) branch main updated: [test] Improve testing time for FlinkRecordEmitterTest by removing unnecessary FlinkTestBase dependency (#2533)

[jark]

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

jark 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 fd82007c8 [test] Improve testing time for FlinkRecordEmitterTest by 
removing unnecessary FlinkTestBase dependency (#2533)
fd82007c8 is described below

commit fd82007c89274e921b9e09801475e258f9be9c72
Author: Jark Wu <j...@apache.org>
AuthorDate: Sat Jan 31 22:25:11 2026 +0800

    [test] Improve testing time for FlinkRecordEmitterTest by removing 
unnecessary FlinkTestBase dependency (#2533)
---
 .../fluss/flink/source/emitter/FlinkRecordEmitterTest.java | 14 +++-----------
 1 file changed, 3 insertions(+), 11 deletions(-)

diff --git 
a/fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/source/emitter/FlinkRecordEmitterTest.java
 
b/fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/source/emitter/FlinkRecordEmitterTest.java
index 6868fcff3..d2a647d04 100644
--- 
a/fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/source/emitter/FlinkRecordEmitterTest.java
+++ 
b/fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/source/emitter/FlinkRecordEmitterTest.java
@@ -25,11 +25,9 @@ import 
org.apache.fluss.flink.source.split.HybridSnapshotLogSplit;
 import org.apache.fluss.flink.source.split.HybridSnapshotLogSplitState;
 import org.apache.fluss.flink.source.testutils.Order;
 import org.apache.fluss.flink.source.testutils.OrderDeserializationSchema;
-import org.apache.fluss.flink.utils.FlinkTestBase;
 import org.apache.fluss.flink.utils.FlussRowToFlinkRowConverter;
 import org.apache.fluss.metadata.Schema;
 import org.apache.fluss.metadata.TableBucket;
-import org.apache.fluss.metadata.TableDescriptor;
 import org.apache.fluss.record.ChangeType;
 import org.apache.fluss.types.DataType;
 import org.apache.fluss.types.DataTypes;
@@ -47,11 +45,11 @@ import static org.apache.fluss.testutils.DataTestUtils.row;
 import static org.assertj.core.api.Assertions.assertThat;
 
 /** Tests for {@link FlinkRecordEmitter} with RowData output type. */
-public class FlinkRecordEmitterTest extends FlinkTestBase {
+public class FlinkRecordEmitterTest {
     @Test
     void testEmitRowDataRecordWithHybridSplitInSnapshotPhase() throws 
Exception {
         // Setup
-        long tableId = createTable(DEFAULT_TABLE_PATH, 
DEFAULT_PK_TABLE_DESCRIPTOR);
+        long tableId = 1L;
 
         TableBucket bucket0 = new TableBucket(tableId, 0);
 
@@ -103,13 +101,7 @@ public class FlinkRecordEmitterTest extends FlinkTestBase {
                         .column("address", DataTypes.STRING())
                         .build();
 
-        TableDescriptor tableDescriptor =
-                TableDescriptor.builder()
-                        .schema(tableSchema)
-                        .distributedBy(DEFAULT_BUCKET_NUM, "orderId")
-                        .build();
-
-        long tableId = createTable(DEFAULT_TABLE_PATH, tableDescriptor);
+        long tableId = 1L;
 
         TableBucket bucket0 = new TableBucket(tableId, 0);