This issue has been going on for a while but i couldn't figure it out no
matter what I tried
Some general info
Flink 1.14.5 with checkpoint/HA storage in S3
we have 3 jobs which are identical code the only difference is which kafka
topic is read and what prefix is used in the S3 sink
this means tha
Thanks Chesnay,
I wanted to check out the tagged release 1.15.1. I did it in this way:
git clone --depth 1 --branch release-1.15.1 g...@github.com:apache/flink.git
This seems cause the problem. With the same java/maven, I can build the branch
1.15.
> On Sep 9, 2022, at 11:58 PM, Chesnay Sch
