The JAR upload and submit functionality is now integrated into the JobManager web interface.

This closes #1481

This closes #1478

This makes the signal handler registration atomic and does not fail (but ignore) re-registration.

This closes #1338

This closes #1451

This closes #1453

Adds a simple tracker of checkpoint statistics.

[FLINK-3131] [contrib, runtime, streaming-java] Add long getStateSize() to StateHandle and KvStateSnapshot

In order to report the state sizes, we need to expose them. All state backends
currently available backends know the state size. Only the LazyDbKvState does
not expose it at the moment, because it serializes the data lazily. This can be
changed in a follow-up fix.

This closes #1467

- removed BoltWrapperTwoInputs
- add generic multi-input stream bolt wrapper
- updated FlinkTopology to translate multi-input bolts correctly
- added multi-input union test wrapper
- updated FlinkTopology to translate multi-input bolts correctly
- added multi-input union test

This closes #1456

[FLINK-3166] [runtime] The first program in ObjectReuseITCase has the wrong expected result, and it succeeds
- TestEnvironment now honors configuration of object reuse
- Fixed reduce transformations to allow the user to modify and return either input

This closes #1464

This closes #1472

WriteMode has 2 values NO_OVERWRITE and OVERWRITE but it refers CREATE in the javadoc.
Probably old code.

This closes #1475

[FLINK-3103] [runtime] Remove unnecessary synchronization in FsStateBackend.FsCheckpointStateOutputStream

This closes 1474

This closes #1473
This closes #1098
This closes #1459

- The off-heap stats reported by the memory logger didn't include direct memory.

This closes #1466

This closes #1444

This closes #1255

Enalbes submission of Flink programs written in Clojure.

This closes #1457

- use AMRMClientAsync instead of AMRMClient
- handle allocation and startup of containers in callbacks
- remove YarnHeartbeat message

The AMRMClientAsync uses one thread to communicate with the resource
manager and an additional thread to execute the callbacks.

This closes #1450.

This closes #1463.

This closes #1439

This closes #1442

- Memoize string representations of AbstractID.
- Use lookup table for byte-to-hex conversion in StringUtils.

This closes #1455

Before, when the Kafka Source would emit a final Long.MAX_VALUE
watermark to signal the end of elements (i.e. no partition assigned).
This would trip up the AutomaticWatermarkContext and the
NonWatermarkContext.

Now, a Long.MAX_VALUE watermark is allowed through.

[FLINK-3171] [misc] Consolidate zoo of wrapper classes for input/output-stream to data-input/output-view.