nit

Author: xx789633

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

@@ -28,7 +28,7 @@
 import org.junit.jupiter.api.BeforeAll;
 import org.junit.jupiter.api.Test;
 
-import java.util.ArrayList;
+import java.util.Arrays;
 import java.util.List;
 
 import static org.apache.fluss.testutils.DataTestUtils.row;
@@ -55,32 +55,26 @@ void testLogTableCompaction() throws Exception {
             long t1Id = createLogTable(t1, true);
             TableBucket t1Bucket = new TableBucket(t1Id, 0);
 
-            writeTableRecords(t1, t1Bucket, 1, 3, 3);
+            int i = 0;
+            writeLogTableRecords(t1, t1Bucket, ++i);
 
-            writeTableRecords(t1, t1Bucket, 4, 6, 6);
+            writeLogTableRecords(t1, t1Bucket, ++i);
 
-            writeTableRecords(t1, t1Bucket, 7, 9, 9);
+            writeLogTableRecords(t1, t1Bucket, ++i);
             checkFileCountInIcebergTable(t1, 3);
 
             // trigger compaction
-            writeTableRecords(t1, t1Bucket, 10, 12, 12);
+            writeLogTableRecords(t1, t1Bucket, ++i);
             checkFileCountInIcebergTable(t1, 2);
         } finally {
             jobClient.cancel().get();
         }
     }
 
-    private void writeTableRecords(
-            TablePath tablePath,
-            TableBucket tableBucket,
-            int from,
-            int to,
-            long expectedLogEndOffset)
+    private void writeLogTableRecords(
+            TablePath tablePath, TableBucket tableBucket, long expectedLogEndOffset)
             throws Exception {
-        List<InternalRow> rows = new ArrayList<>();
-        for (int i = from; i <= to; i++) {
-            rows.add(row(i, "v" + i));
-        }
+        List<InternalRow> rows = Arrays.asList(row(1, "v1"));
         writeRows(tablePath, rows, true);
         assertReplicaStatus(tableBucket, expectedLogEndOffset);
     }