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.14
CI report:
- 7bd99c5c9e14d72f947853e70755ac69d3c12835 Azure: FAILURE
Bot commands
The @flinkbot bot supports the following commands:-
@flinkbot run azure
re-run the last Azure build