flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From srich...@apache.org
Subject flink git commit: [hotfix] Revert: Temporarily deactivate RocksDB checkpointing tests
Date Tue, 09 May 2017 09:25:56 GMT
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.richter@data-artisans.com>
Authored: Tue May 9 11:25:28 2017 +0200
Committer: Stefan Richter <s.richter@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;


Mime
View raw message