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 2016/04/28 14:15:41 UTC
flink git commit: [FLINK-3840] Remove Testing Files in RocksDB Backend
Repository: flink
Updated Branches:
refs/heads/master 4f5dbc2ed -> a1968f03e
[FLINK-3840] Remove Testing Files in RocksDB Backend
We create random files on initialization to check whether we can write
to the data directory. These files are also removed now.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a1968f03
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a1968f03
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/a1968f03
Branch: refs/heads/master
Commit: a1968f03e7c57f69163459625ca168add4c4822c
Parents: 4f5dbc2
Author: Aljoscha Krettek <al...@gmail.com>
Authored: Thu Apr 28 10:02:26 2016 +0200
Committer: Aljoscha Krettek <al...@gmail.com>
Committed: Thu Apr 28 10:02:26 2016 +0200
----------------------------------------------------------------------
.../apache/flink/contrib/streaming/state/RocksDBStateBackend.java | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/a1968f03/flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackend.java
----------------------------------------------------------------------
diff --git a/flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackend.java b/flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackend.java
index 99ee1cd..4b7d7ee 100644
--- a/flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackend.java
+++ b/flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackend.java
@@ -248,6 +248,7 @@ public class RocksDBStateBackend extends AbstractStateBackend {
} else {
dirs.add(f);
}
+ testDir.delete();
}
if (dirs.isEmpty()) {