[
https://issues.apache.org/jira/browse/FLINK-36621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo closed FLINK-36621.
------------------------------
Fix Version/s: 2.0.0
Resolution: Fixed
master via e19f576358221172d6ef7837a320e1557f19c45b
> Build failure: StatefulSink not found
> -------------------------------------
>
> Key: FLINK-36621
> URL: https://issues.apache.org/jira/browse/FLINK-36621
> Project: Flink
> Issue Type: Improvement
> Components: Connectors / Common
> Affects Versions: 2.0-preview
> Reporter: Piotr Nowojski
> Assignee: LvYanquan
> Priority: Blocker
> Labels: pull-request-available
> Fix For: 2.0.0
>
>
> Locally in the IntelliJ building Flink fails for me due to:
> {code:java}
> flink-apache/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/statemachine/KafkaEventsGeneratorJob.java:72:42
> java: cannot access org.apache.flink.api.connector.sink2.StatefulSink
> class file for org.apache.flink.api.connector.sink2.StatefulSink not found
> {code}
> flink-examples depend on flink-connector-kafka in version 3.0.0-17 that in
> turns is still referring to the StatefulSink:
> {code:java}
> public class KafkaSink<IN> implements StatefulSink<IN, KafkaWriterState>,
> TwoPhaseCommittingSink<IN, KafkaCommittable> (...)
> {code}
> which has been deleted in FLINK-36245. I think maven builds might be working
> due to some luck and differences between how IntelliJ and Maven are
> interpreting pom files and dealing with the dependencies.
> CC [~kunni] [~renqs] [~Leonard]
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
