Merge branch 'master' into iceberg-1.7.0-upgrade

Author: j1wonpark

amoro-ams/src/test/java/org/apache/amoro/server/optimizing/flow/RandomRecordGenerator.java

@@ -33,6 +33,7 @@
 import java.time.LocalDate;
 import java.time.LocalDateTime;
 import java.time.OffsetDateTime;
+import java.time.ZoneOffset;
 import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.HashSet;
@@ -45,6 +46,12 @@
 
 public class RandomRecordGenerator {
 
+  private static final LocalDate BASE_DATE = LocalDate.of(2026, 1, 1);
+  private static final LocalDateTime BASE_LOCAL_DATE_TIME =
+      LocalDateTime.of(2026, 1, 1, 12, 0, 0, 123_456_000);
+  private static final OffsetDateTime BASE_OFFSET_DATE_TIME =
+      OffsetDateTime.of(BASE_LOCAL_DATE_TIME, ZoneOffset.UTC);
+
   private final Random random;
 
   private final Schema primary;
@@ -120,7 +127,6 @@ public List<Record> scatter(int[] primaries) {
 
   public Record randomRecord(int primaryValue) {
     Record record = GenericRecord.create(schema);
-    Random random = new Random();
     List<Types.NestedField> columns = schema.columns();
     Map<Integer, Object> partitionValue = null;
     if (partitionValues != null) {
@@ -148,7 +154,6 @@ public Record randomRecord(int primaryValue) {
 
   public Record randomRecord() {
     Record record = GenericRecord.create(schema);
-    Random random = new Random();
     List<Types.NestedField> columns = schema.columns();
     Map<Integer, Object> partitionValue = null;
     if (partitionValues != null) {
@@ -170,7 +175,7 @@ private Object generateObject(Type type) {
       case INTEGER:
         return random.nextInt();
       case STRING:
-        return UUID.randomUUID().toString();
+        return new UUID(random.nextLong(), random.nextLong()).toString();
       case LONG:
         return random.nextLong();
       case FLOAT:
@@ -180,13 +185,17 @@ private Object generateObject(Type type) {
       case BOOLEAN:
         return random.nextBoolean();
       case DATE:
-        return LocalDate.now().minusDays(random.nextInt(10000));
+        return BASE_DATE.minusDays(random.nextInt(10000));
       case TIMESTAMP:
         Types.TimestampType timestampType = (Types.TimestampType) type;
         if (timestampType.shouldAdjustToUTC()) {
-          return OffsetDateTime.now().minusDays(random.nextInt(10000));
+          return BASE_OFFSET_DATE_TIME
+              .minusDays(random.nextInt(10000))
+              .plusNanos(random.nextInt(1_000_000) * 1_000L);
         } else {
-          return LocalDateTime.now().minusDays(random.nextInt(10000));
+          return BASE_LOCAL_DATE_TIME
+              .minusDays(random.nextInt(10000))
+              .plusNanos(random.nextInt(1_000_000) * 1_000L);
         }
       case DECIMAL:
         Types.DecimalType decimalType = (Types.DecimalType) type;

amoro-ams/src/test/java/org/apache/amoro/server/optimizing/flow/TestKeyedContinuousOptimizing.java

@@ -48,6 +48,8 @@
 @RunWith(Parameterized.class)
 public class TestKeyedContinuousOptimizing extends TableTestBase {
 
+  private static final long DATA_SEED = 1L;
+
   @ClassRule public static TestHMS TEST_HMS = new TestHMS();
 
   public TestKeyedContinuousOptimizing(
@@ -102,7 +104,7 @@ public void run() throws Exception {
             partitionCount,
             primaryUpperBound,
             writeTargetFileSize,
-            null);
+            DATA_SEED);
 
     // init checker
     DataConcurrencyChecker dataConcurrencyChecker = new DataConcurrencyChecker(view);

amoro-ams/src/test/java/org/apache/amoro/server/optimizing/flow/TestUnKeyedContinuousOptimizing.java

@@ -48,6 +48,8 @@
 @RunWith(Parameterized.class)
 public class TestUnKeyedContinuousOptimizing extends TableTestBase {
 
+  private static final long DATA_SEED = 1L;
+
   @ClassRule public static TestHMS TEST_HMS = new TestHMS();
 
   public TestUnKeyedContinuousOptimizing(
@@ -97,7 +99,7 @@ public void run() throws Exception {
     // Need move file to hive scene
 
     UnKeyedTableDataView view =
-        new UnKeyedTableDataView(table, partitionCount, writeTargetFileSize, null);
+        new UnKeyedTableDataView(table, partitionCount, writeTargetFileSize, DATA_SEED);
 
     // init checker
     DataConcurrencyChecker dataConcurrencyChecker = new DataConcurrencyChecker(view);

amoro-common/pom.xml

@@ -194,6 +194,18 @@
                     </java>
                 </configuration>
             </plugin>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-checkstyle-plugin</artifactId>
+                <configuration>
+                    <excludes>src/main/gen-java/**</excludes>
+                </configuration>
+            </plugin>
+
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-surefire-plugin</artifactId>
+            </plugin>
         </plugins>
         <sourceDirectory>${basedir}/src/main/java</sourceDirectory>
     </build>