Piotr Nowojski created FLINK-36621:
--------------------------------------
Summary: 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
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)
