[ci] Fix CI unstable for TableManagerITCase#testPartitionedTableManag…

…ement
alibaba · Dec 13, 2024 · b9b83e3 · b9b83e3
1 parent 246cdc5
commit b9b83e3
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/fluss-client/src/test/java/com/alibaba/fluss/client/admin/FlussAdminITCase.java b/fluss-client/src/test/java/com/alibaba/fluss/client/admin/FlussAdminITCase.java
@@ -80,7 +80,7 @@ class FlussAdminITCase extends ClientToServerITCaseBase {
             TableDescriptor.builder()
                     .schema(DEFAULT_SCHEMA)
                     .comment("test table")
-                    .distributedBy(10, "id")
+                    .distributedBy(3, "id")
                     .property(ConfigOptions.TABLE_LOG_TTL, Duration.ofDays(1))
                     .customProperty("connector", "fluss")
                     .build();
@@ -350,7 +350,7 @@ void testListPartitionInfos() throws Exception {
                                         .column("pt", DataTypes.STRING())
                                         .build())
                         .comment("test table")
-                        .distributedBy(10, "id")
+                        .distributedBy(3, "id")
                         .partitionedBy("pt")
                         .property(ConfigOptions.TABLE_AUTO_PARTITION_ENABLED, true)
                         .property(

diff --git a/fluss-server/src/test/java/com/alibaba/fluss/server/coordinator/TableManagerITCase.java b/fluss-server/src/test/java/com/alibaba/fluss/server/coordinator/TableManagerITCase.java
@@ -649,7 +649,7 @@ private static TableDescriptor.Builder newPartitionedTableBuilder(
         return TableDescriptor.builder()
                 .schema(builder.build())
                 .comment("partitioned table")
-                .distributedBy(16)
+                .distributedBy(3)
                 .partitionedBy("dt")
                 .property(ConfigOptions.TABLE_AUTO_PARTITION_ENABLED.key(), "true")
                 .property(
@@ -662,7 +662,7 @@ private static TableDescriptor newTable() {
         return TableDescriptor.builder()
                 .schema(newSchema())
                 .comment("first table")
-                .distributedBy(16, "a")
+                .distributedBy(3, "a")
                 .build();
     }