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 2017/09/27 11:09:18 UTC
[13/20] flink git commit: [FLINK-2268] Don't use Hadoop FileSystem in
RocksDB tests
[FLINK-2268] Don't use Hadoop FileSystem in RocksDB tests
This was in there because of legacy reasons but is not required by the
test.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/712db79b
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/712db79b
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/712db79b
Branch: refs/heads/master
Commit: 712db79b2630ba61023a11f929e2d47b83dcef0b
Parents: d5866ad
Author: Aljoscha Krettek <al...@gmail.com>
Authored: Tue Aug 22 16:50:18 2017 +0200
Committer: Aljoscha Krettek <al...@gmail.com>
Committed: Wed Sep 27 10:05:11 2017 +0200
----------------------------------------------------------------------
.../streaming/state/RocksDBAsyncSnapshotTest.java | 15 ---------------
1 file changed, 15 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/712db79b/flink-contrib/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBAsyncSnapshotTest.java
----------------------------------------------------------------------
diff --git a/flink-contrib/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBAsyncSnapshotTest.java b/flink-contrib/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBAsyncSnapshotTest.java
index 98208fd..1f1b65a 100644
--- a/flink-contrib/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBAsyncSnapshotTest.java
+++ b/flink-contrib/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBAsyncSnapshotTest.java
@@ -56,22 +56,16 @@ import org.apache.flink.streaming.runtime.tasks.StreamMockEnvironment;
import org.apache.flink.streaming.runtime.tasks.StreamTask;
import org.apache.flink.util.FutureUtil;
-import org.apache.hadoop.conf.Configuration;
-import org.apache.hadoop.fs.FileSystem;
-import org.apache.hadoop.fs.LocalFileSystem;
import org.junit.Assert;
import org.junit.Ignore;
import org.junit.Test;
import org.junit.runner.RunWith;
-import org.powermock.api.mockito.PowerMockito;
import org.powermock.core.classloader.annotations.PowerMockIgnore;
-import org.powermock.core.classloader.annotations.PrepareForTest;
import org.powermock.modules.junit4.PowerMockRunner;
import java.io.File;
import java.io.IOException;
import java.lang.reflect.Field;
-import java.net.URI;
import java.util.Arrays;
import java.util.Map;
import java.util.UUID;
@@ -96,7 +90,6 @@ import static org.mockito.Mockito.verify;
* Tests for asynchronous RocksDB Key/Value state checkpoints.
*/
@RunWith(PowerMockRunner.class)
-@PrepareForTest({FileSystem.class})
@PowerMockIgnore({"javax.management.*", "com.sun.jndi.*", "org.apache.log4j.*"})
@SuppressWarnings("serial")
public class RocksDBAsyncSnapshotTest {
@@ -111,10 +104,6 @@ public class RocksDBAsyncSnapshotTest {
@Test
public void testFullyAsyncSnapshot() throws Exception {
- LocalFileSystem localFS = new LocalFileSystem();
- localFS.initialize(new URI("file:///"), new Configuration());
- PowerMockito.stub(PowerMockito.method(FileSystem.class, "get", URI.class, Configuration.class)).toReturn(localFS);
-
final OneInputStreamTask<String, String> task = new OneInputStreamTask<>();
final OneInputStreamTaskTestHarness<String, String> testHarness = new OneInputStreamTaskTestHarness<>(task, BasicTypeInfo.STRING_TYPE_INFO, BasicTypeInfo.STRING_TYPE_INFO);
@@ -222,10 +211,6 @@ public class RocksDBAsyncSnapshotTest {
@Test
@Ignore
public void testCancelFullyAsyncCheckpoints() throws Exception {
- LocalFileSystem localFS = new LocalFileSystem();
- localFS.initialize(new URI("file:///"), new Configuration());
- PowerMockito.stub(PowerMockito.method(FileSystem.class, "get", URI.class, Configuration.class)).toReturn(localFS);
-
final OneInputStreamTask<String, String> task = new OneInputStreamTask<>();
final OneInputStreamTaskTestHarness<String, String> testHarness = new OneInputStreamTaskTestHarness<>(task, BasicTypeInfo.STRING_TYPE_INFO, BasicTypeInfo.STRING_TYPE_INFO);