[FLINK-3400] Move RocksDB Copy Utils to flink-streaming-java

They are not specific to RocksDB, just utilities for copying local folders to/from HDFS. Moving them to flink-streaming-java means that they are always in the classpath of the TaskManager, not only in the user-code jar when using RocksDB. If they are only in the user-code jar the external process runner cannot find the class files, leading to ClassNotFoundExceptions.
apache · Feb 17, 2016 · c97a63e · c97a63e
1 parent cee135a
commit c97a63e
Show file tree

Hide file tree

Showing 4 changed files with 5 additions and 3 deletions.
diff --git a/...-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/AbstractRocksDBState.java b/...-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/AbstractRocksDBState.java
@@ -29,6 +29,8 @@
 import org.apache.flink.runtime.state.KvState;
 import org.apache.flink.runtime.state.KvStateSnapshot;
 
+import org.apache.flink.streaming.util.HDFSCopyFromLocal;
+import org.apache.flink.streaming.util.HDFSCopyToLocal;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.fs.FileSystem;
 import org.apache.hadoop.fs.Path;

diff --git a/...ib/streaming/state/HDFSCopyFromLocal.java → ...ink/streaming/util/HDFSCopyFromLocal.java b/...ib/streaming/state/HDFSCopyFromLocal.java → ...ink/streaming/util/HDFSCopyFromLocal.java
@@ -15,7 +15,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.apache.flink.contrib.streaming.state;
+package org.apache.flink.streaming.util;
 
 import org.apache.flink.util.ExternalProcessRunner;
 import org.apache.hadoop.conf.Configuration;

diff --git a/...trib/streaming/state/HDFSCopyToLocal.java → ...flink/streaming/util/HDFSCopyToLocal.java b/...trib/streaming/state/HDFSCopyToLocal.java → ...flink/streaming/util/HDFSCopyToLocal.java
@@ -15,7 +15,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.apache.flink.contrib.streaming.state;
+package org.apache.flink.streaming.util;
 
 import org.apache.flink.util.ExternalProcessRunner;
 import org.apache.hadoop.conf.Configuration;

diff --git a/...treaming/state/HDFSCopyUtilitiesTest.java → ...streaming/util/HDFSCopyUtilitiesTest.java b/...treaming/state/HDFSCopyUtilitiesTest.java → ...streaming/util/HDFSCopyUtilitiesTest.java
@@ -15,7 +15,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.apache.flink.contrib.streaming.state;
+package org.apache.flink.streaming.util;
 
 import org.apache.hadoop.conf.Configuration;
 import org.junit.Rule;