Hi,
Did you ever get to solve this issue? I'm getting the same error.
On 1.3.2 I used to run the fat jar as a standalone without any job
submission and it worked just fine
It looked like it used an embedded MiniCluster.
After just changing the dependencies to 1.4.0 we started getting this
Hi,
I'm a bit new to Flink and I'm trying to figure out what's the best way to
make an upgrade for my current running topology without having duplicate
messages being sent by the the sink. (One time prior the upgrade and one
time after).
I thought that the "atomic" part of the savepoint & cancel
