slachiewicz opened a new pull request, #284: URL: https://github.com/apache/flink-connector-kafka/pull/284
Bumps flink.version to 2.3.0 and the CI matrix to match. Flink 2.3 adds Python 3.12 support (tox.ini envlist) and removes JobResult.getApplicationStatus() (replaced with isSuccess() in KafkaSinkITCase). It also requires an explicit ON CONFLICT clause on INSERT statements whose upsert key differs from the sink's primary key (FLIP-558); added ON CONFLICT DO DEDUPLICATE to the affected UpsertKafkaTableITCase/KafkaChangelogTableITCase queries to preserve prior SinkUpsertMaterializer behavior. Also fixes a TIME-to-VARCHAR cast formatting change in KafkaTableITCase. -- 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]
