[flink] 04/04: [hotfix][state-backends] Simple cleanups in RocksDBStateBackend

[sewen]

This is an automated email from the ASF dual-hosted git repository.

sewen pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 88c206dd8e4d29739b9fe3c140754b7907e93163
Author: Stephan Ewen <se...@apache.org>
AuthorDate: Wed Dec 4 12:43:28 2019 +0100

    [hotfix][state-backends] Simple cleanups in RocksDBStateBackend
---
 .../org/apache/flink/contrib/streaming/state/RocksDBStateBackend.java | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git 
a/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackend.java
 
b/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackend.java
index c5604e5..ab48c68 100644
--- 
a/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackend.java
+++ 
b/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackend.java
@@ -213,7 +213,6 @@ public class RocksDBStateBackend extends 
AbstractStateBackend implements Configu
         * @param checkpointDataUri The URI describing the filesystem and path 
to the checkpoint data directory.
         * @throws IOException Thrown, if no file system can be found for the 
scheme in the URI.
         */
-       @SuppressWarnings("deprecation")
        public RocksDBStateBackend(URI checkpointDataUri) throws IOException {
                this(new FsStateBackend(checkpointDataUri));
        }
@@ -231,7 +230,6 @@ public class RocksDBStateBackend extends 
AbstractStateBackend implements Configu
         * @param enableIncrementalCheckpointing True if incremental 
checkpointing is enabled.
         * @throws IOException Thrown, if no file system can be found for the 
scheme in the URI.
         */
-       @SuppressWarnings("deprecation")
        public RocksDBStateBackend(URI checkpointDataUri, boolean 
enableIncrementalCheckpointing) throws IOException {
                this(new FsStateBackend(checkpointDataUri), 
enableIncrementalCheckpointing);
        }
@@ -857,7 +855,7 @@ public class RocksDBStateBackend extends 
AbstractStateBackend implements Configu
        //  static library loading utilities
        // 
------------------------------------------------------------------------
 
-       private void ensureRocksDBIsLoaded(String tempDirectory) throws 
IOException {
+       private static void ensureRocksDBIsLoaded(String tempDirectory) throws 
IOException {
                synchronized (RocksDBStateBackend.class) {
                        if (!rocksDbInitialized) {