You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@seatunnel.apache.org by le...@apache.org on 2022/01/20 01:06:42 UTC
[incubator-seatunnel] branch dev updated: [Improve][seatunnel-core] Remove useless parameters (#1107)
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 286cd2f [Improve][seatunnel-core] Remove useless parameters (#1107)
286cd2f is described below
commit 286cd2f1e6de2bd6b57f3cef3f27a41ea5c231ba
Author: wuchunfu <31...@qq.com>
AuthorDate: Thu Jan 20 09:06:37 2022 +0800
[Improve][seatunnel-core] Remove useless parameters (#1107)
---
.../src/main/java/org/apache/seatunnel/Seatunnel.java | 2 +-
.../src/main/java/org/apache/seatunnel/SeatunnelFlink.java | 2 +-
.../src/main/java/org/apache/seatunnel/SeatunnelSpark.java | 2 +-
.../main/java/org/apache/seatunnel/example/flink/LocalFlinkExample.java | 2 +-
.../main/java/org/apache/seatunnel/example/spark/LocalSparkExample.java | 2 +-
5 files changed, 5 insertions(+), 5 deletions(-)
diff --git a/seatunnel-core/seatunnel-core-base/src/main/java/org/apache/seatunnel/Seatunnel.java b/seatunnel-core/seatunnel-core-base/src/main/java/org/apache/seatunnel/Seatunnel.java
index 1a89be0..f28203e 100644
--- a/seatunnel-core/seatunnel-core-base/src/main/java/org/apache/seatunnel/Seatunnel.java
+++ b/seatunnel-core/seatunnel-core-base/src/main/java/org/apache/seatunnel/Seatunnel.java
@@ -48,7 +48,7 @@ import java.util.Optional;
public class Seatunnel {
private static final Logger LOGGER = LoggerFactory.getLogger(Seatunnel.class);
- public static void run(CommandLineArgs commandLineArgs, Engine engine, String[] args) {
+ public static void run(CommandLineArgs commandLineArgs, Engine engine) {
Common.setDeployMode(commandLineArgs.getDeployMode());
String configFilePath = getConfigFilePath(commandLineArgs, engine);
boolean testConfig = commandLineArgs.isTestConfig();
diff --git a/seatunnel-core/seatunnel-core-flink/src/main/java/org/apache/seatunnel/SeatunnelFlink.java b/seatunnel-core/seatunnel-core-flink/src/main/java/org/apache/seatunnel/SeatunnelFlink.java
index c6c3863..28148a5 100644
--- a/seatunnel-core/seatunnel-core-flink/src/main/java/org/apache/seatunnel/SeatunnelFlink.java
+++ b/seatunnel-core/seatunnel-core-flink/src/main/java/org/apache/seatunnel/SeatunnelFlink.java
@@ -26,7 +26,7 @@ public class SeatunnelFlink {
public static void main(String[] args) {
CommandLineArgs flinkArgs = CommandLineUtils.parseFlinkArgs(args);
- Seatunnel.run(flinkArgs, FLINK, args);
+ Seatunnel.run(flinkArgs, FLINK);
}
}
diff --git a/seatunnel-core/seatunnel-core-spark/src/main/java/org/apache/seatunnel/SeatunnelSpark.java b/seatunnel-core/seatunnel-core-spark/src/main/java/org/apache/seatunnel/SeatunnelSpark.java
index 15e75fc..28e2927 100644
--- a/seatunnel-core/seatunnel-core-spark/src/main/java/org/apache/seatunnel/SeatunnelSpark.java
+++ b/seatunnel-core/seatunnel-core-spark/src/main/java/org/apache/seatunnel/SeatunnelSpark.java
@@ -26,7 +26,7 @@ public class SeatunnelSpark {
public static void main(String[] args) {
CommandLineArgs sparkArgs = CommandLineUtils.parseSparkArgs(args);
- Seatunnel.run(sparkArgs, SPARK, args);
+ Seatunnel.run(sparkArgs, SPARK);
}
}
diff --git a/seatunnel-examples/seatunnel-flink-examples/src/main/java/org/apache/seatunnel/example/flink/LocalFlinkExample.java b/seatunnel-examples/seatunnel-flink-examples/src/main/java/org/apache/seatunnel/example/flink/LocalFlinkExample.java
index 8675df7..1cd1f8b 100644
--- a/seatunnel-examples/seatunnel-flink-examples/src/main/java/org/apache/seatunnel/example/flink/LocalFlinkExample.java
+++ b/seatunnel-examples/seatunnel-flink-examples/src/main/java/org/apache/seatunnel/example/flink/LocalFlinkExample.java
@@ -29,7 +29,7 @@ public class LocalFlinkExample {
public static void main(String[] args) {
String configFile = getTestConfigFile("fake_to_console.conf");
CommandLineArgs flinkArgs = new CommandLineArgs(configFile, false);
- Seatunnel.run(flinkArgs, FLINK, args);
+ Seatunnel.run(flinkArgs, FLINK);
}
public static String getTestConfigFile(String configFile) {
diff --git a/seatunnel-examples/seatunnel-spark-examples/src/main/java/org/apache/seatunnel/example/spark/LocalSparkExample.java b/seatunnel-examples/seatunnel-spark-examples/src/main/java/org/apache/seatunnel/example/spark/LocalSparkExample.java
index 33c2b3a..ec03851 100644
--- a/seatunnel-examples/seatunnel-spark-examples/src/main/java/org/apache/seatunnel/example/spark/LocalSparkExample.java
+++ b/seatunnel-examples/seatunnel-spark-examples/src/main/java/org/apache/seatunnel/example/spark/LocalSparkExample.java
@@ -29,7 +29,7 @@ public class LocalSparkExample {
public static void main(String[] args) {
String configFile = getTestConfigFile("spark.batch.conf.template");
CommandLineArgs flinkArgs = new CommandLineArgs(configFile, false);
- Seatunnel.run(flinkArgs, SPARK, args);
+ Seatunnel.run(flinkArgs, SPARK);
}
public static String getTestConfigFile(String configFile) {