[
https://issues.apache.org/jira/browse/FLINK-18934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17229959#comment-17229959
]
Aljoscha Krettek commented on FLINK-18934:
------------------------------------------
I don't think we can fix it for Flink 1.12. This requires extending the
operator interface to "teach" operators about idleness as well so that they can
combine the two sides and forward an appropriate watermark/idleness.
> Idle stream does not advance watermark in connected stream
> ----------------------------------------------------------
>
> Key: FLINK-18934
> URL: https://issues.apache.org/jira/browse/FLINK-18934
> Project: Flink
> Issue Type: Bug
> Components: API / DataStream
> Affects Versions: 1.11.1
> Reporter: Truong Duc Kien
> Priority: Critical
> Fix For: 1.12.0, 1.11.3
>
>
> Per Flink documents, when a stream is idle, it will allow watermarks of
> downstream operator to advance. However, when I connect an active data stream
> with an idle data stream, the output watermark of the CoProcessOperator does
> not increase.
> Here's a small test that reproduces the problem.
> https://github.com/kien-truong/flink-idleness-testing
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
