[jira] [Updated] (FLINK-14230) Change the endInput call of the downstream operator to after the upstream operator closes
[ https://issues.apache.org/jira/browse/FLINK-14230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-14230: - Fix Version/s: 1.10.0 > Change the endInput call of the downstream operator to after the upstream > operator closes > -- > > Key: FLINK-14230 > URL: https://issues.apache.org/jira/browse/FLINK-14230 > Project: Flink > Issue Type: Sub-task > Components: Runtime / Task >Reporter: Haibo Sun >Assignee: Haibo Sun >Priority: Major > Labels: pull-request-available > Fix For: 1.10.0 > > Time Spent: 20m > Remaining Estimate: 0h > > This ticket is for fixing the error of propagating "endInput" on the chain > immediately after the input of the head operator is finished. Correctly, > "endInput" of the downstream operator should be invoked only after closing > the upstream operator. > After "endInput" of the downstream operator on the chain is invoked > correctly, we revert the changes of PR#9298 and PR#9221. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Updated] (FLINK-14230) Change the endInput call of the downstream operator to after the upstream operator closes
[ https://issues.apache.org/jira/browse/FLINK-14230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-14230: - Description: This ticket is for fixing the error of propagating "endInput" on the chain immediately after the input of the head operator is finished. Correctly, "endInput" of the downstream operator should be invoked only after closing the upstream operator. After "endInput" of the downstream operator on the chain is invoked correctly, we revert the changes of PR#9298 and PR#9221. > Change the endInput call of the downstream operator to after the upstream > operator closes > -- > > Key: FLINK-14230 > URL: https://issues.apache.org/jira/browse/FLINK-14230 > Project: Flink > Issue Type: Sub-task > Components: Runtime / Task >Reporter: Haibo Sun >Assignee: Haibo Sun >Priority: Major > Labels: pull-request-available > Time Spent: 20m > Remaining Estimate: 0h > > This ticket is for fixing the error of propagating "endInput" on the chain > immediately after the input of the head operator is finished. Correctly, > "endInput" of the downstream operator should be invoked only after closing > the upstream operator. > After "endInput" of the downstream operator on the chain is invoked > correctly, we revert the changes of PR#9298 and PR#9221. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Updated] (FLINK-14230) Change the endInput call of the downstream operator to after the upstream operator closes
[ https://issues.apache.org/jira/browse/FLINK-14230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14230: --- Labels: pull-request-available (was: ) > Change the endInput call of the downstream operator to after the upstream > operator closes > -- > > Key: FLINK-14230 > URL: https://issues.apache.org/jira/browse/FLINK-14230 > Project: Flink > Issue Type: Sub-task > Components: Runtime / Task >Reporter: Haibo Sun >Assignee: Haibo Sun >Priority: Major > Labels: pull-request-available > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Updated] (FLINK-14230) Change the endInput call of the downstream operator to after the upstream operator closes
[ https://issues.apache.org/jira/browse/FLINK-14230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haibo Sun updated FLINK-14230: -- Summary: Change the endInput call of the downstream operator to after the upstream operator closes (was: Change the endinput call of the downstream operator to after the upstream operator closes) > Change the endInput call of the downstream operator to after the upstream > operator closes > -- > > Key: FLINK-14230 > URL: https://issues.apache.org/jira/browse/FLINK-14230 > Project: Flink > Issue Type: Sub-task > Components: Runtime / Task >Reporter: Haibo Sun >Assignee: Haibo Sun >Priority: Major > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Updated] (FLINK-14230) Change the endinput call of the downstream operator to after the upstream operator closes
[ https://issues.apache.org/jira/browse/FLINK-14230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haibo Sun updated FLINK-14230: -- Summary: Change the endinput call of the downstream operator to after the upstream operator closes (was: Change the endinput call of the downstream operator to after closing the upstream operator) > Change the endinput call of the downstream operator to after the upstream > operator closes > -- > > Key: FLINK-14230 > URL: https://issues.apache.org/jira/browse/FLINK-14230 > Project: Flink > Issue Type: Sub-task > Components: Runtime / Task >Reporter: Haibo Sun >Assignee: Haibo Sun >Priority: Major > -- This message was sent by Atlassian Jira (v8.3.4#803005)
