[ 
https://issues.apache.org/jira/browse/FLINK-36621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

ASF GitHub Bot updated FLINK-36621:
-----------------------------------
    Labels: pull-request-available  (was: )

> 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
>            Priority: Blocker
>              Labels: pull-request-available
>
> 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)

Reply via email to