This is an automated email from the ASF dual-hosted git repository. reswqa pushed a commit to branch test-3.1 in repository https://gitbox.apache.org/repos/asf/flink-connector-elasticsearch.git
commit 0bde96ea54dfcaa55729f6486f1f0cffa32aee79 Author: Guo <[email protected]> AuthorDate: Fri May 15 16:45:52 2026 +0800 debug --- .../flink/streaming/tests/ElasticsearchSinkE2ECaseBase.java | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/flink-connector-elasticsearch-e2e-tests/flink-connector-elasticsearch-e2e-tests-common/src/main/java/org/apache/flink/streaming/tests/ElasticsearchSinkE2ECaseBase.java b/flink-connector-elasticsearch-e2e-tests/flink-connector-elasticsearch-e2e-tests-common/src/main/java/org/apache/flink/streaming/tests/ElasticsearchSinkE2ECaseBase.java index be6e4da..4bab9c8 100644 --- a/flink-connector-elasticsearch-e2e-tests/flink-connector-elasticsearch-e2e-tests-common/src/main/java/org/apache/flink/streaming/tests/ElasticsearchSinkE2ECaseBase.java +++ b/flink-connector-elasticsearch-e2e-tests/flink-connector-elasticsearch-e2e-tests-common/src/main/java/org/apache/flink/streaming/tests/ElasticsearchSinkE2ECaseBase.java @@ -19,6 +19,7 @@ package org.apache.flink.streaming.tests; import org.apache.flink.connector.testframe.container.FlinkContainerTestEnvironment; +import org.apache.flink.connector.testframe.container.FlinkContainersSettings; import org.apache.flink.connector.testframe.external.DefaultContainerizedExternalSystem; import org.apache.flink.connector.testframe.external.ExternalSystemDataReader; import org.apache.flink.connector.testframe.junit.annotations.TestEnv; @@ -56,7 +57,12 @@ public abstract class ElasticsearchSinkE2ECaseBase<T extends Comparable<T>> // Defines TestEnvironment @TestEnv - protected FlinkContainerTestEnvironment flink = new FlinkContainerTestEnvironment(1, 6); + protected FlinkContainerTestEnvironment flink = + FlinkContainerTestEnvironment.fromSettings( + FlinkContainersSettings.builder() + .numTaskManagers(1) + .numSlotsPerTaskManager(6) + .build()); // Defines ConnectorExternalSystem @TestExternalSystem
