Thank you Yun.
I haven't tried to follow your guide to check (would take some time for me
to follow on how to do).
However, I could now confirm that the "*union"* is the culprit. In my Flink
Console GUI, I can see that the link from StreamC to CEP via "union" is a
FORWARD link, not a HASH one,
Hi Stefan, Dawid,
I hadn't changed anything in the configuration. Env's parallelism stayed at
64. Some source/sink operators have parallelism of 1 to 8. I'm using Flink
1.7-SNAPSHOT, with the code pulled from master about 5 days back. Savepoint
was saved to either S3 or HDFS (I tried multiple
