nit

apache · Jan 9, 2024 · 42e2ac2 · 42e2ac2
1 parent 52572e8
commit 42e2ac2
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/flink/v1.18/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceSql.java b/flink/v1.18/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceSql.java
@@ -106,9 +106,9 @@ private List<Record> generateExpectedRecords(boolean ascending) throws Exception
     helper.appendToTable(dataFile1, dataFile2);
 
     // Expected records if the splits are ordered
-    //     - ascending (watermark from t1) - records from the split with early timestamps then
+    //     - ascending (watermark from t1) - records from the split with early timestamps, then
     // records from the split with late timestamps
-    //     - descending (watermark from t2) - records from the split with old longs then records
+    //     - descending (watermark from t2) - records from the split with old longs, then records
     // from the split with new longs
     List<Record> expected = Lists.newArrayList();
     if (ascending) {