[BugFix][Spark] Close the FileSystem Object

apache · Oct 23, 2023 · 375241c · 375241c
1 parent ea34615
commit 375241c
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/spark/src/main/scala/com/alibaba/graphar/util/FileSystem.scala b/spark/src/main/scala/com/alibaba/graphar/util/FileSystem.scala
@@ -109,6 +109,7 @@ object FileSystem {
     // consistent with c++ library, convert to little-endian
     output.writeLong(java.lang.Long.reverseBytes(value))
     output.close()
+    fs.close()
   }
 
   def readValue(inputPath: String, hadoopConfig: Configuration): Long = {