[2/2] flink git commit: [FLINK-2286] [streaming] ITCase for ParallelMerge behavior

2015-08-19 Thread mbalassi
[FLINK-2286] [streaming] ITCase for ParallelMerge behavior Closes #1014 Adapted for version 0.9 Conflicts: flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/example/PageRankITCase.java Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [tests] Replaces Scala mixins for the Job/TaskManager with classes which extend the respective classes. Adds proper logger registration for sub-classes of FlinkUntypedActor.

2015-08-19 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master 8602b7af0 - baaa3daca [tests] Replaces Scala mixins for the Job/TaskManager with classes which extend the respective classes. Adds proper logger registration for sub-classes of FlinkUntypedActor. Project:

[3/6] flink git commit: [FLINK-2398][api-breaking] Introduce StreamGraphGenerator

2015-08-19 Thread aljoscha
http://git-wip-us.apache.org/repos/asf/flink/blob/bac21bf5/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/transformations/SplitTransformation.java -- diff --git

[5/6] flink git commit: [FLINK-2398][api-breaking] Introduce StreamGraphGenerator

2015-08-19 Thread aljoscha
http://git-wip-us.apache.org/repos/asf/flink/blob/bac21bf5/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/IterativeDataStream.java -- diff --git

[1/6] flink git commit: [FLINK-2398][api-breaking] Introduce StreamGraphGenerator

2015-08-19 Thread aljoscha
Repository: flink Updated Branches: refs/heads/master baaa3daca - bac21bf5d http://git-wip-us.apache.org/repos/asf/flink/blob/bac21bf5/flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/runtime/partitioner/FieldsPartitionerTest.java