diff --git a/petastorm/fs_utils.py b/petastorm/fs_utils.py
index 38d60c31..348e12fa 100644
--- a/petastorm/fs_utils.py
+++ b/petastorm/fs_utils.py
@@ -83,8 +83,8 @@ def __init__(self, dataset_url, hadoop_configuration=None, connector=HdfsConnect
 
         elif self._parsed_dataset_url.scheme == 'file':
             # Case 2: definitely local
-            self._filesystem = pyarrow.localfs
-            self._filesystem_factory = lambda: pyarrow.localfs
+            self._filesystem = pyarrow.fs.LocalFileSystem
+            self._filesystem_factory = lambda: pyarrow.fs.LocalFileSystem
 
         elif self._parsed_dataset_url.scheme == 'hdfs':