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 <renqs...@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; } }