Hello Gordon,
Thanks for the explanations. A few follow-up questions:
Are you using the DataStream API and using the KafkaSource (and not
the older FlinkKafkaConsumer connector)? If that's the case, I believe
you always have to set a watermark strategy when adding the
KafkaSource to the job t
Hi Anirban,
> But this happened only once and now it is not getting reproduced at all.
This does make it sound a lot like
https://issues.apache.org/jira/browse/FLINK-31632.
> 1. What is the default watermarking strategy used in Flink. Can I quickly
check the default parameters being used by call
> Perhaps he could weigh in on whether the combination of automated tests
plus those smoke tests should be sufficient for testing with new Flink
versions
What we usually did at the bare minimum for new StateFun releases was the
following:
1. Build tests (including the smoke tests in the e2e mo
