Просмотр исходного кода

AMBARI-13844. Support WebHDFS over SSL in Ambari Views. (Gaurav Nagar via dipayanb)

Dipayan Bhowmick 9 лет назад
Родитель
Сommit
ada7f51b27

+ 5 - 0
contrib/views/hive/src/test/java/org/apache/ambari/view/hive/PropertyValidatorTest.java

@@ -65,6 +65,11 @@ public class PropertyValidatorTest {
 
     definition.getPropertyMap().put(PropertyValidator.WEBHDFS_URL, "webhdfs://hostname.internal:50070");
 
+    assertTrue(validator.validateProperty(PropertyValidator.WEBHDFS_URL,
+        definition, Validator.ValidationContext.PRE_CREATE).isValid());
+
+    definition.getPropertyMap().put(PropertyValidator.WEBHDFS_URL, "swebhdfs://hostname.internal:50070");
+
     assertTrue(validator.validateProperty(PropertyValidator.WEBHDFS_URL,
         definition, Validator.ValidationContext.PRE_CREATE).isValid());
 

+ 1 - 1
contrib/views/utils/src/main/java/org/apache/ambari/view/utils/ambari/ValidatorUtils.java

@@ -29,7 +29,7 @@ public class ValidatorUtils {
    * @return is url valid
    */
   public static boolean validateHdfsURL(String webhdfsUrl) {
-    String[] schemes = {"webhdfs", "hdfs", "s3","wasb"};
+    String[] schemes = {"webhdfs", "hdfs", "s3","wasb","swebhdfs"};
     return validateURL(webhdfsUrl, schemes);
   }
 

+ 3 - 1
contrib/views/utils/src/main/java/org/apache/ambari/view/utils/hdfs/ConfigurationBuilder.java

@@ -26,6 +26,7 @@ import org.apache.hadoop.fs.LocalFileSystem;
 import org.apache.hadoop.fs.azure.NativeAzureFileSystem;
 import org.apache.hadoop.fs.azure.Wasb;
 import org.apache.hadoop.hdfs.DistributedFileSystem;
+import org.apache.hadoop.hdfs.web.SWebHdfsFileSystem;
 import org.apache.hadoop.hdfs.web.WebHdfsFileSystem;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -233,7 +234,8 @@ public class ConfigurationBuilder {
     conf.set("fs.hdfs.impl", DistributedFileSystem.class.getName());
     conf.set("fs.webhdfs.impl", WebHdfsFileSystem.class.getName());
     conf.set("fs.file.impl", LocalFileSystem.class.getName());
-
+    conf.set("fs.swebhdfs.impl", SWebHdfsFileSystem.class.getName());
+    
     configureWASB();
 
     return conf;