You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by sr...@apache.org on 2017/05/09 09:25:56 UTC
flink git commit: [hotfix] Revert: Temporarily deactivate RocksDB
checkpointing tests
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 <s....@data-artisans.com>
Authored: Tue May 9 11:25:28 2017 +0200
Committer: Stefan Richter <s....@data-artisans.com>
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;