[FLINK-3085] Move State Backend Initialization from "registerInputOutput()" to "invoke()"

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Invalid
• Affects Version/s: 0.10.0
• Assignee: Stephan Ewen
• Reporter: Stephan Ewen
• Created: 26/Nov/15 16:30
• Updated: 28/Feb/19 11:14
• Resolved: 11/Jul/16 19:23

Description

The state backend initialization currently happens in the StreamTask in registerInputOutput(). For better error handling, it should be part of invoke(), where the task is properly interrupted, threads are properly joined, and exceptions are treated aware of cancelling.