Re:Re: Tenantive Flink 2.0 release date?

2024-10-31 Thread Xuyang
Hi, Anil. You can follow the timeline for the 2.0 release in the following ways: 1. (More real-time) Subscribe to the dev mailing list[1] to stay updated on release 2.0 related news. 2. Check the cwiki[2], although updates might not be as timely. [1] d...@flink.apache.org [2] https://cwi

Request performance advice on simple statistics

2024-10-31 Thread Smokeriu
I have a requirement that will use Flink to parse data and put it into a DB (like Doris, CH). The program will do a simple statistical analysis of the data before entering it into the DB. For example, counting the number of occurrences of a certain IP, and always adding up. And write the statistics

Re: Tenantive Flink 2.0 release date?

2024-10-31 Thread Anil Dasari
Hi Yanquan, Yes. Mainly, I am looking for JDK 11 support. Thank you for sharing the details. On Thu, Oct 31, 2024 at 4:26 AM Yanquan Lv wrote: > Hi, Anil. > Flink can maintain compatibility with one previous version, so a bump to > 1.19 can also meet your requirements? > There are already PR wit

Re: Tenantive Flink 2.0 release date?

2024-10-31 Thread Yanquan Lv
Hi, Anil. Flink can maintain compatibility with one previous version, so a bump to 1.19 can also meet your requirements? There are already PR with bump up to 1.19[1] and JDK11[2] adaptation in the FlinkCDC community, maybe you can refer to it for modification. [1]https://github.com/apache/flink-

Enable GC dump/logging on TMs on kube session

2024-10-31 Thread Vararu, Vadim
Hi, Trying to enable the GC dumps on Task Managers in a kube session. Tried this -Dkubernetes.taskmanager.entrypoint.args="-Xlog:gc*=debug:file=/tmp/gc.log:filecount=5,filesize=30m" and it added the arg at the end of the java command which does not seem to work. How could I add Xlog:gc*=debug