[incubator-seatunnel] branch dev updated: [E2E] enabled rocketmq zeta e2e (#4711)

[ga...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

gaojun2048 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 a2145cfc0 [E2E] enabled rocketmq zeta e2e (#4711)
a2145cfc0 is described below

commit a2145cfc012a85ac356f5898e2a1812dbadc9c69
Author: Xiaojian Sun <su...@163.com>
AuthorDate: Tue May 9 10:39:52 2023 +0800

    [E2E] enabled rocketmq zeta e2e (#4711)
---
 .../org/apache/seatunnel/e2e/connector/rocketmq/RocketMqIT.java     | 6 ------
 1 file changed, 6 deletions(-)

diff --git a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-rocketmq-e2e/src/test/java/org/apache/seatunnel/e2e/connector/rocketmq/RocketMqIT.java b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-rocketmq-e2e/src/test/java/org/apache/seatunnel/e2e/connector/rocketmq/RocketMqIT.java
index 22fa19a43..f292d1120 100644
--- a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-rocketmq-e2e/src/test/java/org/apache/seatunnel/e2e/connector/rocketmq/RocketMqIT.java
+++ b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-rocketmq-e2e/src/test/java/org/apache/seatunnel/e2e/connector/rocketmq/RocketMqIT.java
@@ -37,9 +37,7 @@ import org.apache.seatunnel.connectors.seatunnel.rocketmq.exception.RocketMqConn
 import org.apache.seatunnel.connectors.seatunnel.rocketmq.serialize.DefaultSeaTunnelRowSerializer;
 import org.apache.seatunnel.e2e.common.TestResource;
 import org.apache.seatunnel.e2e.common.TestSuiteBase;
-import org.apache.seatunnel.e2e.common.container.EngineType;
 import org.apache.seatunnel.e2e.common.container.TestContainer;
-import org.apache.seatunnel.e2e.common.junit.DisabledOnContainer;
 import org.apache.seatunnel.engine.common.Constant;
 
 import org.apache.rocketmq.client.consumer.DefaultLitePullConsumer;
@@ -79,10 +77,6 @@ import java.util.UUID;
 import static org.apache.seatunnel.e2e.connector.rocketmq.RocketMqContainer.NAMESRV_PORT;
 
 @Slf4j
-@DisabledOnContainer(
-        value = {},
-        type = {EngineType.SEATUNNEL},
-        disabledReason = "There is some problem on Zeta Engine for RocketMQ e2e")
 public class RocketMqIT extends TestSuiteBase implements TestResource {
 
     private static final String IMAGE = "apache/rocketmq:4.9.4";