Fixes #126

SIDN · Jun 9, 2020 · 4c8dac4 · 4c8dac4
1 parent 9779df7
commit 4c8dac4
Showing 1 changed file with 7 additions and 9 deletions.
diff --git a/src/main/java/nl/sidnlabs/entrada/file/HDFSFileManagerImpl.java b/src/main/java/nl/sidnlabs/entrada/file/HDFSFileManagerImpl.java
@@ -64,17 +64,15 @@ public String schema() {
   @Override
   public void close() {
     // close filesystem
-    if (fs == null) {
-      // do nothing, not using hdfs fs
-      return;
+    if (fs != null) {
+      try {
+        fs.close();
+        fs = null;
+      } catch (Exception e) {
+        log.error("Error while closing filesystem", e);
+      }
     }
 
-    try {
-      fs.close();
-      fs = null;
-    } catch (Exception e) {
-      log.error("Error while closing filesystem", e);
-    }
     // close filesystem internal cache
     try {
       FileSystem.closeAll();