[KAFKA-5937] Improve ProcessorStateManager exception handling

• Type: Sub-task
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.11.0.0, 0.11.0.1
• Fix Version/s: 1.0.0
• Component/s: streams
• Assignee: Matthias J. Sax
• Reporter: Matthias J. Sax
• Created: 19/Sep/17 23:01
• Updated: 25/Sep/17 00:53
• Resolved: 21/Sep/17 23:34

Description

We identified the follow issues:

• constructor calls StateDirectory#directoryForTask() and wraps throw ProcessorStateException with LockException and rethrows -> we should not change the exception type here
• ProcessorStateManager#flush() loops through all stores and calls StateStore#flush(); it stops on first Exception -> we should keep looping and flush all remaining stores before rethrowing at the end

Issue Links

• links to: GitHub Pull Request #3913