[incubator-seatunnel] branch st-engine updated: [Engine][DAG] LogicalDagGenerator error (#2491)

[fanjia]

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

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


The following commit(s) were added to refs/heads/st-engine by this push:
     new fc671e59e [Engine][DAG] LogicalDagGenerator error (#2491)
fc671e59e is described below

commit fc671e59e1e8d1951420a3179ab64510e32ca951
Author: Zongwen Li <zongwen.li.t...@gmail.com>
AuthorDate: Mon Aug 22 13:35:02 2022 +0800

    [Engine][DAG] LogicalDagGenerator error (#2491)
---
 .../apache/seatunnel/engine/core/dag/logical/LogicalDagGenerator.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/dag/logical/LogicalDagGenerator.java
 
b/seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/dag/logical/LogicalDagGenerator.java
index f6209b9dc..cca39d04c 100644
--- 
a/seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/dag/logical/LogicalDagGenerator.java
+++ 
b/seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/dag/logical/LogicalDagGenerator.java
@@ -88,8 +88,8 @@ public class LogicalDagGenerator {
                 .stream()
                 .map(entry -> entry.getValue()
                         .stream()
-                        .map(upstreamId -> new 
LogicalEdge(logicalVertexMap.get(upstreamId),
-                                logicalVertexMap.get(entry.getKey())))
+                        .map(targetId -> new 
LogicalEdge(logicalVertexMap.get(entry.getKey()),
+                                logicalVertexMap.get(targetId)))
                         .collect(Collectors.toList()))
                 .flatMap(Collection::stream)
                 .collect(Collectors.toSet());