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:21 UTC
[flink-connector-pulsar] 04/27: [FLINK-25038][testutils] Refactor FlinkContainer to split JM and TMs to individual containers and supports HA
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 475d9e7c29829ac6c05d6a001381a9b83d877064
Author: Qingsheng Ren <re...@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