Repository: flink Updated Branches: refs/heads/release-1.3 062163344 -> b412e530d
[FLINK-6008] Use Flink's FileUtils in BlobUtils to have proper exception handling Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b412e530 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b412e530 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/b412e530 Branch: refs/heads/release-1.3 Commit: b412e530d58f71f2c881199c66fb73c0f81583f2 Parents: 0621633 Author: Till Rohrmann <[email protected]> Authored: Thu May 11 11:22:09 2017 +0200 Committer: Till Rohrmann <[email protected]> Committed: Thu May 11 12:15:07 2017 +0200 ---------------------------------------------------------------------- .../src/main/java/org/apache/flink/runtime/blob/BlobUtils.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/b412e530/flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobUtils.java ---------------------------------------------------------------------- diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobUtils.java b/flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobUtils.java index b0cab78..3c14f2f 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobUtils.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobUtils.java @@ -19,13 +19,13 @@ package org.apache.flink.runtime.blob; import com.google.common.io.BaseEncoding; -import org.apache.commons.io.FileUtils; import org.apache.flink.api.common.JobID; import org.apache.flink.configuration.ConfigConstants; import org.apache.flink.configuration.Configuration; import org.apache.flink.configuration.IllegalConfigurationException; import org.apache.flink.runtime.highavailability.zookeeper.ZooKeeperHaServices; import org.apache.flink.runtime.jobmanager.HighAvailabilityMode; +import org.apache.flink.util.FileUtils; import org.apache.flink.util.StringUtils; import org.slf4j.Logger;
