[FLINK-36621] Build failure: StatefulSink not found

• Type: Improvement
• Status: Closed
• Priority: Blocker
• Resolution: Fixed
• Affects Version/s: 2.0-preview
• Fix Version/s: 2.0.0
• Component/s: Connectors / Common
• Labels: pull-request-available
• Assignee: Yanquan Lv
• Reporter: Piotr Nowojski
• Created: 29/Oct/24 10:37
• Updated: 31/Oct/24 13:39
• Resolved: 31/Oct/24 11:08

Description

Locally in the IntelliJ building Flink fails for me due to:

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

flink-examples depend on flink-connector-kafka in version 3.0.0-17 that in turns is still referring to the StatefulSink:

public class KafkaSink<IN> implements StatefulSink<IN, KafkaWriterState>, TwoPhaseCommittingSink<IN, KafkaCommittable> (...)

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

Issue Links

• is caused by: FLINK-36245 Remove legacy SourceFunction / SinkFunction / Sink V1 API and deprecated method/interface in Sink V2 in 2.0
• is related to: FLINK-36413 Reenable the test case that related to Source/Sink APi deprecated.
• links to: GitHub Pull Request #25588