[FLINK-1660] [streaming] Increased timeout for MultiTriggerPolicyTest and introduced a constant representing it.

This closes #459

Fault Tolerance monitor suicide on ExecutionGraph terminal state

Forwarding messages to StreamCheckpointCoordinator

Exposed state registering in the public API

This closes #458

Add parentheses on Exception#getMessage calls from pattern of:

"Initializing the input processing failed" + e.getMessage() == null ? "." : ": " + e.getMessage()

to:

"Initializing the input processing failed" + (e.getMessage() == null ? "." : ": " + e.getMessage())

Extra parentheses needed to make sure ternary operator check on e.getMessage scope call.

Author: Henry Saputra <henry.saputra@gmail.com>

Closes #461 from hsaputra/fix_parentheses_exception_getmessage and squashes the following commits:

1345cbf [Henry Saputra] Fix checking null for Exception#getMessage call from pattern of:

JobManagerStartupTest should not assume user could not create /does-not-exist-no-sir dir.

Sometimes, user that run tests could have write access to root directory so creating /does-not-exist-no-sir is possible,
hence no exception thrown.

Need to construct a Flink test directory under directory specified under "java.io.tmpdir" and change the permission
to not allow create new directory.

Author: Henry Saputra <henry.saputra@gmail.com>

Closes #460 from hsaputra/FLINK-1651_fix_jobmanager_fail_test and squashes the following commits:

5d46716 [Henry Saputra] [FLINK-1651] Fix test case at JobManagerStartupTest should not assume user could not create /does-not-exist-no-sir dir.

This closes #450

This closes #463

This closes #440

This PR consists of:

1. Remove unnecessary brackets in ExecutionVertex#getPreferredLocations
2. Throw illegal argument with proper message for consistencies of not nullable argument.
3. Add final modifier to RecordWriter#serializers since the content being used as lock.
4. Wrap too long of lines in some of the Java code for readibility.
5. Add missing JavaDoc parameter.
6. Remove final modifier in the OutputEmitter's private methods because it is redundant.

Author: Henry Saputra <henry.saputra@gmail.com>

Closes #457 from hsaputra/cleanup_javadoc_and_longlines_1 and squashes the following commits:

8815302 [Henry Saputra] Some cleanups and doc updates while looking at runtime package: 1. Remove unnecessary brackets in ExecutionVertex#getPreferredLocations 2. Throw illegal argument with proper message for consistencies of not nullable argument. 3. Add final modifier to RecordWriter#serializers since the content being used as lock. 4. Wrap too long of lines in some of the Java code for readibility. 5. Add missing JavaDoc parameter. 6. Remove final modifier in the OutputEmitter's private methods because it is redundant.

This closes #453

This closes #455

This closes #456

This closes #449

[FLINK-1625] [streaming] [api-breaking] Added proper cancellation to StreamInvokables + Sink- and SourceFunction interfaces extended with cancel method

[FLINK-1625] [streaming] Refactored StreamVertex and subclasses to clean up after invoke and properly log and propagate exceptions