Hi all, We are testing the new Idleness detection feature in Flink 1.11, however, it does not work as we expected: When we connect two data streams, of which one is idle, the output watermark CoProcessOperator does not increase, hence the program cannot progress.
I've made a small project to illustrate the problem. The watermark received by the sink does not increase at all until the idle source is stopped. https://github.com/kien-truong/flink-idleness-testing Is this a bug or does the idleness detection not support this use case ? Regards. Kien
