Re: Flink job manager conditional start of flink jobs

2023-04-11 Thread Gen Luo
Hi, Is the job you want to start running or already finished? If the job is running, this is simply a failover or a JM failover case. While if the job has finished, there's no such feature that can restart the job automatically, AFAIK. The job has to be submitted again. On Wed, Apr 12, 2023 at 1

Flink job manager conditional start of flink jobs

2023-04-11 Thread naga sudhakar
Hi Team, Greetings!! Just wanted to know when job manager or task manager is being restarted, is there a way to run the existing flink jobs based on a condition? Same query when I am starting flink job fresh also. Please let me know if any more information is required from my side. Thanks & Regar

Requirements for POJO serialization

2023-04-11 Thread Alexis Sarda-Espinosa
Hello, according to the documentation, a POJO must have a no-arg constructor and either public fields or public getters and setters with conventional naming. I recently realized that if I create an explicit TypeInfoFactory that provides Types.POJO and all other required details, the getters and se