[jira] [Closed] (FLINK-18934) Idle stream does not advance watermark in connected stream

2021-05-24 Thread Dawid Wysakowicz (Jira) 


 [ 
https://issues.apache.org/jira/browse/FLINK-18934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Dawid Wysakowicz closed FLINK-18934.

Resolution: Fixed

Fixed in 
214ba6817762c595110db289a7a3550cba5024e6..ee9f9b227a7703c2688924070c4746a70bff3fd8

> 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, Runtime / Task
>Affects Versions: 1.11.0, 1.12.0
>Reporter: Truong Duc Kien
>Assignee: Dawid Wysakowicz
>Priority: Critical
>  Labels: pull-request-available, stale-assigned
> Fix For: 1.14.0
>
>
> 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)

[jira] [Closed] (FLINK-18934) Idle stream does not advance watermark in connected stream

2021-10-08 Thread Dawid Wysakowicz (Jira) 


 [ 
https://issues.apache.org/jira/browse/FLINK-18934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Dawid Wysakowicz closed FLINK-18934.

Release Note: We added {{Input#processStreamStatus}} method in order to 
take the {{StreamStatus}} into account when combining watermarks in two/multi 
input operators.
  Resolution: Fixed

> 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, Runtime / Task
>Affects Versions: 1.11.0, 1.12.0, 1.13.0
>Reporter: Truong Duc Kien
>Assignee: Dawid Wysakowicz
>Priority: Critical
>  Labels: pull-request-available, stale-assigned
> Fix For: 1.14.0
>
>
> 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)