flink
flink copied to clipboard
[FLINK-28975][connector/base] Add IdlenessManager for main and per-split output in source operator to mark idleness only if both outputs are idle
Unchanged backport of #20760 on release-1.15
CI report:
- 48bdb223bac22a56dfad8a734182d4ceebd1c133 Azure: FAILURE
Bot commands
The @flinkbot bot supports the following commands:-
@flinkbot run azurere-run the last Azure build
A successful run: https://renqs.visualstudio.com/Apache%20Flink/_build/results?buildId=417&view=results