[incubator-seatunnel] branch st-engine updated: [Engine] [LogicalDAG] Remove useless set RowTypeInfo (#2737)

[gaojun2048]

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

gaojun2048 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 a5f452eeb [Engine] [LogicalDAG] Remove useless set RowTypeInfo (#2737)
a5f452eeb is described below

commit a5f452eebec02507c666c09350f844a17e8a6500
Author: Hisoka <fanjiaemi...@qq.com>
AuthorDate: Thu Sep 15 18:23:25 2022 +0800

    [Engine] [LogicalDAG] Remove useless set RowTypeInfo (#2737)
---
 seatunnel-connectors-v2/connector-file/connector-file-local/pom.xml  | 5 -----
 .../apache/seatunnel/engine/client/job/ConnectorInstanceLoader.java  | 1 -
 .../java/org/apache/seatunnel/engine/client/job/JobConfigParser.java | 4 ++--
 3 files changed, 2 insertions(+), 8 deletions(-)

diff --git 
a/seatunnel-connectors-v2/connector-file/connector-file-local/pom.xml 
b/seatunnel-connectors-v2/connector-file/connector-file-local/pom.xml
index 1ac5bb77b..d19f69e3a 100644
--- a/seatunnel-connectors-v2/connector-file/connector-file-local/pom.xml
+++ b/seatunnel-connectors-v2/connector-file/connector-file-local/pom.xml
@@ -35,11 +35,6 @@
             <artifactId>connector-file-base</artifactId>
             <version>${project.version}</version>
         </dependency>
-        <dependency>
-            <groupId>junit</groupId>
-            <artifactId>junit</artifactId>
-            <scope>test</scope>
-        </dependency>
         <dependency>
             <groupId>org.powermock</groupId>
             <artifactId>powermock-module-junit4</artifactId>
diff --git 
a/seatunnel-engine/seatunnel-engine-client/src/main/java/org/apache/seatunnel/engine/client/job/ConnectorInstanceLoader.java
 
b/seatunnel-engine/seatunnel-engine-client/src/main/java/org/apache/seatunnel/engine/client/job/ConnectorInstanceLoader.java
index 44f6aa4f5..e9756cb1c 100644
--- 
a/seatunnel-engine/seatunnel-engine-client/src/main/java/org/apache/seatunnel/engine/client/job/ConnectorInstanceLoader.java
+++ 
b/seatunnel-engine/seatunnel-engine-client/src/main/java/org/apache/seatunnel/engine/client/job/ConnectorInstanceLoader.java
@@ -78,7 +78,6 @@ public class ConnectorInstanceLoader {
         SeaTunnelSink<SeaTunnelRow, Serializable, Serializable, Serializable> 
seaTunnelSink =
             sinkPluginDiscovery.createPluginInstance(pluginIdentifier);
         seaTunnelSink.prepare(sinkConfig);
-        seaTunnelSink.setTypeInfo(null);
         seaTunnelSink.setJobContext(jobContext);
         return new ImmutablePair<>(seaTunnelSink, new 
HashSet<>(pluginJarPaths));
     }
diff --git 
a/seatunnel-engine/seatunnel-engine-client/src/main/java/org/apache/seatunnel/engine/client/job/JobConfigParser.java
 
b/seatunnel-engine/seatunnel-engine-client/src/main/java/org/apache/seatunnel/engine/client/job/JobConfigParser.java
index 0d19411d6..b1e5aa1fb 100644
--- 
a/seatunnel-engine/seatunnel-engine-client/src/main/java/org/apache/seatunnel/engine/client/job/JobConfigParser.java
+++ 
b/seatunnel-engine/seatunnel-engine-client/src/main/java/org/apache/seatunnel/engine/client/job/JobConfigParser.java
@@ -270,8 +270,6 @@ public class JobConfigParser {
                 pair.getRight());
         
sourceAction.setParallelism(getSourceParallelism(sourceConfigs.get(0)));
         SeaTunnelDataType dataType = 
sourceAction.getSource().getProducedType();
-        ImmutablePair<SeaTunnelSink<SeaTunnelRow, Serializable, Serializable, 
Serializable>, Set<URL>>
-            sinkListImmutablePair = 
ConnectorInstanceLoader.loadSinkInstance(sinkConfigs.get(0), 
jobConfig.getJobContext());
 
         Action sinkUpstreamAction = sourceAction;
 
@@ -294,6 +292,8 @@ public class JobConfigParser {
             sinkUpstreamAction = transformAction;
         }
 
+        ImmutablePair<SeaTunnelSink<SeaTunnelRow, Serializable, Serializable, 
Serializable>, Set<URL>>
+            sinkListImmutablePair = 
ConnectorInstanceLoader.loadSinkInstance(sinkConfigs.get(0), 
jobConfig.getJobContext());
         SinkAction sinkAction = createSinkAction(
             idGenerator.getNextId(),
             sinkListImmutablePair.getLeft().getPluginName(),