Skip to content

Commit 2835e4a

Browse files
committed
[FLINK-36059][tests] Bump cp-kafka and cp-schema-registry from 7.2.2 to 7.2.9
cp-kafka:7.2.2 ships JDK 11.0.16.1 which has a known cgroup v2 bug (JDK-8287073) that causes a NullPointerException in CgroupV2Subsystem.getInstance(). Docker 29 changed cgroup handling in a way that now triggers this bug, crashing the Kafka container before it can start and failing SqlClientITCase. cp-kafka:7.2.9 ships JDK 11.0.21 which includes the fix. Update cp-schema-registry to 7.2.9 as well since it bundles the same vulnerable JDK. (cherry picked from commit 2db7996)
1 parent 004e2ef commit 2835e4a

File tree

3 files changed

+4
-4
lines changed

3 files changed

+4
-4
lines changed

flink-end-to-end-tests/test-scripts/test_confluent_schema_registry.sh

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@
2020
set -Eeuo pipefail
2121

2222
KAFKA_VERSION="3.2.3"
23-
CONFLUENT_VERSION="7.2.2"
23+
CONFLUENT_VERSION="7.2.9"
2424
CONFLUENT_MAJOR_VERSION="7.2"
2525
# Check the Confluent Platform <> Apache Kafka compatibility matrix when updating KAFKA_VERSION
2626
KAFKA_SQL_VERSION="universal"

flink-end-to-end-tests/test-scripts/test_pyflink.sh

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@
2020
set -Eeuo pipefail
2121

2222
KAFKA_VERSION="3.2.3"
23-
CONFLUENT_VERSION="7.2.2"
23+
CONFLUENT_VERSION="7.2.9"
2424
CONFLUENT_MAJOR_VERSION="7.2"
2525
# Check the Confluent Platform <> Apache Kafka compatibility matrix when updating KAFKA_VERSION
2626
KAFKA_SQL_VERSION="universal"

flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/util/DockerImageVersions.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -28,9 +28,9 @@
2828
*/
2929
public class DockerImageVersions {
3030

31-
public static final String KAFKA = "confluentinc/cp-kafka:7.2.2";
31+
public static final String KAFKA = "confluentinc/cp-kafka:7.2.9";
3232

33-
public static final String SCHEMA_REGISTRY = "confluentinc/cp-schema-registry:7.2.2";
33+
public static final String SCHEMA_REGISTRY = "confluentinc/cp-schema-registry:7.2.9";
3434

3535
public static final String KINESALITE = "instructure/kinesalite:latest";
3636

0 commit comments

Comments
 (0)