Repository: flink Updated Branches: refs/heads/release-1.3 8dd05c053 -> 77d57f1be
[hotfix] Revert: Temporarily deactivate RocksDB checkpointing tests Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/77d57f1b Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/77d57f1b Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/77d57f1b Branch: refs/heads/release-1.3 Commit: 77d57f1be05ee35c7f097a6e06e79d99c16d9d0c Parents: 8dd05c0 Author: Stefan Richter <[email protected]> Authored: Tue May 9 11:25:28 2017 +0200 Committer: Stefan Richter <[email protected]> Committed: Tue May 9 11:25:28 2017 +0200 ---------------------------------------------------------------------- ...ckendEventTimeWindowCheckpointingITCase.java | 3 -- .../PartitionedStateCheckpointingITCase.java | 30 ++++++++++---------- ...ckendEventTimeWindowCheckpointingITCase.java | 3 -- .../streaming/runtime/PartitionerITCase.java | 1 - 4 files changed, 15 insertions(+), 22 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/77d57f1b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/IncrementalRocksDbBackendEventTimeWindowCheckpointingITCase.java ---------------------------------------------------------------------- diff --git a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/IncrementalRocksDbBackendEventTimeWindowCheckpointingITCase.java b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/IncrementalRocksDbBackendEventTimeWindowCheckpointingITCase.java index 716a127..352f9f7 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/IncrementalRocksDbBackendEventTimeWindowCheckpointingITCase.java +++ b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/IncrementalRocksDbBackendEventTimeWindowCheckpointingITCase.java @@ -18,9 +18,6 @@ package org.apache.flink.test.checkpointing; -import org.junit.Ignore; - -@Ignore public class IncrementalRocksDbBackendEventTimeWindowCheckpointingITCase extends AbstractEventTimeWindowCheckpointingITCase { public IncrementalRocksDbBackendEventTimeWindowCheckpointingITCase() { http://git-wip-us.apache.org/repos/asf/flink/blob/77d57f1b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/PartitionedStateCheckpointingITCase.java ---------------------------------------------------------------------- diff --git a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/PartitionedStateCheckpointingITCase.java b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/PartitionedStateCheckpointingITCase.java index 358ac91..517c82b 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/PartitionedStateCheckpointingITCase.java +++ b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/PartitionedStateCheckpointingITCase.java @@ -18,6 +18,19 @@ package org.apache.flink.test.checkpointing; +import static org.junit.Assert.assertEquals; +import static org.junit.Assert.assertTrue; + +import java.io.IOException; +import java.util.Arrays; +import java.util.Collection; +import java.util.Collections; +import java.util.List; +import java.util.Map; +import java.util.Map.Entry; +import java.util.Random; +import java.util.concurrent.ConcurrentHashMap; + import org.apache.flink.api.common.functions.RichMapFunction; import org.apache.flink.api.common.state.ValueState; import org.apache.flink.api.common.state.ValueStateDescriptor; @@ -37,19 +50,6 @@ import org.junit.rules.TemporaryFolder; import org.junit.runner.RunWith; import org.junit.runners.Parameterized; -import java.io.IOException; -import java.util.Arrays; -import java.util.Collection; -import java.util.Collections; -import java.util.List; -import java.util.Map; -import java.util.Map.Entry; -import java.util.Random; -import java.util.concurrent.ConcurrentHashMap; - -import static org.junit.Assert.assertEquals; -import static org.junit.Assert.assertTrue; - /** * A simple test that runs a streaming topology with checkpointing enabled. * @@ -88,9 +88,9 @@ public class PartitionedStateCheckpointingITCase extends StreamFaultToleranceTes syncMemBackend, asyncMemBackend, syncFsBackend, - asyncFsBackend/**, + asyncFsBackend, fullRocksDbBackend, - incRocksDbBackend**/); + incRocksDbBackend); } @Parameterized.Parameter http://git-wip-us.apache.org/repos/asf/flink/blob/77d57f1b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/RocksDbBackendEventTimeWindowCheckpointingITCase.java ---------------------------------------------------------------------- diff --git a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/RocksDbBackendEventTimeWindowCheckpointingITCase.java b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/RocksDbBackendEventTimeWindowCheckpointingITCase.java index 02bb749..da2bbc7 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/RocksDbBackendEventTimeWindowCheckpointingITCase.java +++ b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/RocksDbBackendEventTimeWindowCheckpointingITCase.java @@ -18,9 +18,6 @@ package org.apache.flink.test.checkpointing; -import org.junit.Ignore; - -@Ignore public class RocksDbBackendEventTimeWindowCheckpointingITCase extends AbstractEventTimeWindowCheckpointingITCase { public RocksDbBackendEventTimeWindowCheckpointingITCase() { http://git-wip-us.apache.org/repos/asf/flink/blob/77d57f1b/flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/PartitionerITCase.java ---------------------------------------------------------------------- diff --git a/flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/PartitionerITCase.java b/flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/PartitionerITCase.java index 35e4f9c..3a125ba 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/PartitionerITCase.java +++ b/flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/PartitionerITCase.java @@ -30,7 +30,6 @@ import org.apache.flink.streaming.util.StreamingMultipleProgramsTestBase; import org.apache.flink.test.streaming.runtime.util.NoOpIntMap; import org.apache.flink.test.streaming.runtime.util.TestListResultSink; -import org.junit.Ignore; import org.junit.Test; import java.util.Arrays;
