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 index 932216b5..e7713152 100644 --- 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