This is an automated email from the ASF dual-hosted git repository.
martijnvisser pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-pulsar.git
commit 9046e81e5a93600d86a135826fd57ebd6f6172fb
Author: Yufei Zhang <affei...@gmail.com>
AuthorDate: Wed Dec 15 20:48:01 2021 +0800
[FLINK-25210][pulsar][e2e][tests] add resource file to test jar
---
.../org/apache/flink/tests/util/pulsar/PulsarSourceOrderedE2ECase.java | 3 ---
.../apache/flink/tests/util/pulsar/PulsarSourceUnorderedE2ECase.java | 3 ---
2 files changed, 6 deletions(-)
diff --git
a/flink-connector-pulsar-e2e-tests/src/test/java/org/apache/flink/tests/util/pulsar/PulsarSourceOrderedE2ECase.java
b/flink-connector-pulsar-e2e-tests/src/test/java/org/apache/flink/tests/util/pulsar/PulsarSourceOrderedE2ECase.java
index 95c1486..9a499e6 100644
---
a/flink-connector-pulsar-e2e-tests/src/test/java/org/apache/flink/tests/util/pulsar/PulsarSourceOrderedE2ECase.java
+++
b/flink-connector-pulsar-e2e-tests/src/test/java/org/apache/flink/tests/util/pulsar/PulsarSourceOrderedE2ECase.java
@@ -28,15 +28,12 @@ import
org.apache.flink.tests.util.pulsar.cases.ExclusiveSubscriptionContext;
import org.apache.flink.tests.util.pulsar.cases.FailoverSubscriptionContext;
import
org.apache.flink.tests.util.pulsar.common.FlinkContainerWithPulsarEnvironment;
-import org.junit.jupiter.api.Disabled;
-
import static
org.apache.flink.connector.pulsar.testutils.runtime.PulsarRuntime.container;
/**
* Pulsar E2E test based on connector testing framework. It's used for
Failover & Exclusive
* subscription.
*/
-@Disabled("FLINK-25210")
public class PulsarSourceOrderedE2ECase extends SourceTestSuiteBase<String> {
// Defines TestEnvironment.
diff --git
a/flink-connector-pulsar-e2e-tests/src/test/java/org/apache/flink/tests/util/pulsar/PulsarSourceUnorderedE2ECase.java
b/flink-connector-pulsar-e2e-tests/src/test/java/org/apache/flink/tests/util/pulsar/PulsarSourceUnorderedE2ECase.java
index c59831f..797c7b1 100644
---
a/flink-connector-pulsar-e2e-tests/src/test/java/org/apache/flink/tests/util/pulsar/PulsarSourceUnorderedE2ECase.java
+++
b/flink-connector-pulsar-e2e-tests/src/test/java/org/apache/flink/tests/util/pulsar/PulsarSourceUnorderedE2ECase.java
@@ -28,15 +28,12 @@ import
org.apache.flink.tests.util.pulsar.cases.SharedSubscriptionContext;
import
org.apache.flink.tests.util.pulsar.common.FlinkContainerWithPulsarEnvironment;
import org.apache.flink.tests.util.pulsar.common.UnorderedSourceTestSuiteBase;
-import org.junit.jupiter.api.Disabled;
-
import static
org.apache.flink.connector.pulsar.testutils.runtime.PulsarRuntime.container;
/**
* Pulsar E2E test based on connector testing framework. It's used for Shared
& Key_Shared
* subscription.
*/
-@Disabled("FLINK-25210")
public class PulsarSourceUnorderedE2ECase extends
UnorderedSourceTestSuiteBase<String> {
// Defines TestEnvironment.
