MartijnVisser opened a new pull request #18257:
URL: https://github.com/apache/flink/pull/18257
…2.8.1
## What is the purpose of the change
The Flink codebases uses Kafka Client and Confluent Platform in multiple
places:
- AVRO Confluent Schema Registry
- Flink end-to-end tests (Bash e2e tests)
- Flink end-to-end tests common (Java e2e tests)
- SQL AVRO Confluent Schema Registry
- Flink Test Utils
- Flink Tests
The used versions are currently not in sync, which could result in
unexpected results.
## Brief change log
* Updated
`flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/pom.xml` from
Confluent Platform 5.5.2 to 6.2.2 and Kafka Client from 2.4.1 to 2.8.1
* Updated
`flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/SQLClientKafkaITCase.java`
and
`flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/StreamingKafkaITCase.java`
from Kafka Client 2.4.1 to 2.8.1
* Updated
`flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/SQLClientSchemaRegistryITCase.java`
from Confluent Platform 5.5.2 to 6.2.2
* Updated `flink-end-to-end-tests/pom.xml` to skip dependency convergence
due to Guava, else the CI build will fail due to:
```
Dependency convergence error for com.google.guava:guava:30.1.1-jre paths to
dependency are:
+-org.apache.flink:flink-end-to-end-tests-common-kafka:1.15-SNAPSHOT
+-io.confluent:kafka-schema-registry-client:6.2.2
+-com.google.guava:guava:30.1.1-jre
and
+-org.apache.flink:flink-end-to-end-tests-common-kafka:1.15-SNAPSHOT
+-org.apache.flink:flink-connector-testing:1.15-SNAPSHOT
+-org.apache.flink:flink-test-utils:1.15-SNAPSHOT
+-org.apache.curator:curator-test:2.12.0
+-com.google.guava:guava:16.0.1
```
* Updated
`flink-end-to-end-tests/test-scripts/test_confluent_schema_registry.sh` from
Kafka Client 2.6.0 to 2.8.1 and Confluent Platform from 6.0.4 to 6.2.2
* Updated `flink-end-to-end-tests/test-scripts/test_pyflink.sh` from Kafka
Client 2.2.0 to 2.8.1 and Confluent Platform from 5.2.6 to 6.2.2
* Updated `flink-end-to-end-tests/test-scripts/test_sql_client.sh` from
Kafka Client 2.2.2 to 2.8.1 and Confluent Platform 5.2.6 to 6.2.2
* Updated `flink-formats/flink-avro-confluent-registry/pom.xml` from Kafka
Client 2.4.1 to 2.8.1 and Confluent Platform from 5.5.2 to 6.2.2
* Updated
`flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/util/DockerImageVersions.java`
testcontainers version for Confluent Platform from 6.2.1 to 6.2.2
* Updated
`flink-formats/flink-sql-avro-confluent-registry/src/main/resources/META-INF/NOTICE`
license information from 5.5.2 to 6.2.2 for Kafka Client dependencies
## Verifying this change
This change is a trivial rework / code cleanup without any test coverage.
## Does this pull request potentially affect one of the following parts:
- Dependencies (does it add or upgrade a dependency): yes
- The public API, i.e., is any changed class annotated with
`@Public(Evolving)`: no
- The serializers: no
- The runtime per-record code paths (performance sensitive): no
- Anything that affects deployment or recovery: JobManager (and its
components), Checkpointing, Kubernetes/Yarn, ZooKeeper: no
- The S3 file system connector: no
## Documentation
- Does this pull request introduce a new feature? no
- If yes, how is the feature documented? not applicable
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
