You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2018/04/04 12:22:36 UTC
[18/18] flink git commit: +ScheduleOrUpdateConsumersTest
+ScheduleOrUpdateConsumersTest
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6ffe22db
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6ffe22db
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/6ffe22db
Branch: refs/heads/master
Commit: 6ffe22db86f0846c7d3f1e7d7ff77eaa61483701
Parents: fea6d5e
Author: zentol <ch...@apache.org>
Authored: Wed Apr 4 11:43:55 2018 +0200
Committer: zentol <ch...@apache.org>
Committed: Wed Apr 4 11:43:55 2018 +0200
----------------------------------------------------------------------
.../jobmanager/scheduler/ScheduleOrUpdateConsumersTest.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/6ffe22db/flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/scheduler/ScheduleOrUpdateConsumersTest.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/scheduler/ScheduleOrUpdateConsumersTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/scheduler/ScheduleOrUpdateConsumersTest.java
index c743a63..e16c3ed 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/scheduler/ScheduleOrUpdateConsumersTest.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/scheduler/ScheduleOrUpdateConsumersTest.java
@@ -31,7 +31,7 @@ import org.apache.flink.runtime.jobmanager.SlotCountExceedingParallelismTest;
import org.apache.flink.runtime.minicluster.MiniCluster;
import org.apache.flink.runtime.minicluster.MiniClusterConfiguration;
import org.apache.flink.runtime.testingUtils.TestingUtils;
-import org.apache.flink.testutils.category.Flip6;
+import org.apache.flink.testutils.category.New;
import org.apache.flink.types.IntValue;
import org.apache.flink.util.TestLogger;
@@ -46,7 +46,7 @@ import java.util.List;
import static org.apache.flink.runtime.jobmanager.SlotCountExceedingParallelismTest.SubtaskIndexReceiver.CONFIG_KEY;
-@Category(Flip6.class)
+@Category(New.class)
public class ScheduleOrUpdateConsumersTest extends TestLogger {
private static final int NUMBER_OF_TMS = 2;