Kostas Kloudas created FLINK-11573: -------------------------------------- Summary: Make StreamTask properly handle the SUSPEND message. Key: FLINK-11573 URL: https://issues.apache.org/jira/browse/FLINK-11573 Project: Flink Issue Type: Sub-task Components: Core, Streaming, TaskManager Affects Versions: 1.8.0 Reporter: Kostas Kloudas Assignee: Kostas Kloudas Fix For: 1.8.0
In this case, the {{StreamTask}} has to; - launch the checkpointing process - wait until also for the checkpoint notification callback to be successfully executed - make sure no elements are processed by downstream operators (req. for exactly-once with idempotent updates) - do not call {{close()}} - let the job go gracefully to {{FINISHED}} -- This message was sent by Atlassian JIRA (v7.6.3#76005)