From a1975e52a2167dc3609e615753928ada29a96a8e Mon Sep 17 00:00:00 2001 From: Emily Curtin Date: Thu, 15 Feb 2018 15:38:29 -0500 Subject: [PATCH] Fixing regex for hdfs urls --- .../scala/com/ibm/sparktc/sparkbench/utils/SparkFuncs.scala | 2 +- 1 file changed, 1 insertion(+), 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 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