- Flink dependencies are now 'provided'
  - flink-storm-examples has no direct storm-core dependency, but only depends through flink-storm

This closes #2293.

This closes #2274.

Adds further dependency exlcusions for unneeded (and potentially conflicting) storm dependencies.

- remove unused utility testing function
- remove leftover FLINK_CONF_DIR jvm property

This closes #2325

Cassandra needs Java 8 to run reliably.

This closes #2281

This prints a message when the leading JobManager changes after first
connecting to a JobManager. Further, it prints a message when a connection
to a JobManager has been established.

This closes #2322.

This PR changes the failure behaviour such that the consumer task is failed instead of the
producer task. The latter is problematic, since a finsihed producer task will simply swallow
scheduling exception originating from scheduling the consumer task.

This closes #2321.

This reverts commit 81cf2296.

We had an incorrent implementation of Murmur hash in Flink 1.0. This
was fixed in 641a0d43 for Flink 1.1. Then we thought that we need to
revert this in order to ensure backwards compatability between Flink
1.0 and 1.1 savepoints (81cf22). Turns out, savepoint backwards
compatability is broken for other reasons, too. Therefore, we revert
81cf22 here, ending up with a correct implementation of Murmur hash
again.

This closes #2311

Some source files had the -x flag set:

Before this change:
```
$ find . -perm +111 -type f | grep "\.java"
./flink-contrib/flink-tweet-inputformat/src/main/java/org/apache/flink/contrib/tweetinputformat/model/places/Attributes.java
./flink-contrib/flink-tweet-inputformat/src/main/java/org/apache/flink/contrib/tweetinputformat/model/places/BoundingBox.java
./flink-contrib/flink-tweet-inputformat/src/main/java/org/apache/flink/contrib/tweetinputformat/model/places/Places.java
./flink-contrib/flink-tweet-inputformat/src/main/java/org/apache/flink/contrib/tweetinputformat/model/tweet/Contributors.java
./flink-contrib/flink-tweet-inputformat/src/main/java/org/apache/flink/contrib/tweetinputformat/model/tweet/Coordinates.java
./flink-contrib/flink-tweet-inputformat/src/main/java/org/apache/flink/contrib/tweetinputformat/model/tweet/CurrentUserRetweet.java
./flink-contrib/flink-tweet-inputformat/src/main/java/org/apache/flink/contrib/tweetinputformat/model/tweet/entities/Entities.java
./flink-contrib/flink-tweet-inputformat/src/main/java/org/apache/flink/contrib/tweetinputformat/model/tweet/entities/HashTags.java
./flink-contrib/flink-tweet-inputformat/src/main/java/org/apache/flink/contrib/tweetinputformat/model/tweet/entities/Media.java
./flink-contrib/flink-tweet-inputformat/src/main/java/org/apache/flink/contrib/tweetinputformat/model/tweet/entities/Size.java
./flink-contrib/flink-tweet-inputformat/src/main/java/org/apache/flink/contrib/tweetinputformat/model/tweet/entities/Symbol.java
./flink-contrib/flink-tweet-inputformat/src/main/java/org/apache/flink/contrib/tweetinputformat/model/tweet/entities/URL.java
./flink-contrib/flink-tweet-inputformat/src/main/java/org/apache/flink/contrib/tweetinputformat/model/tweet/entities/UserMention.java
./flink-contrib/flink-tweet-inputformat/src/main/java/org/apache/flink/contrib/tweetinputformat/model/tweet/Tweet.java
./flink-contrib/flink-tweet-inputformat/src/main/java/org/apache/flink/contrib/tweetinputformat/model/User/Users.java
./flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/Graph.java
./flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/gsa/ApplyFunction.java
./flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/gsa/GatherFunction.java
./flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/gsa/GatherSumApplyIteration.java
./flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/gsa/Neighbor.java
./flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/gsa/SumFunction.java
./flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/GSAConnectedComponents.java
./flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/GSASingleSourceShortestPaths.java
./flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/examples/GSASingleSourceShortestPaths.java
./flink-libraries/flink-gelly-examples/src/test/java/org/apache/flink/graph/test/GatherSumApplyITCase.java
./flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java
```

After this change:
```
$ find . -perm +111 -type f | grep "\.java"
```

This closes #2310

This closes #2308

The json module is bundled with Ruby from 1.9.0 and upwards. This
cures dependency problems with different versions of Ruby.

This closes #2307.

Closes #2299

This closes #2232.

- fail if config couldn't be loaded
- remove duplicate api methods
- remove undocumented XML loading feature
- generate yaml conf in tests instead of xml conf
- only load one config file instead of all xml or yaml files (flink-conf.yaml)
- make globalconfiguration non-global and remove static SINGLETON
- fix test cases
- add test cases

This closes #2123

This also updates documentation and tests.

Reporters can now be specified like this:

metrics.reporters: foo,bar

metrics.reporter.foo.class: JMXReporter.class
metrics.reporter.foo.port: 10

metrics.reporter.bar.class: GangliaReporter.class
metrics.reporter.bar.port: 11
metrics.reporter.bar.something: 42

Unfortunately, we can't deploy snapshots atomically using the Nexus
repository. The staged process which leads to an atomic deployment is
only designed to work for releases. Best we can do is to retry
deploying artifacts in case of failures.

- introduce retry in case of failure of snapshot deployment
- simplify deployment script

This closes #2296

- Add YarnFlinkResourceManager test to reaccept task manager registrations from a re-elected job manager

- Remove unnecessary sync logic between JobManager and ResourceManager

- Avoid duplicate reigstration attempts in case of a refused registration

- Add test case to check that not an excessive amount of RegisterTaskManager messages are sent

- Remove containersLaunched from YarnFlinkResourceManager and instead not clearing registeredWorkers when JobManager loses leadership

- Let YarnFlinkResourceManagerTest extend TestLogger

- Harden YarnFlinkResourceManager.getContainersFromPreviousAttempts

- Add FatalErrorOccurred message handler to FlinkResourceManager;
  Increase timeout for YarnFlinkResourceManagerTest;
  Add additional constructor to TestingYarnFlinkResourceManager for tests

- Rename registeredWorkers field into startedWorkers
Additionally, the RegisterResource message is renamed into NotifyResourceStarted which
tells the RM that a resource has been started. This reflects the current semantics of
the startedWorkers map in the resource manager.

- Fix concurrency issues in TestingLeaderRetrievalService

This closes #2257

- moved user-facing API to 'flink-metrics/flink-metrics-core'
- moved JMXReporter to 'flink-metrics/flink-metrics-jmx'
- moved remaining metric classes to 'flink-runtime'

This closes #2226