From 1749224055b0af9f3046780159c45063c081d659 Mon Sep 17 00:00:00 2001 From: zhangminglei Date: Thu, 29 Jun 2017 13:50:51 +0800 Subject: [PATCH] [FLINK-5842] [runtime] Uncomment and activate code in HadoopFileSystem --- .../flink/runtime/fs/hdfs/HadoopFileSystem.java | 13 ++++++------- 1 file changed, 6 insertions(+), 7 deletions(-) diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopFileSystem.java b/flink-runtime/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopFileSystem.java index 1371d21f02aa3..3b60c1861357f 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopFileSystem.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopFileSystem.java @@ -467,13 +467,12 @@ public boolean isDistributedFS() { public Class getHadoopWrapperClassNameForFileSystem(String scheme) { Configuration hadoopConf = getHadoopConfiguration(); Class clazz; - // We can activate this block once we drop Hadoop1 support (only hd2 has the getFileSystemClass-method) -// try { -// clazz = org.apache.hadoop.fs.FileSystem.getFileSystemClass(scheme, hadoopConf); -// } catch (IOException e) { -// LOG.info("Flink could not load the Hadoop File system implementation for scheme "+scheme); -// return null; -// } + try { + clazz = org.apache.hadoop.fs.FileSystem.getFileSystemClass(scheme, hadoopConf); + } catch (IOException e) { + LOG.info("Flink could not load the Hadoop File system implementation for scheme "+scheme); + return null; + } clazz = hadoopConf.getClass("fs." + scheme + ".impl", null, org.apache.hadoop.fs.FileSystem.class); if(clazz != null && LOG.isDebugEnabled()) {