This removes the IOReadableWritable interface from AbstractID which is no longer used with IDs.

[hotfix] [config] Minor improvements to JobManagerOptions docs and harmonization of config parameters.

This PR ports the existing JobManager configuration options to the JobManagerOptions class
using the ConfigOption abstraction.

This closes #3556

This closes #3576.

This reverts commit 486f7249.

Removed after the "[DISCUSS] TravisCI status on GitHub Page" discussion on
the mailing list.

This closes #3577.

[FLINK-6138] [table] Create the ListStateDescriptor with the aggregationStateType instead of a serializer.

this closes #3581

This closes #3579.

This closes #3559.

When applying an AcceptFunction on a Future x, then we should register the exception handler
on the returned thenAccept future instead of on x. This has the advantage that we also catch
exceptions which are thrown inside of the AcceptFunction and not only those which originate
from x. The PR adapts the code respectively.

This closes #3537.

In order to check whether the heartbeat manager detects timeouts we wait on the
JobMasterGateway.disconnectTaskManager call which happens asynchronously. In order to harden
the test, we increase the timeout from 50 ms to 500 ms for the timeout call to happen.

The JobLeaderIdService is being created by the ResourceManagerRunner and then given to a
ResourceManager. Before the ResourceManager stopped the service before being stopped
itself. This could lead to a concurrent modification exception by a state changing action
executed by the actor thread. In order to avoid this concurrent modification, the service's
shut down is now being executed after the ResourceManager has been shut down.

This closes #3526.

[FLINK-6027] [checkpoints] Suppress (and log)  exceptions thrown by the subsuming of completed checkppoints

This closes #3521

[FLINK-5883] [core] Re-adding the Exception-thrown code for ListKeyGroupedIterator when the iterator is requested the second time

This closes #3392

This closes #3503

This closes #3570.

This closes #3232.

This cloes #3553.

[FLINK-5568] [table] Introduce ExternalCatalog interface, integrated with calcite and provide an in-memory implementation for testing.

This closes #3406.

This also adds tests.

The Scala side output API uses context bounds to get a TypeInformation
for an OutputTag. This also adds a SideOutputITCase for the Scala API.

We use side outputs to emit dropped late data.

This does not yet allow users to emit to side outputs in user functions.
Only operators (StreamOperator) can emit to side outputs. A side output
can be retrieved on a SingleOutputStreamOperator.

Before, there where some checks in
StreamExecutionEnvironment.set(Max)Parallelism() but a user would
circumvent these if using the ExecutionConfig directly. Now, all checks
are moved to the ExecutionConfig.

We need to have them there if we want to properly test the arguments of
setMaxParallelism() in the ExecutionConfig itself.

Before, it was set on the ExecutionConfig for some stream execution
environments and later for others. Now, we don't set the default
parallelism on the ExecutionConfig but instead set it at the latest
possible point, in the StreamingJobGraphGenerator.

This also adds tests that verify that we don't set the default
parallelism on the ExecutionConfig.

The HeartbeatServices are used to create all services relevant for heartbeating. This
includes at the moment the creation of HeartbeatManager implementations which actively
send heartbeats and those which only respond to heartbeat requests.

Add comments

This closes #3151.