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
I am running several queries in FlinkSQL, and in a final step before
inserting into Kafka, I perform an ORDER BY eventTime. When I look at the
execution plan, I see Exchange(distribution=[single]). Does this mean that
all the data is going to a single node and getting reordered there? I
haven't bee
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
Hi,
I am also interested in the planned release dates for those versions.
Regards,
Nikola
On Wed, Nov 6, 2024 at 5:17 AM Prasanna kumar
wrote:
> Hi all ,
>
> What’s the planned release dates for flink versions 1.19.2 and 1.20.1.
>
> Thank you,
> Prasanna
>
