Changes the uidSuffix used in IceberSink uuid related tests

apache · Aug 26, 2024 · ebc0d79 · ebc0d79
1 parent 71f2893
commit ebc0d79
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/sink/TestIcebergSink.java b/flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/sink/TestIcebergSink.java
@@ -403,15 +403,15 @@ void testOperatorsUidNameWitUidSuffix() throws Exception {
         .tableSchema(SimpleDataUtil.FLINK_SCHEMA)
         .writeParallelism(parallelism)
         .distributionMode(DistributionMode.HASH)
-        .uidSuffix("mlpt-ingestion")
+        .uidSuffix("data-ingestion")
         .append();
 
     Transformation firstTransformation = env.getTransformations().get(0);
     Transformation secondTransformation = env.getTransformations().get(1);
-    assertThat(firstTransformation.getUid()).isEqualTo("Sink pre-writer mapper: mlpt-ingestion");
-    assertThat(firstTransformation.getName()).isEqualTo("Sink pre-writer mapper: mlpt-ingestion");
-    assertThat(secondTransformation.getUid()).isEqualTo("mlpt-ingestion");
-    assertThat(secondTransformation.getName()).isEqualTo("mlpt-ingestion");
+    assertThat(firstTransformation.getUid()).isEqualTo("Sink pre-writer mapper: data-ingestion");
+    assertThat(firstTransformation.getName()).isEqualTo("Sink pre-writer mapper: data-ingestion");
+    assertThat(secondTransformation.getUid()).isEqualTo("data-ingestion");
+    assertThat(secondTransformation.getName()).isEqualTo("data-ingestion");
   }
 
   private void testWriteRow(TableSchema tableSchema, DistributionMode distributionMode)