that there was a collision occurring between the jobs.
Chris
From: Timothy Victor
Date: Friday, March 8, 2019 at 7:28 AM
To: user
Subject: [EXTERNAL] Flink 1.7.1 KafkaProducer error using Exactly Once semantic
Yesterday I came across a weird problem when attempting to run 2 nearly
identical jobs
Yesterday I came across a weird problem when attempting to run 2 nearly
identical jobs on a cluster. I was able to solve it (or rather workaround
it), but am sharing here so we can consider a potential fix in Flink's
KafkaProducer code.
My scenario is as follows. I have a Flink program that read
