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:28 UTC
[flink-connector-pulsar] 11/27: [FLINK-25288][tests][pulsar] Make pulsar e2e tests more robust
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 81c756e214af6519b95a26c74666d01a410c5dda
Author: Leonard Xu <xb...@gmail.com>
AuthorDate: Tue Feb 15 01:24:03 2022 +0800
[FLINK-25288][tests][pulsar] Make pulsar e2e tests more robust
This closes #18516.
---
.../common/FlinkContainerWithPulsarEnvironment.java | 16 ++++++++++++----
1 file changed, 12 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 14feeed..52957fc 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
@@ -19,12 +19,12 @@
package org.apache.flink.tests.util.pulsar.common;
import org.apache.flink.configuration.Configuration;
+import org.apache.flink.configuration.JobManagerOptions;
import org.apache.flink.configuration.MemorySize;
+import org.apache.flink.configuration.TaskManagerOptions;
import org.apache.flink.tests.util.TestUtils;
import org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment;
-import static org.apache.flink.configuration.TaskManagerOptions.TASK_OFF_HEAP_MEMORY;
-
/** A Flink Container which would bundles pulsar connector in its classpath. */
public class FlinkContainerWithPulsarEnvironment extends FlinkContainerTestEnvironment {
@@ -46,8 +46,16 @@ public class FlinkContainerWithPulsarEnvironment extends FlinkContainerTestEnvir
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));
+ // Increase the off heap memory of TaskManager to avoid direct buffer memory error in Pulsar
+ // e2e tests.
+ configuration.set(TaskManagerOptions.TASK_OFF_HEAP_MEMORY, MemorySize.ofMebiBytes(100));
+
+ // Increase the jvm metaspace memory to avoid java.lang.OutOfMemoryError: Metaspace
+ configuration.set(TaskManagerOptions.TOTAL_PROCESS_MEMORY, MemorySize.ofMebiBytes(2048));
+ configuration.set(TaskManagerOptions.JVM_METASPACE, MemorySize.ofMebiBytes(512));
+ configuration.set(JobManagerOptions.TOTAL_PROCESS_MEMORY, MemorySize.ofMebiBytes(2048));
+ configuration.set(JobManagerOptions.JVM_METASPACE, MemorySize.ofMebiBytes(512));
+
return configuration;
}
}