[FLINK-4892] Re-enable RescalingITCase With AbstractStreamOperator no longer implementing StreamCheckpointedOperator the test passes again.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b673760d Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b673760d Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/b673760d Branch: refs/heads/master Commit: b673760d3d2ebe98a97786fb0fdf194db1cb6709 Parents: c0192ec Author: Aljoscha Krettek <[email protected]> Authored: Mon Oct 24 12:03:17 2016 +0200 Committer: Aljoscha Krettek <[email protected]> Committed: Wed Oct 26 23:26:28 2016 +0200 ---------------------------------------------------------------------- .../org/apache/flink/test/checkpointing/RescalingITCase.java | 4 ---- 1 file changed, 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/b673760d/flink-tests/src/test/java/org/apache/flink/test/checkpointing/RescalingITCase.java ---------------------------------------------------------------------- diff --git a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/RescalingITCase.java b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/RescalingITCase.java index bc40a89..4819c26 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/RescalingITCase.java +++ b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/RescalingITCase.java @@ -77,11 +77,7 @@ import static org.junit.Assert.fail; /** * TODO : parameterize to test all different state backends! - * - * Ignored for now since the timers in {@link org.apache.flink.streaming.api.operators.AbstractStreamOperator} - * are not repartitionable/key-group-aware. */ -@Ignore public class RescalingITCase extends TestLogger { private static final int numTaskManagers = 2;
