[Improve][Starter] Optimize code structure & remove redundant code (#…

…4525) * [Improve][Starter] Optimize code structure & remove redundant code * [Improve][Starter] Revert SeaTunnelApiExample * [Improve][Starter] Fix ci error
apache · Apr 9, 2023 · c24e399 · c24e399
1 parent e0aec5e
commit c24e399
Show file tree

Hide file tree

Showing 51 changed files with 187 additions and 1,878 deletions.
diff --git a/seatunnel-core/seatunnel-flink-starter/pom.xml b/seatunnel-core/seatunnel-flink-starter/pom.xml
@@ -35,6 +35,7 @@
     <modules>
         <module>seatunnel-flink-13-starter</module>
         <module>seatunnel-flink-15-starter</module>
+        <module>seatunnel-flink-starter-common</module>
     </modules>
 
     <properties>

diff --git a/seatunnel-core/seatunnel-flink-starter/seatunnel-flink-13-starter/pom.xml b/seatunnel-core/seatunnel-flink-starter/seatunnel-flink-13-starter/pom.xml
@@ -31,6 +31,18 @@
 
     <dependencies>
 
+        <dependency>
+            <groupId>org.apache.seatunnel</groupId>
+            <artifactId>seatunnel-flink-starter-common</artifactId>
+            <version>${project.version}</version>
+            <exclusions>
+                <exclusion>
+                    <groupId>*</groupId>
+                    <artifactId>*</artifactId>
+                </exclusion>
+            </exclusions>
+        </dependency>
+
         <!-- flink-translation -->
         <dependency>
             <groupId>org.apache.seatunnel</groupId>
@@ -66,7 +78,7 @@
             <groupId>org.apache.flink</groupId>
             <artifactId>flink-statebackend-rocksdb_${scala.binary.version}</artifactId>
             <version>${flink.1.13.6.version}</version>
-            <scope>provided</scope>
+            <scope>${flink.scope}</scope>
         </dependency>
 
     </dependencies>

diff --git a/seatunnel-core/seatunnel-flink-starter/seatunnel-flink-15-starter/pom.xml b/seatunnel-core/seatunnel-flink-starter/seatunnel-flink-15-starter/pom.xml
@@ -31,6 +31,12 @@
 
     <dependencies>
 
+        <dependency>
+            <groupId>org.apache.seatunnel</groupId>
+            <artifactId>seatunnel-flink-starter-common</artifactId>
+            <version>${revision}</version>
+        </dependency>
+
         <dependency>
             <groupId>org.apache.seatunnel</groupId>
             <artifactId>seatunnel-translation-flink-15</artifactId>

diff --git a/...-starter/src/main/java/org/apache/seatunnel/core/starter/flink/args/FlinkCommandArgs.java b/...-starter/src/main/java/org/apache/seatunnel/core/starter/flink/args/FlinkCommandArgs.java
diff --git a/...c/main/java/org/apache/seatunnel/core/starter/flink/command/FlinkConfValidateCommand.java b/...c/main/java/org/apache/seatunnel/core/starter/flink/command/FlinkConfValidateCommand.java
diff --git a/...rc/main/java/org/apache/seatunnel/core/starter/flink/command/FlinkTaskExecuteCommand.java b/...rc/main/java/org/apache/seatunnel/core/starter/flink/command/FlinkTaskExecuteCommand.java
diff --git a/...rg/apache/seatunnel/core/starter/flink/execution/FlinkAbstractPluginExecuteProcessor.java b/...rg/apache/seatunnel/core/starter/flink/execution/FlinkAbstractPluginExecuteProcessor.java