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/seatunnel.git
The following commit(s) were added to refs/heads/dev by this push:
new 460e73ec36 [E2E] Enable fakesource e2e of spark/flink (#7325)
460e73ec36 is described below
commit 460e73ec36f1afac42c36320fb79a47a45bfc823
Author: hailin0 <[email protected]>
AuthorDate: Wed Aug 7 12:44:24 2024 +0800
[E2E] Enable fakesource e2e of spark/flink (#7325)
---
.../org/apache/seatunnel/e2e/connector/fake/FakeWithSchemaTT.java | 6 ------
.../apache/seatunnel/e2e/connector/fake/FakeWithTableNamesTT.java | 6 ------
2 files changed, 12 deletions(-)
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-fake-e2e/src/test/java/org/apache/seatunnel/e2e/connector/fake/FakeWithSchemaTT.java
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-fake-e2e/src/test/java/org/apache/seatunnel/e2e/connector/fake/FakeWithSchemaTT.java
index b81bb7b620..e7628d7b5d 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-fake-e2e/src/test/java/org/apache/seatunnel/e2e/connector/fake/FakeWithSchemaTT.java
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-fake-e2e/src/test/java/org/apache/seatunnel/e2e/connector/fake/FakeWithSchemaTT.java
@@ -18,9 +18,7 @@
package org.apache.seatunnel.e2e.connector.fake;
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.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.TestTemplate;
@@ -28,10 +26,6 @@ import org.testcontainers.containers.Container;
import java.io.IOException;
-@DisabledOnContainer(
- value = {},
- type = {EngineType.SPARK, EngineType.FLINK},
- disabledReason = "Currently SPARK and FLINK do not support
CatalogTable")
public class FakeWithSchemaTT extends TestSuiteBase {
@TestTemplate
public void testFakeConnector(TestContainer container)
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-fake-e2e/src/test/java/org/apache/seatunnel/e2e/connector/fake/FakeWithTableNamesTT.java
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-fake-e2e/src/test/java/org/apache/seatunnel/e2e/connector/fake/FakeWithTableNamesTT.java
index 50e58b1ae3..50b82b346e 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-fake-e2e/src/test/java/org/apache/seatunnel/e2e/connector/fake/FakeWithTableNamesTT.java
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-fake-e2e/src/test/java/org/apache/seatunnel/e2e/connector/fake/FakeWithTableNamesTT.java
@@ -18,9 +18,7 @@
package org.apache.seatunnel.e2e.connector.fake;
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.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.TestTemplate;
@@ -28,10 +26,6 @@ import org.testcontainers.containers.Container;
import java.io.IOException;
-@DisabledOnContainer(
- value = {},
- type = {EngineType.SPARK, EngineType.FLINK},
- disabledReason = "Currently SPARK and FLINK do not support
CatalogTable")
public class FakeWithTableNamesTT extends TestSuiteBase {
@TestTemplate
public void testFakeConnector(TestContainer container)
