Hi,
I'd like to ask the behavior I am getting I am using kafka as a source with window TumblingProcessingTime. When I tried to fire 1 parallel config but submit 2 instnce of the same jar in flink server, the data being consumed by the 2 jobs are the same (duplicate) even they have the same kafka group ID. But when I tried to use 2 for parallelism in the config the behavior was right, they get data no duplicate. Our expectation was if we fire multiple instance of the same job as long as they belong to the same kafka group ID, no duplicate data should be consumed. What are we doing wrong? Thanks Regards, Pat
