You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ma...@apache.org on 2022/12/12 18:33:23 UTC
[flink-connector-pulsar] 06/27: [FLINK-25210][pulsar][e2e][tests] add resource file to test jar
This is an automated email from the ASF dual-hosted git repository.
martijnvisser pushed a commit to branch v3.0
in repository https://gitbox.apache.org/repos/asf/flink-connector-pulsar.git
commit cd8da45d69450d7bb357fdb3fe35a5c748105651
Author: Yufei Zhang <af...@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.