[
https://issues.apache.org/jira/browse/FLINK-40059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-40059:
-----------------------------------
Labels: pull-request-available (was: )
> 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
> Priority: Minor
> Labels: pull-request-available
>
> 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
>
>
>
> {code:java}
> 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)
> {code}
>
>
> (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)
