From a78ed1a0ae6fd39f817a8e69a60f8c2da534c5b5 Mon Sep 17 00:00:00 2001 From: Ivan Date: Fri, 23 Jun 2017 08:36:52 +1000 Subject: [PATCH] fix fs infer (#74) --- .../scala/com/github/sadikovi/spark/netflow/DefaultSource.scala | 2 +- 1 file changed, 1 insertion(+), 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 index 80983b6..2f7afc7 100644 --- 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