This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git
The following commit(s) were added to refs/heads/master by this push:
new 05e3e6281e [e2e] Try to fix e2e tests timeout by updating kafka docker
version (#4637)
05e3e6281e is described below
commit 05e3e6281e2ae2b60f55d0a148605b1315bc7051
Author: tsreaper <[email protected]>
AuthorDate: Wed Dec 4 17:17:28 2024 +0800
[e2e] Try to fix e2e tests timeout by updating kafka docker version (#4637)
---
.../src/test/java/org/apache/paimon/tests/E2eTestBase.java | 3 ++-
paimon-e2e-tests/src/test/resources-filtered/docker-compose.yaml | 4 ++--
2 files changed, 4 insertions(+), 3 deletions(-)
diff --git
a/paimon-e2e-tests/src/test/java/org/apache/paimon/tests/E2eTestBase.java
b/paimon-e2e-tests/src/test/java/org/apache/paimon/tests/E2eTestBase.java
index 55f9e984e5..0547ac4f27 100644
--- a/paimon-e2e-tests/src/test/java/org/apache/paimon/tests/E2eTestBase.java
+++ b/paimon-e2e-tests/src/test/java/org/apache/paimon/tests/E2eTestBase.java
@@ -111,7 +111,8 @@ public abstract class E2eTestBase {
for (String s : kafkaServices) {
environment.withLogConsumer(s + "-1", new
Slf4jLogConsumer(LOG));
}
- environment.waitingFor("kafka-1", buildWaitStrategy(".*Recorded
new controller.*", 2));
+ environment.waitingFor(
+ "kafka-1", buildWaitStrategy(".*Recorded new ZK
controller.*", 2));
}
if (withHive) {
List<String> hiveServices =
diff --git a/paimon-e2e-tests/src/test/resources-filtered/docker-compose.yaml
b/paimon-e2e-tests/src/test/resources-filtered/docker-compose.yaml
index 80d4a51fb1..b89420c812 100644
--- a/paimon-e2e-tests/src/test/resources-filtered/docker-compose.yaml
+++ b/paimon-e2e-tests/src/test/resources-filtered/docker-compose.yaml
@@ -77,7 +77,7 @@ services:
# ----------------------------------------
zookeeper:
- image: confluentinc/cp-zookeeper:7.0.1
+ image: confluentinc/cp-zookeeper:7.8.0
networks:
testnetwork:
aliases:
@@ -89,7 +89,7 @@ services:
- "2181"
kafka:
- image: confluentinc/cp-kafka:7.0.1
+ image: confluentinc/cp-kafka:7.8.0
networks:
testnetwork:
aliases:
