Hello,
As per link below for Flink 2.0, there are many breaking changes which will
impact users. Please give inputs for below.
1. What are the alternatives for the APIs/interfaces/methods/constants which
are supposed to be removed? Any documentation related to this, please share?
1. I
I saw the related fix commit on github, but now I want to use the 1.18 fixed version, where should I find it? I see that the 1.18 version provided by the official website is still in 2023, or can I only compile from the source code?在 2024年11月27日，17:56，William Wallace 写道：hi, It seems similar to is
Hi Folks,
We are currently running a Java 8 application that uses Protobufs and
runs on Apache Flink 1.18.1. While Flink supports the Protobuf data format
for message exchange between operators, the serialization and
deserialization of these Protobuf messages are performed using Kryo 2.x for
hi,
It seems similar to issue described here:
https://lists.apache.org/thread/g8yb4rlj0mlf1vgjl71815nts8r1w51p
were we were not able to restore state because of the high number of S3
reads (in your case it might first encounter the connection limitation
first).
Have a look at https://issues.apache.
The Apache Flink community is very happy to announce the release of Apache
Flink CDC 3.2.1.
Apache Flink CDC is a distributed data integration tool for real time data
and batch data, bringing the simplicity and elegance of data integration
via YAML to describe the data movement and transformation i
