[incubator-seatunnel] branch dev updated: [Hotfix][Zeta] Fix LogicalDagGeneratorTest testcase (#4401)

[gaojun2048]

This is an automated email from the ASF dual-hosted git repository.

gaojun2048 pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new 39dbe21a2 [Hotfix][Zeta] Fix LogicalDagGeneratorTest testcase (#4401)
39dbe21a2 is described below

commit 39dbe21a2f3bdbb1d47fb30b69f7524edbc2d240
Author: hailin0 <wanghai...@apache.org>
AuthorDate: Thu Mar 23 12:06:07 2023 +0800

    [Hotfix][Zeta] Fix LogicalDagGeneratorTest testcase (#4401)
---
 .../org/apache/seatunnel/engine/core/parse/JobConfigParser.java   | 3 ++-
 .../seatunnel/engine/core/parse/MultipleTableJobConfigParser.java | 8 ++++++--
 2 files changed, 8 insertions(+), 3 deletions(-)

diff --git 
a/seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/parse/JobConfigParser.java
 
b/seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/parse/JobConfigParser.java
index 9b6812763..d81de1702 100644
--- 
a/seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/parse/JobConfigParser.java
+++ 
b/seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/parse/JobConfigParser.java
@@ -49,6 +49,7 @@ import java.net.URL;
 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 class JobConfigParser {
                     inputVertices.stream()
                             .flatMap(Collection::stream)
                             .map(Tuple2::_2)
-                            .collect(Collectors.toSet());
+                            
.collect(Collectors.toCollection(LinkedHashSet::new));
             checkProducedTypeEquals(inputActions);
             SinkAction<?, ?, ?, ?> sinkAction =
                     parseSink(
diff --git 
a/seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/parse/MultipleTableJobConfigParser.java
 
b/seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/parse/MultipleTableJobConfigParser.java
index 8777a9228..ad77a0a05 100644
--- 
a/seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/parse/MultipleTableJobConfigParser.java
+++ 
b/seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/parse/MultipleTableJobConfigParser.java
@@ -74,6 +74,7 @@ import java.util.Collection;
 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 @@ public class MultipleTableJobConfigParser {
                         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 @@ public class MultipleTableJobConfigParser {
                     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 =