[Hotfix][Zeta] Fix LogicalDagGeneratorTest testcase (apache#4401)

ic4y · Mar 23, 2023 · 4bd0936 · 4bd0936
1 parent c6d84c6
commit 4bd0936
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 3 deletions.
diff --git a/...nel-engine-core/src/main/java/org/apache/seatunnel/engine/core/parse/JobConfigParser.java b/...nel-engine-core/src/main/java/org/apache/seatunnel/engine/core/parse/JobConfigParser.java
@@ -49,6 +49,7 @@
 import java.util.ArrayList;
 import java.util.Collection;
 import java.util.Collections;
+import java.util.LinkedHashSet;
 import java.util.List;
 import java.util.Set;
 import java.util.stream.Collectors;
@@ -136,7 +137,7 @@ public Tuple2<CatalogTable, Action> parseTransform(
                     inputVertices.stream()
                             .flatMap(Collection::stream)
                             .map(Tuple2::_2)
-                            .collect(Collectors.toSet());
+                            .collect(Collectors.toCollection(LinkedHashSet::new));
             checkProducedTypeEquals(inputActions);
             SinkAction<?, ?, ?, ?> sinkAction =
                     parseSink(

diff --git a/...re/src/main/java/org/apache/seatunnel/engine/core/parse/MultipleTableJobConfigParser.java b/...re/src/main/java/org/apache/seatunnel/engine/core/parse/MultipleTableJobConfigParser.java
@@ -74,6 +74,7 @@
 import java.util.Collections;
 import java.util.HashSet;
 import java.util.LinkedHashMap;
+import java.util.LinkedHashSet;
 import java.util.LinkedList;
 import java.util.List;
 import java.util.Map;
@@ -360,7 +361,10 @@ private void parseTransform(
                         factoryId,
                         (factory) -> factory.createTransform(null));
 
-        Set<Action> inputActions = inputs.stream().map(Tuple2::_2).collect(Collectors.toSet());
+        Set<Action> inputActions =
+                inputs.stream()
+                        .map(Tuple2::_2)
+                        .collect(Collectors.toCollection(LinkedHashSet::new));
         SeaTunnelDataType<?> expectedType = getProducedType(inputs.get(0)._2());
         checkProducedTypeEquals(inputActions);
         int spareParallelism = inputs.get(0)._2().getParallelism();
@@ -472,7 +476,7 @@ private static <T> T findLast(LinkedHashMap<?, T> map) {
                     inputVertices.stream()
                             .flatMap(Collection::stream)
                             .map(Tuple2::_2)
-                            .collect(Collectors.toSet());
+                            .collect(Collectors.toCollection(LinkedHashSet::new));
             checkProducedTypeEquals(inputActions);
             Tuple2<CatalogTable, Action> inputActionSample = inputVertices.get(0).get(0);
             SinkAction<?, ?, ?, ?> sinkAction =