[
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
>
[
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
[
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
[
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
[
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