[FLINK-1982] Rename MapTaskTest to FlatMapTaskTest

apache · Oct 23, 2015 · 9df82a9 · 9df82a9
1 parent 05810bd
commit 9df82a9
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/.../flink/runtime/operators/MapTaskTest.java → ...nk/runtime/operators/FlatMapTaskTest.java b/.../flink/runtime/operators/MapTaskTest.java → ...nk/runtime/operators/FlatMapTaskTest.java
@@ -37,14 +37,14 @@
 import org.junit.Assert;
 import org.junit.Test;
 
-public class MapTaskTest extends DriverTestBase<FlatMapFunction<Record, Record>> {
+public class FlatMapTaskTest extends DriverTestBase<FlatMapFunction<Record, Record>> {
 
-	private static final Logger LOG = LoggerFactory.getLogger(MapTaskTest.class);
+	private static final Logger LOG = LoggerFactory.getLogger(FlatMapTaskTest.class);
 
 	private final CountingOutputCollector output = new CountingOutputCollector();
 
 
-	public MapTaskTest(ExecutionConfig config) {
+	public FlatMapTaskTest(ExecutionConfig config) {
 		super(config, 0, 0);
 	}
 

diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/operators/chaining/ChainTaskTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/operators/chaining/ChainTaskTest.java
@@ -31,7 +31,7 @@
 import org.apache.flink.runtime.operators.DriverStrategy;
 import org.apache.flink.runtime.operators.BatchTask;
 import org.apache.flink.runtime.operators.FlatMapDriver;
-import org.apache.flink.runtime.operators.MapTaskTest.MockMapStub;
+import org.apache.flink.runtime.operators.FlatMapTaskTest.MockMapStub;
 import org.apache.flink.runtime.operators.ReduceTaskTest.MockReduceStub;
 import org.apache.flink.runtime.operators.shipping.ShipStrategyType;
 import org.apache.flink.runtime.operators.testutils.TaskTestBase;