[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:
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:
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
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
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