This is an automated email from the ASF dual-hosted git repository.
fanjia 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 b4e6f7891 [E2E] Enable Zeta E2E (#4267)
b4e6f7891 is described below
commit b4e6f78917d3e7179f765b308c8293033da16dbf
Author: Eric <[email protected]>
AuthorDate: Sat Mar 4 21:35:19 2023 +0800
[E2E] Enable Zeta E2E (#4267)
---
.../org/apache/seatunnel/engine/e2e/ClusterFaultToleranceIT.java | 5 -----
.../seatunnel/engine/e2e/ClusterFaultToleranceTwoPipelineIT.java | 6 ------
.../src/test/resources/hazelcast-client.yaml | 1 -
.../src/test/resources/log4j2-test.properties | 6 ++----
.../seatunnel-engine-common/src/main/resources/seatunnel.yaml | 2 +-
5 files changed, 3 insertions(+), 17 deletions(-)
diff --git
a/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/ClusterFaultToleranceIT.java
b/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/ClusterFaultToleranceIT.java
index 66c191fba..dc7514e1b 100644
---
a/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/ClusterFaultToleranceIT.java
+++
b/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/ClusterFaultToleranceIT.java
@@ -284,7 +284,6 @@ public class ClusterFaultToleranceIT {
@SuppressWarnings("checkstyle:RegexpSingleline")
@Test
- @Disabled
public void testBatchJobRestoreIn2NodeWorkerDown()
throws ExecutionException, InterruptedException {
String testCaseName = "testBatchJobRestoreIn2NodeWorkerDown";
@@ -383,7 +382,6 @@ public class ClusterFaultToleranceIT {
@SuppressWarnings("checkstyle:RegexpSingleline")
@Test
- @Disabled
public void testStreamJobRestoreIn2NodeWorkerDown()
throws ExecutionException, InterruptedException {
String testCaseName = "testStreamJobRestoreIn2NodeWorkerDown";
@@ -501,7 +499,6 @@ public class ClusterFaultToleranceIT {
@SuppressWarnings("checkstyle:RegexpSingleline")
@Test
- @Disabled
public void testBatchJobRestoreIn2NodeMasterDown()
throws ExecutionException, InterruptedException {
String testCaseName = "testBatchJobRestoreIn2NodeMasterDown";
@@ -601,7 +598,6 @@ public class ClusterFaultToleranceIT {
@SuppressWarnings("checkstyle:RegexpSingleline")
@Test
- @Disabled
public void testStreamJobRestoreIn2NodeMasterDown()
throws ExecutionException, InterruptedException {
String testCaseName = "testStreamJobRestoreIn2NodeMasterDown";
@@ -726,7 +722,6 @@ public class ClusterFaultToleranceIT {
@SuppressWarnings("checkstyle:RegexpSingleline")
@Test
- @Disabled
public void testStreamJobRestoreInAllNodeDown()
throws ExecutionException, InterruptedException {
String testCaseName = "testStreamJobRestoreInAllNodeDown";
diff --git
a/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/ClusterFaultToleranceTwoPipelineIT.java
b/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/ClusterFaultToleranceTwoPipelineIT.java
index 86c9729a2..108620aa3 100644
---
a/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/ClusterFaultToleranceTwoPipelineIT.java
+++
b/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/ClusterFaultToleranceTwoPipelineIT.java
@@ -71,7 +71,6 @@ public class ClusterFaultToleranceTwoPipelineIT {
@SuppressWarnings("checkstyle:RegexpSingleline")
@Test
- @Disabled
public void testTwoPipelineBatchJobRunOkIn2Node()
throws ExecutionException, InterruptedException {
String testCaseName = "testTwoPipelineBatchJobRunOkIn2Node";
@@ -201,7 +200,6 @@ public class ClusterFaultToleranceTwoPipelineIT {
@SuppressWarnings("checkstyle:RegexpSingleline")
@Test
- @Disabled
public void testTwoPipelineStreamJobRunOkIn2Node()
throws ExecutionException, InterruptedException {
String testCaseName = "testTwoPipelineStreamJobRunOkIn2Node";
@@ -299,7 +297,6 @@ public class ClusterFaultToleranceTwoPipelineIT {
@SuppressWarnings("checkstyle:RegexpSingleline")
@Test
- @Disabled
public void testTwoPipelineBatchJobRestoreIn2NodeWorkerDown()
throws ExecutionException, InterruptedException {
String testCaseName =
"testTwoPipelineBatchJobRestoreIn2NodeWorkerDown";
@@ -412,7 +409,6 @@ public class ClusterFaultToleranceTwoPipelineIT {
@SuppressWarnings("checkstyle:RegexpSingleline")
@Test
- @Disabled
public void testTwoPipelineStreamJobRestoreIn2NodeWorkerDown()
throws ExecutionException, InterruptedException {
String testCaseName =
"testTwoPipelineStreamJobRestoreIn2NodeWorkerDown";
@@ -538,7 +534,6 @@ public class ClusterFaultToleranceTwoPipelineIT {
@SuppressWarnings("checkstyle:RegexpSingleline")
@Test
- @Disabled
public void testTwoPipelineBatchJobRestoreIn2NodeMasterDown()
throws ExecutionException, InterruptedException {
String testCaseName =
"testTwoPipelineBatchJobRestoreIn2NodeMasterDown";
@@ -644,7 +639,6 @@ public class ClusterFaultToleranceTwoPipelineIT {
@SuppressWarnings("checkstyle:RegexpSingleline")
@Test
- @Disabled
public void testTwoPipelineStreamJobRestoreIn2NodeMasterDown()
throws ExecutionException, InterruptedException {
String testCaseName =
"testTwoPipelineStreamJobRestoreIn2NodeMasterDown";
diff --git
a/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/resources/hazelcast-client.yaml
b/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/resources/hazelcast-client.yaml
index 1834d9c94..f06e7e317 100644
---
a/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/resources/hazelcast-client.yaml
+++
b/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/resources/hazelcast-client.yaml
@@ -17,7 +17,6 @@
hazelcast-client:
cluster-name: seatunnel
-
network:
cluster-members:
- localhost:5801
diff --git
a/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/resources/log4j2-test.properties
b/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/resources/log4j2-test.properties
index d2e429647..0999f9487 100644
---
a/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/resources/log4j2-test.properties
+++
b/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/resources/log4j2-test.properties
@@ -21,10 +21,8 @@ rootLogger.level = INFO
rootLogger.appenderRef.consoleStdout.ref = consoleStdoutAppender
rootLogger.appenderRef.consoleStderr.ref = consoleStderrAppender
-logger.checkpoint.name=org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator
-logger.checkpoint.level=DEBUG
-logger.pipeline.name=org.apache.seatunnel.engine.server.scheduler.PipelineBaseScheduler
-logger.pipeline.level=DEBUG
+logger.zeta.name=org.apache.seatunnel.engine
+logger.zeta.level=DEBUG
appender.consoleStdout.name = consoleStdoutAppender
appender.consoleStdout.type = CONSOLE
diff --git
a/seatunnel-engine/seatunnel-engine-common/src/main/resources/seatunnel.yaml
b/seatunnel-engine/seatunnel-engine-common/src/main/resources/seatunnel.yaml
index 6b45331c5..17deb1b7f 100644
--- a/seatunnel-engine/seatunnel-engine-common/src/main/resources/seatunnel.yaml
+++ b/seatunnel-engine/seatunnel-engine-common/src/main/resources/seatunnel.yaml
@@ -33,4 +33,4 @@ seatunnel:
plugin-config:
namespace: /tmp/seatunnel/checkpoint_snapshot/
storage.type: hdfs
- fs.defaultFS: file:///tmp/ # Ensure that the directory has
written permission
+ fs.defaultFS: file:///tmp/
