You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@seatunnel.apache.org by ki...@apache.org on 2022/03/30 10:57:07 UTC
[incubator-seatunnel] branch dev updated: [hotfix][seatunnel-spark-examples][#1614] lose default deploy mode value issue (#1615)
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 b0c0fe6 [hotfix][seatunnel-spark-examples][#1614] lose default deploy mode value issue (#1615)
b0c0fe6 is described below
commit b0c0fe682faa9a2d3a52cb76270cb07e478bdb5d
Author: KONENET <ko...@163.com>
AuthorDate: Wed Mar 30 18:57:01 2022 +0800
[hotfix][seatunnel-spark-examples][#1614] lose default deploy mode value issue (#1615)
---
.../main/java/org/apache/seatunnel/example/spark/LocalSparkExample.java | 2 ++
1 file changed, 2 insertions(+)
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 5fbf353..520fa2b 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
@@ -19,6 +19,7 @@ package org.apache.seatunnel.example.spark;
import org.apache.seatunnel.Seatunnel;
import org.apache.seatunnel.command.SparkCommandArgs;
+import org.apache.seatunnel.common.config.DeployMode;
public class LocalSparkExample {
@@ -30,6 +31,7 @@ public class LocalSparkExample {
sparkArgs.setConfigFile(configFile);
sparkArgs.setCheckConfig(false);
sparkArgs.setVariables(null);
+ sparkArgs.setDeployMode(DeployMode.CLIENT.getName());
Seatunnel.run(sparkArgs);
}