Removed synchronized, Path.getFileSystem is threadsafe

markhamstra · Oct 24, 2014 · e4bee20 · e4bee20
1 parent 55514e2
commit e4bee20
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/streaming/src/main/scala/org/apache/spark/streaming/util/HdfsUtils.scala b/streaming/src/main/scala/org/apache/spark/streaming/util/HdfsUtils.scala
@@ -60,7 +60,7 @@ private[streaming] object HdfsUtils {
     blockLocs.map(_.flatMap(_.getHosts))
   }
 
-  def getFileSystemForPath(path: Path, conf: Configuration): FileSystem = synchronized {
+  def getFileSystemForPath(path: Path, conf: Configuration): FileSystem = {
     // For local file systems, return the raw loca file system, such calls to flush()
     // actually flushes the stream.
     val fs = path.getFileSystem(conf)