Repository: flink Updated Branches: refs/heads/release-1.3 12b941d36 -> a35664a77
[hotfix] 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/a35664a7 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a35664a7 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/a35664a7 Branch: refs/heads/release-1.3 Commit: a35664a77c6c39187411870cfd1124945dcb35a0 Parents: 12b941d Author: Stefan Richter <[email protected]> Authored: Mon May 8 11:04:51 2017 +0200 Committer: Stefan Richter <[email protected]> Committed: Mon May 8 12:01:20 2017 +0200 ---------------------------------------------------------------------- ...ckendEventTimeWindowCheckpointingITCase.java | 3 ++ .../PartitionedStateCheckpointingITCase.java | 30 ++++++++++---------- ...ckendEventTimeWindowCheckpointingITCase.java | 3 ++ .../streaming/runtime/PartitionerITCase.java | 1 + 4 files changed, 22 insertions(+), 15 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/a35664a7/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 352f9f7..716a127 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,6 +18,9 @@ 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/a35664a7/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 517c82b..358ac91 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,19 +18,6 @@ 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; @@ -50,6 +37,19 @@ 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/a35664a7/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 da2bbc7..02bb749 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,6 +18,9 @@ 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/a35664a7/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 3a125ba..35e4f9c 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,6 +30,7 @@ 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;
