[
https://issues.apache.org/jira/browse/FLINK-13767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-13767:
-
Description:
StreamInputProcessor#processInput could return InputStatus instead of current
boolean valu
[
https://issues.apache.org/jira/browse/FLINK-13767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-13767:
-
Summary: Refactor StreamInputProcessor#processInput based on InputStatus
(was: Migrate isFinished metho