Purushottam Sinha created FLINK-40059: -----------------------------------------
Summary: StateMachineExample.jar bundles a Kafka connector
incompatible with Flink 2.x
Key: FLINK-40059
URL: https://issues.apache.org/jira/browse/FLINK-40059
Project: Flink
Issue Type: Technical Debt
Components: Examples
Reporter: Purushottam Sinha
Description:
The distribution ships StateMachineExample.jar with flink-connector-kafka
3.0.0-1.17 shaded in. That connector is not binary-compatible with Flink 2.x:
running the example with --kafka-topic fails on job start with
```
java.lang.NoSuchMethodError: 'void
org.apache.flink.connector.base.source.reader
.fetcher.SingleThreadFetcherManager.<init>(FutureCompletingBlockingQueue, ...)'
at KafkaSourceFetcherManager.<init>(KafkaSourceFetcherManager.java:72)
at KafkaSource.createReader(KafkaSource.java:163)
```
(constructor removed from flink-connector-base in 2.0, FLINK-31324).
Fix: bump to 5.0.0-2.2 (flink-examples-streaming +
flink-confluent-schema-registry
e2e), drop the obsolete flink-shaded-guava pin (FLINK-32462), update the
NOTICE.
Verified on a local 2.x cluster: the example consumes from Kafka again.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
