fix fs infer (#74)

sadikovi · Jun 22, 2017 · a78ed1a · a78ed1a
1 parent 1af9de3
commit a78ed1a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/scala/com/github/sadikovi/spark/netflow/DefaultSource.scala b/src/main/scala/com/github/sadikovi/spark/netflow/DefaultSource.scala
@@ -157,8 +157,8 @@ class DefaultSource extends FileFormat with DataSourceRegister {
       val opts = optsBroadcast.value
       val conf = confBroadcast.value.value
 
-      val fs = FileSystem.get(conf)
       val path = new Path(file.filePath)
+      val fs = path.getFileSystem(conf)
       val fileLength = file.length
 
       // Prepare file stream