fix bucket num

Author: xx789633

fluss-lake/fluss-lake-iceberg/src/test/java/org/apache/fluss/lake/iceberg/tiering/IcebergTieringTest.java

@@ -130,6 +130,7 @@ void testTieringWriteTable(boolean isPrimaryKeyTable, boolean isPartitionedTable
                                         .column("c2", DataTypes.STRING())
                                         .column("c3", DataTypes.STRING())
                                         .build())
+                        .distributedBy(BUCKET_NUM)
                         .property(ConfigOptions.TABLE_DATALAKE_ENABLED, true)
                         .build();
         TableInfo tableInfo = TableInfo.of(tablePath, 0, 1, descriptor, 1L, 1L);

fluss-lake/fluss-lake-lance/src/test/java/com/alibaba/fluss/lake/lance/tiering/LanceTieringTest.java

@@ -102,6 +102,7 @@ void testTieringWriteTable(boolean isPartitioned) throws Exception {
         TableDescriptor descriptor =
                 TableDescriptor.builder()
                         .schema(schema)
+                        .distributedBy(bucketNum)
                         .property(ConfigOptions.TABLE_DATALAKE_ENABLED, true)
                         .customProperties(customProperties)
                         .build();

fluss-lake/fluss-lake-paimon/src/test/java/org/apache/fluss/lake/paimon/tiering/PaimonTieringTest.java

@@ -129,6 +129,7 @@ void testTieringWriteTable(boolean isPrimaryKeyTable, boolean isPartitioned) thr
                                         .column("c2", org.apache.fluss.types.DataTypes.STRING())
                                         .column("c3", org.apache.fluss.types.DataTypes.STRING())
                                         .build())
+                        .distributedBy(bucketNum)
                         .property(ConfigOptions.TABLE_DATALAKE_ENABLED, true)
                         .build();
         TableInfo tableInfo = TableInfo.of(tablePath, 0, 1, descriptor, 1L, 1L);
@@ -257,6 +258,7 @@ void testMultiPartitionTiering() throws Exception {
                                         .column("year", org.apache.fluss.types.DataTypes.STRING())
                                         .build())
                         .partitionedBy("region", "year")
+                        .distributedBy(1)
                         .property(ConfigOptions.TABLE_DATALAKE_ENABLED, true)
                         .build();
         TableInfo tableInfo = TableInfo.of(tablePath, 0, 1, descriptor, 1L, 1L);
@@ -333,6 +335,7 @@ void testThreePartitionTiering() throws Exception {
                                         .column("month", org.apache.fluss.types.DataTypes.STRING())
                                         .build())
                         .partitionedBy("region", "year", "month")
+                        .distributedBy(1)
                         .property(ConfigOptions.TABLE_DATALAKE_ENABLED, true)
                         .build();
         TableInfo tableInfo = TableInfo.of(tablePath, 0, 1, descriptor, 1L, 1L);