flink git commit: [doc] fixed typos in "Internals -> Fault Tolerance for Data Streaming"

Repository: flink Updated Branches: refs/heads/master 846ad7064 -> bbd97354b [doc] fixed typos in "Internals -> Fault Tolerance for Data Streaming" Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/bbd97354 Tree:

flink git commit: [FLINK-2663] [gelly] Updated Gelly library methods to use generic key types

Repository: flink Updated Branches: refs/heads/master bbd97354b -> 9f7110748 [FLINK-2663] [gelly] Updated Gelly library methods to use generic key types This squashes the following commits: [gelly] Added missing Javadocs to GSA classes [FLINK-2663] [gelly] Updated Gelly library methods to

[3/3] flink git commit: [hotfix] [build] Add joda-convert as a non-optional dependency, to fix Scala interoperability

[hotfix] [build] Add joda-convert as a non-optional dependency, to fix Scala interoperability Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c04a7704 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/c04a7704 Diff:

[3/9] flink git commit: [streaming] [storm] Clean up instantiation of mini clusters and test environments.

[streaming] [storm] Clean up instantiation of mini clusters and test environments. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/82d62361 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/82d62361 Diff:

[8/9] flink git commit: [FLINK-2778] Add API for non-parallel non-keyed Windows

[FLINK-2778] Add API for non-parallel non-keyed Windows This adds two new operators for non-keyed windows: Regular trigger operator and evicting trigger operator. This also adds the API calls nonParallelWindow(...) on DataStream and the API class NonParallelWindowDataStream for representing

[5/9] flink git commit: [hotfix] Simplify new windowing API

http://git-wip-us.apache.org/repos/asf/flink/blob/5623c15b/flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/EvictingWindowOperatorTest.java -- diff --git

[2/9] flink git commit: [streaming] [storm] Clean up instantiation of mini clusters and test environments.

http://git-wip-us.apache.org/repos/asf/flink/blob/82d62361/flink-staging/flink-tez/src/main/java/org/apache/flink/tez/client/RemoteTezEnvironment.java -- diff --git

[1/9] flink git commit: [FLINK-2787] [core] Prevent instantiation of RemoteEnvironment when running a program through the command line.

Repository: flink Updated Branches: refs/heads/master c04a77042 -> 846ad7064 [FLINK-2787] [core] Prevent instantiation of RemoteEnvironment when running a program through the command line. This also cleans up the use of context environments. Project: