[ANNOUNCE] Apache Flink CDC 3.4.0 released

2025-05-16 Thread Yanquan Lv
The Apache Flink community is very happy to announce the release of Apache Flink CDC 3.4.0. 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

Flink History Server Logs

2025-05-16 Thread SURAJ KADEL
Hi Team, How can we configure Flink History Server to retrieve the logs from jobManager and taskManagers? Currently, all of our flink logs are getting stored in ElasticSearch but we want to observe these logs from History Server as well. Any sort of suggestions would be very helpful. Thanks, Sur

Re: Apache Flink Serialization Question

2025-05-16 Thread Zhanghao Chen
Flink 2.0 will work. You may use Types.LIST for lists and Types.MAP for sets (mocked by a Map) for that. Notice that Flink's built-in LIST does not support null element and MAP type does not support null key, and neither support null collection. In Flink 2.0, we've added special treatment of th