This is an automated email from the ASF dual-hosted git repository.
ferenc-csaky pushed a commit to branch v3.4
in repository https://gitbox.apache.org/repos/asf/flink-connector-kafka.git
The following commit(s) were added to refs/heads/v3.4 by this push:
new 0629c4eb [hotfix] Turn off zookeeper HA in E2E tests
0629c4eb is described below
commit 0629c4eb87e74fad9ff64da552bf3dc3da0ab11a
Author: Ferenc Csaky <[email protected]>
AuthorDate: Tue Apr 21 11:04:21 2026 +0200
[hotfix] Turn off zookeeper HA in E2E tests
---
.github/workflows/push_pr.yml | 4 ++--
.../java/org/apache/flink/tests/util/kafka/KafkaSinkE2ECase.java | 9 ++++++++-
.../org/apache/flink/tests/util/kafka/KafkaSourceE2ECase.java | 9 ++++++++-
3 files changed, 18 insertions(+), 4 deletions(-)
diff --git a/.github/workflows/push_pr.yml b/.github/workflows/push_pr.yml
index 69854c34..b57f2cff 100644
--- a/.github/workflows/push_pr.yml
+++ b/.github/workflows/push_pr.yml
@@ -28,7 +28,7 @@ jobs:
compile_and_test:
strategy:
matrix:
- flink: [ 1.20.0 ]
+ flink: [ 1.20.3 ]
jdk: [ '8, 11, 17, 21' ]
uses: apache/flink-connector-shared-utils/.github/workflows/ci.yml@ci_utils
with:
@@ -37,7 +37,7 @@ jobs:
python_test:
strategy:
matrix:
- flink: [ 1.20.0 ]
+ flink: [ 1.20.3 ]
uses:
apache/flink-connector-shared-utils/.github/workflows/python_ci.yml@ci_utils
with:
flink_version: ${{ matrix.flink }}
diff --git
a/flink-connector-kafka-e2e-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/KafkaSinkE2ECase.java
b/flink-connector-kafka-e2e-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/KafkaSinkE2ECase.java
index e18c035b..4a45119e 100644
---
a/flink-connector-kafka-e2e-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/KafkaSinkE2ECase.java
+++
b/flink-connector-kafka-e2e-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/KafkaSinkE2ECase.java
@@ -21,6 +21,7 @@ package org.apache.flink.tests.util.kafka;
import
org.apache.flink.connector.kafka.sink.testutils.KafkaSinkExternalContextFactory;
import org.apache.flink.connector.kafka.testutils.DockerImageVersions;
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.junit.annotations.TestContext;
import org.apache.flink.connector.testframe.junit.annotations.TestEnv;
@@ -47,7 +48,13 @@ public class KafkaSinkE2ECase extends
SinkTestSuiteBase<String> {
};
// Defines TestEnvironment
- @TestEnv FlinkContainerTestEnvironment flink = new
FlinkContainerTestEnvironment(1, 6);
+ @TestEnv
+ FlinkContainerTestEnvironment flink =
+ FlinkContainerTestEnvironment.fromSettings(
+ FlinkContainersSettings.builder()
+ .numTaskManagers(1)
+ .numSlotsPerTaskManager(6)
+ .build());
// Defines ConnectorExternalSystem
@TestExternalSystem
diff --git
a/flink-connector-kafka-e2e-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/KafkaSourceE2ECase.java
b/flink-connector-kafka-e2e-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/KafkaSourceE2ECase.java
index 1a2ac1f2..5ea2bd2a 100644
---
a/flink-connector-kafka-e2e-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/KafkaSourceE2ECase.java
+++
b/flink-connector-kafka-e2e-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/KafkaSourceE2ECase.java
@@ -21,6 +21,7 @@ package org.apache.flink.tests.util.kafka;
import org.apache.flink.connector.kafka.testutils.DockerImageVersions;
import
org.apache.flink.connector.kafka.testutils.KafkaSourceExternalContextFactory;
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.junit.annotations.TestContext;
import org.apache.flink.connector.testframe.junit.annotations.TestEnv;
@@ -46,7 +47,13 @@ public class KafkaSourceE2ECase extends
SourceTestSuiteBase<String> {
CheckpointingMode[] semantics = new CheckpointingMode[]
{CheckpointingMode.EXACTLY_ONCE};
// Defines TestEnvironment
- @TestEnv FlinkContainerTestEnvironment flink = new
FlinkContainerTestEnvironment(1, 6);
+ @TestEnv
+ FlinkContainerTestEnvironment flink =
+ FlinkContainerTestEnvironment.fromSettings(
+ FlinkContainersSettings.builder()
+ .numTaskManagers(1)
+ .numSlotsPerTaskManager(6)
+ .build());
// Defines ConnectorExternalSystem
@TestExternalSystem
