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 87b9f1bbeb4ee276e4809b1327003b18028913ce Author: Hang Ruan <ruanhang1...@hotmail.com> AuthorDate: Thu Jan 27 16:57:27 2022 +0800 [FLINK-25840][tests] Add semantics test support for connector test framework This closes #18547 --- .../apache/flink/tests/util/pulsar/PulsarSourceOrderedE2ECase.java | 6 ++++++ .../flink/tests/util/pulsar/PulsarSourceUnorderedE2ECase.java | 6 ++++++ 2 files changed, 12 insertions(+) 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 8641f50..7d22e80 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 @@ -23,7 +23,9 @@ import org.apache.flink.connector.pulsar.testutils.PulsarTestEnvironment; import org.apache.flink.connector.testframe.junit.annotations.TestContext; import org.apache.flink.connector.testframe.junit.annotations.TestEnv; import org.apache.flink.connector.testframe.junit.annotations.TestExternalSystem; +import org.apache.flink.connector.testframe.junit.annotations.TestSemantics; import org.apache.flink.connector.testframe.testsuites.SourceTestSuiteBase; +import org.apache.flink.streaming.api.CheckpointingMode; 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; @@ -36,6 +38,10 @@ import static org.apache.flink.connector.pulsar.testutils.runtime.PulsarRuntime. */ public class PulsarSourceOrderedE2ECase extends SourceTestSuiteBase<String> { + // Defines the Semantic. + @TestSemantics + CheckpointingMode[] semantics = new CheckpointingMode[] {CheckpointingMode.EXACTLY_ONCE}; + // Defines TestEnvironment. @TestEnv FlinkContainerWithPulsarEnvironment flink = new FlinkContainerWithPulsarEnvironment(1, 6); 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 4351147..d14d8f9 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 @@ -23,6 +23,8 @@ import org.apache.flink.connector.pulsar.testutils.PulsarTestEnvironment; import org.apache.flink.connector.testframe.junit.annotations.TestContext; import org.apache.flink.connector.testframe.junit.annotations.TestEnv; import org.apache.flink.connector.testframe.junit.annotations.TestExternalSystem; +import org.apache.flink.connector.testframe.junit.annotations.TestSemantics; +import org.apache.flink.streaming.api.CheckpointingMode; import org.apache.flink.tests.util.pulsar.cases.KeySharedSubscriptionContext; import org.apache.flink.tests.util.pulsar.cases.SharedSubscriptionContext; import org.apache.flink.tests.util.pulsar.common.FlinkContainerWithPulsarEnvironment; @@ -36,6 +38,10 @@ import static org.apache.flink.connector.pulsar.testutils.runtime.PulsarRuntime. */ public class PulsarSourceUnorderedE2ECase extends UnorderedSourceTestSuiteBase<String> { + // Defines the Semantic. + @TestSemantics + CheckpointingMode[] semantics = new CheckpointingMode[] {CheckpointingMode.EXACTLY_ONCE}; + // Defines TestEnvironment. @TestEnv FlinkContainerWithPulsarEnvironment flink = new FlinkContainerWithPulsarEnvironment(1, 8);