[jira] [Updated] (FLINK-13767) Refactor StreamInputProcessor#processInput based on InputStatus

2019-09-12 Thread zhijiang (Jira)
[ 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

[jira] [Updated] (FLINK-13767) Refactor StreamInputProcessor#processInput based on InputStatus

2019-09-12 Thread zhijiang (Jira)
[ 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