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 8de314deb821ef6ab763d32642c5896ef9a2db23 Author: Qingsheng Ren <renqs...@gmail.com> AuthorDate: Thu Oct 14 15:48:21 2021 +0800 [FLINK-25038][testutils] Refactor FlinkContainer to split JM and TMs to individual containers and supports HA --- .../org/apache/flink/tests/util/pulsar/PulsarSourceOrderedE2ECase.java | 3 ++- .../apache/flink/tests/util/pulsar/PulsarSourceUnorderedE2ECase.java | 3 ++- 2 files changed, 4 insertions(+), 2 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 1427c2b..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 @@ -42,7 +42,8 @@ public class PulsarSourceOrderedE2ECase extends SourceTestSuiteBase<String> { // Defines ConnectorExternalSystem. @ExternalSystem - PulsarTestEnvironment pulsar = new PulsarTestEnvironment(container(flink.getFlinkContainer())); + PulsarTestEnvironment pulsar = + new PulsarTestEnvironment(container(flink.getFlinkContainers().getJobManager())); // Defines a set of external context Factories for different test cases. @ExternalContextFactory 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 25cab21..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 @@ -42,7 +42,8 @@ public class PulsarSourceUnorderedE2ECase extends UnorderedSourceTestSuiteBase<S // Defines ConnectorExternalSystem. @ExternalSystem - PulsarTestEnvironment pulsar = new PulsarTestEnvironment(container(flink.getFlinkContainer())); + PulsarTestEnvironment pulsar = + new PulsarTestEnvironment(container(flink.getFlinkContainers().getJobManager())); // Defines a set of external context Factories for different test cases. @ExternalContextFactory