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:24 UTC
[flink-connector-pulsar] 07/27: [FLINK-25287][connectors/testing-framework] Refactor connector testing framework interfaces for more scenarios
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 a84c51b6a56ff0e2b34f43c6e9fca09235eedf06
Author: Qingsheng Ren <re...@gmail.com>
AuthorDate: Mon Jan 17 16:57:42 2022 +0800
[FLINK-25287][connectors/testing-framework] Refactor connector testing framework interfaces for more scenarios
---
.../util/pulsar/common/FlinkContainerWithPulsarEnvironment.java | 7 +++----
1 file changed, 3 insertions(+), 4 deletions(-)
diff --git a/flink-connector-pulsar-e2e-tests/src/test/java/org/apache/flink/tests/util/pulsar/common/FlinkContainerWithPulsarEnvironment.java b/flink-connector-pulsar-e2e-tests/src/test/java/org/apache/flink/tests/util/pulsar/common/FlinkContainerWithPulsarEnvironment.java
index 890d09e..14feeed 100644
--- a/flink-connector-pulsar-e2e-tests/src/test/java/org/apache/flink/tests/util/pulsar/common/FlinkContainerWithPulsarEnvironment.java
+++ b/flink-connector-pulsar-e2e-tests/src/test/java/org/apache/flink/tests/util/pulsar/common/FlinkContainerWithPulsarEnvironment.java
@@ -30,6 +30,7 @@ public class FlinkContainerWithPulsarEnvironment extends FlinkContainerTestEnvir
public FlinkContainerWithPulsarEnvironment(int numTaskManagers, int numSlotsPerTaskManager) {
super(
+ flinkConfiguration(),
numTaskManagers,
numSlotsPerTaskManager,
resourcePath("pulsar-connector.jar"),
@@ -43,12 +44,10 @@ public class FlinkContainerWithPulsarEnvironment extends FlinkContainerTestEnvir
return TestUtils.getResource(jarName).toAbsolutePath().toString();
}
- @Override
- protected Configuration flinkConfiguration() {
- Configuration configuration = super.flinkConfiguration();
+ protected static Configuration flinkConfiguration() {
+ Configuration configuration = new Configuration();
// Increase the off heap memory for avoiding direct buffer memory error on Pulsar e2e tests.
configuration.set(TASK_OFF_HEAP_MEMORY, MemorySize.ofMebiBytes(100));
-
return configuration;
}
}