[incubator-seatunnel] branch dev updated: check config error (#2266)

[le...@apache.org]

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

leo65535 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 a134c0732 check config error (#2266)
a134c0732 is described below

commit a134c0732aec04b85d6894b927c31c0d293c6c5f
Author: Jared Li <lh...@gmail.com>
AuthorDate: Tue Jul 26 10:51:08 2022 +0800

    check config error (#2266)
    
    * [Improvement][core] StateT of SeaTunnelSource should extend `Serializable`
    ,so that `org.apache.seatunnel.api.source.SeaTunnelSource.getEnumeratorStateSerializer` can support a default implementation.
    This will be useful to each SeaTunnelSource subclass implementation.
    
    * repetitive dependency
    
    repetitive dependency
    
    * [Improvement][connector-v2] postgre jar should be contained in container like mysql-java, so it should be  provided, not compile
    
    * [Improvement][connector-v2] remove the code block in the implementation class to keep code clean.
    
    * [Improvement][connector-v2] remove unused import
    
    * [Improvement][connector-v2] modify import order
    
    * [bug][connector] check config error
    
    Co-authored-by: bjyflihongyu <li...@jd.com>
---
 .../apache/seatunnel/core/flink/command/FlinkApiTaskExecuteCommand.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/FlinkApiTaskExecuteCommand.java b/seatunnel-core/seatunnel-core-flink/src/main/java/org/apache/seatunnel/core/flink/command/FlinkApiTaskExecuteCommand.java
index f5f0cdf8c..ab9a35e82 100644
--- a/seatunnel-core/seatunnel-core-flink/src/main/java/org/apache/seatunnel/core/flink/command/FlinkApiTaskExecuteCommand.java
+++ b/seatunnel-core/seatunnel-core-flink/src/main/java/org/apache/seatunnel/core/flink/command/FlinkApiTaskExecuteCommand.java
@@ -71,7 +71,7 @@ public class FlinkApiTaskExecuteCommand extends BaseTaskExecuteCommand<FlinkComm
         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>,