[incubator-seatunnel] branch dev updated: fix: flink core cannot check source config.[bug] (#1909)

[kirs]

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

kirs 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 15f41bff fix: flink core cannot check source config.[bug] (#1909)
15f41bff is described below

commit 15f41bff082aaf547b2dceec3718e08c832fe7c8
Author: MoSence <jmhjm...@163.com>
AuthorDate: Wed May 18 17:58:55 2022 +0800

    fix: flink core cannot check source config.[bug] (#1909)
    
    Closes #1908
---
 .../apache/seatunnel/core/flink/command/FlinkTaskExecuteCommand.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/seatunnel-core/seatunnel-core-flink/src/main/java/org/apache/seatunnel/core/flink/command/FlinkTaskExecuteCommand.java
 
b/seatunnel-core/seatunnel-core-flink/src/main/java/org/apache/seatunnel/core/flink/command/FlinkTaskExecuteCommand.java
index 612d668e..92ce5208 100644
--- 
a/seatunnel-core/seatunnel-core-flink/src/main/java/org/apache/seatunnel/core/flink/command/FlinkTaskExecuteCommand.java
+++ 
b/seatunnel-core/seatunnel-core-flink/src/main/java/org/apache/seatunnel/core/flink/command/FlinkTaskExecuteCommand.java
@@ -70,7 +70,7 @@ public class FlinkTaskExecuteCommand extends 
BaseTaskExecuteCommand<FlinkCommand
         List<BaseSink<FlinkEnvironment>> sinks = executionContext.getSinks();
 
         checkPluginType(executionContext.getJobMode(), sources, transforms, 
sinks);
-        baseCheckConfig(sinks, transforms, sinks);
+        baseCheckConfig(sources, transforms, sinks);
         showAsciiLogo();
 
         try (Execution<BaseSource<FlinkEnvironment>,