nit

Author: xx789633

fluss-lake/fluss-lake-iceberg/src/test/java/org/apache/fluss/lake/iceberg/maintenance/IcebergRewriteITCase.java

@@ -59,7 +59,7 @@ void testCompaction() throws Exception {
         JobClient jobClient = buildTieringJob(execEnv);
         try {
             TablePath t1 = TablePath.of(DEFAULT_DB, "pkTable");
-            long t1Id = createPkTable(t1);
+            long t1Id = createPkTable(t1, true);
             TableBucket t1Bucket = new TableBucket(t1Id, 0);
 
             writeFullTypeRows(t1, t1Bucket, 1, 3, 3);

fluss-lake/fluss-lake-iceberg/src/test/java/org/apache/fluss/lake/iceberg/testutils/FlinkIcebergTieringTestBase.java

@@ -188,7 +188,12 @@ protected static Catalog getIcebergCatalog() {
     }
 
     protected long createPkTable(TablePath tablePath) throws Exception {
-        return createPkTable(tablePath, 1);
+        return createPkTable(tablePath, false);
+    }
+
+    protected long createPkTable(TablePath tablePath, boolean enableAutoCompaction)
+            throws Exception {
+        return createPkTable(tablePath, 1, enableAutoCompaction);
     }
 
     protected long createLogTable(TablePath tablePath) throws Exception {
@@ -221,8 +226,9 @@ protected long createLogTable(TablePath tablePath, int bucketNum, boolean isPart
         return createTable(tablePath, tableBuilder.build());
     }
 
-    protected long createPkTable(TablePath tablePath, int bucketNum) throws Exception {
-        TableDescriptor table1Descriptor =
+    protected long createPkTable(TablePath tablePath, int bucketNum, boolean enableAutoCompaction)
+            throws Exception {
+        TableDescriptor.Builder pkTableBuilder =
                 TableDescriptor.builder()
                         .schema(
                                 Schema.newBuilder()
@@ -249,10 +255,12 @@ protected long createPkTable(TablePath tablePath, int bucketNum) throws Exceptio
                                         .build())
                         .distributedBy(bucketNum)
                         .property(ConfigOptions.TABLE_DATALAKE_ENABLED.key(), "true")
-                        .property(ConfigOptions.TABLE_DATALAKE_FRESHNESS, Duration.ofMillis(500))
-                        .property(ConfigOptions.TABLE_DATALAKE_AUTO_COMPACTION.key(), "true")
-                        .build();
-        return createTable(tablePath, table1Descriptor);
+                        .property(ConfigOptions.TABLE_DATALAKE_FRESHNESS, Duration.ofMillis(500));
+
+        if (enableAutoCompaction) {
+            pkTableBuilder.property(ConfigOptions.TABLE_DATALAKE_AUTO_COMPACTION.key(), "true");
+        }
+        return createTable(tablePath, pkTableBuilder.build());
     }
 
     protected long createTable(TablePath tablePath, TableDescriptor tableDescriptor)