[FLINK-4386] Add as way to assert that code runs in the RpcEndpoint's Main Thread

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Implemented
• Fix Version/s: 1.2.0
• Component/s: Runtime / Coordination

Environment

FLIP-6 feature branch

• Assignee: Stephan Ewen
• Reporter: Stephan Ewen
• Created: 11/Aug/16 18:00
• Updated: 14/Aug/16 13:45
• Resolved: 14/Aug/16 13:45

Description

It would greatly help stability if we were able to add assertions to the code, like

private void someCallbackHandler() {
    assert isRunningInMainThread()
}