You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by al...@apache.org on 2016/10/26 21:36:51 UTC

[5/9] flink git commit: [FLINK-4892] Re-enable RescalingITCase

[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 <al...@gmail.com>
Authored: Mon Oct 24 12:03:17 2016 +0200
Committer: Aljoscha Krettek <al...@gmail.com>
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;