|
@@ -31,6 +31,7 @@ import org.apache.hadoop.fs.FileStatus;
|
|
|
import org.apache.hadoop.fs.FileSystem;
|
|
|
import org.apache.hadoop.fs.FileUtil;
|
|
|
import org.apache.hadoop.fs.Path;
|
|
|
+import org.apache.hadoop.hdfs.HdfsConfiguration;
|
|
|
import org.apache.hadoop.security.UserGroupInformation;
|
|
|
import org.apache.hadoop.yarn.client.cli.RMAdminCLI;
|
|
|
|
|
@@ -119,7 +120,7 @@ public class HadoopUtils implements Closeable {
|
|
|
*/
|
|
|
private void init() {
|
|
|
try {
|
|
|
- configuration = new Configuration();
|
|
|
+ configuration = new HdfsConfiguration();
|
|
|
|
|
|
String resourceStorageType = PropertyUtils.getUpperCaseString(Constants.RESOURCE_STORAGE_TYPE);
|
|
|
ResUploadType resUploadType = ResUploadType.valueOf(resourceStorageType);
|