You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@seatunnel.apache.org by ty...@apache.org on 2022/10/06 06:52:43 UTC
[incubator-seatunnel] branch dev updated: [Engine][Example] Fix engine example can't run error (#2998)
This is an automated email from the ASF dual-hosted git repository.
tyrantlucifer 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 342c25c59 [Engine][Example] Fix engine example can't run error (#2998)
342c25c59 is described below
commit 342c25c59a706965913656577bf77307f5805222
Author: Hisoka <fa...@qq.com>
AuthorDate: Thu Oct 6 14:52:37 2022 +0800
[Engine][Example] Fix engine example can't run error (#2998)
* [Engine][Example] Fix engine example can't run error
* [Engine][Example] Fix engine example can't run error
---
seatunnel-examples/seatunnel-engine-examples/pom.xml | 11 ++++++++++-
.../src/main/resources/examples/fake_to_console.conf | 20 +++++++++++++++-----
2 files changed, 25 insertions(+), 6 deletions(-)
diff --git a/seatunnel-examples/seatunnel-engine-examples/pom.xml b/seatunnel-examples/seatunnel-engine-examples/pom.xml
index a0d952b2c..aa2b56994 100644
--- a/seatunnel-examples/seatunnel-engine-examples/pom.xml
+++ b/seatunnel-examples/seatunnel-engine-examples/pom.xml
@@ -33,6 +33,15 @@
<artifactId>seatunnel-starter</artifactId>
<version>${project.version}</version>
</dependency>
-
+ <dependency>
+ <groupId>org.apache.seatunnel</groupId>
+ <artifactId>connector-fake</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.seatunnel</groupId>
+ <artifactId>connector-console</artifactId>
+ <version>${project.version}</version>
+ </dependency>
</dependencies>
</project>
\ No newline at end of file
diff --git a/seatunnel-examples/seatunnel-engine-examples/src/main/resources/examples/fake_to_console.conf b/seatunnel-examples/seatunnel-engine-examples/src/main/resources/examples/fake_to_console.conf
index 404c9ec69..6b0599131 100644
--- a/seatunnel-examples/seatunnel-engine-examples/src/main/resources/examples/fake_to_console.conf
+++ b/seatunnel-examples/seatunnel-engine-examples/src/main/resources/examples/fake_to_console.conf
@@ -20,7 +20,7 @@
env {
# You can set engine configuration here
- execution.parallelism = 3
+ execution.parallelism = 1
job.mode = "BATCH"
execution.checkpoint.interval = 5000
#execution.checkpoint.data-uri = "hdfs://localhost:9000/checkpoint"
@@ -30,14 +30,24 @@ source {
# This is a example source plugin **only for test and demonstrate the feature source plugin**
FakeSource {
result_table_name = "fake"
- field_name = "name,age",
- parallelism = 2
+ parallelism = 1
+ schema = {
+ fields {
+ name = "string"
+ age = "int"
+ }
+ }
}
FakeSource {
result_table_name = "fake"
- field_name = "name,age",
- parallelism = 3
+ parallelism = 1
+ schema = {
+ fields {
+ name = "string"
+ age = "int"
+ }
+ }
}
}