[flink-connector-pulsar] 04/31: [FLINK-25038][testutils] Refactor FlinkContainer to split JM and TMs to individual containers and supports HA

[martijnvisser]

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