This is an automated email from the ASF dual-hosted git repository.
peacewong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/linkis.git
The following commit(s) were added to refs/heads/master by this push:
new b1c77a9de seatunnel once job test upgrade seatunnel-2.3.1 (#4780)
b1c77a9de is described below
commit b1c77a9deb27c9988dc3c9aee79ffd75c40e37e3
Author: xiutao <[email protected]>
AuthorDate: Tue Jul 18 12:06:03 2023 +0800
seatunnel once job test upgrade seatunnel-2.3.1 (#4780)
Co-authored-by: shixiutao <[email protected]>
---
.../computation/client/SeatunnelOnceJobTest.java | 18 ++++++++++++------
1 file changed, 12 insertions(+), 6 deletions(-)
diff --git
a/linkis-computation-governance/linkis-client/linkis-computation-client/src/test/java/org/apache/linkis/computation/client/SeatunnelOnceJobTest.java
b/linkis-computation-governance/linkis-client/linkis-computation-client/src/test/java/org/apache/linkis/computation/client/SeatunnelOnceJobTest.java
index fea472708..129183f78 100644
---
a/linkis-computation-governance/linkis-client/linkis-computation-client/src/test/java/org/apache/linkis/computation/client/SeatunnelOnceJobTest.java
+++
b/linkis-computation-governance/linkis-client/linkis-computation-client/src/test/java/org/apache/linkis/computation/client/SeatunnelOnceJobTest.java
@@ -34,10 +34,16 @@ public class SeatunnelOnceJobTest {
+ "}\n"
+ "\n"
+ "source {\n"
- + " Fake {\n"
- + " result_table_name = \"my_dataset\"\n"
- + " }\n"
- + "\n"
+ + " FakeSource {\n"
+ + " result_table_name = \"fake\"\n"
+ + " row.num = 16\n"
+ + " schema = {\n"
+ + " fields {\n"
+ + " name = \"string\"\n"
+ + " age = \"int\"\n"
+ + " }\n"
+ + " }\n"
+ + " }\n"
+ "}\n"
+ "\n"
+ "transform {\n"
@@ -52,12 +58,12 @@ public class SeatunnelOnceJobTest {
.builder()
.setCreateService("seatunnel-Test")
.setMaxSubmitTime(300000)
- .addLabel(LabelKeyUtils.ENGINE_TYPE_LABEL_KEY(), "seatunnel-2.1.2")
+ .addLabel(LabelKeyUtils.ENGINE_TYPE_LABEL_KEY(), "seatunnel-2.3.1")
.addLabel(LabelKeyUtils.USER_CREATOR_LABEL_KEY(),
"hadoop-seatunnel")
.addLabel(LabelKeyUtils.ENGINE_CONN_MODE_LABEL_KEY(), "once")
.addStartupParam(Configuration.IS_TEST_MODE().key(), true)
.addExecuteUser("hadoop")
- .addJobContent("runType", "spark")
+ .addJobContent("runType", "sspark")
.addJobContent("code", code)
.addJobContent("master", "local[4]")
.addJobContent("deploy-mode", "client")
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
