Hi Adrien,
Yes, we recommend using org.apache.flink.api.connector.sink2.Sink instead of
org.apache.flink.streaming.api.functions.sink.SinkFunction or
org.apache.flink.api.connector.sink.Sink.
As for why these codes are still retained in 1.20, one reason is because Sink
The InitContext was only
Hello dear Flink community,
I am new to Flink and am working on implementing my first job. While doing
so, I wanted to implement the `org.apache.flink.api.connector.sink2.Sink`
interface to collect items into a thread-safe list (for testing purposes).
To implement this interface, it is required t
