Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/4414
Thanks for the fix and your notice on the instabilities @NicoK!
Could you check if my understanding of the issue is correct?:
- `Kafka010ITCase.testCommitOffsetsToKafka` was failing on
`JobCancellationException`, whereas that exception signals success and should
be ignored.
- We were "incorrectly passing" before only because we didn't properly wait
for the job to be cancelled.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
