Fixing regex for hdfs urls

CODAIT · Feb 15, 2018 · a1975e5 · a1975e5
1 parent d4422e4
commit a1975e5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/utils/src/main/scala/com/ibm/sparktc/sparkbench/utils/SparkFuncs.scala b/utils/src/main/scala/com/ibm/sparktc/sparkbench/utils/SparkFuncs.scala
@@ -64,7 +64,7 @@ object SparkFuncs {
   }
 
   private def extractHDFSuri(str: String): Option[String] = {
-    val regx = """hdfs://(hdfs:\d+)""".r.unanchored
+    val regx = """hdfs://(\S+:\d+)""".r.unanchored
     str match {
       case regx(uri) => Some(uri)
       case _ => None