From 7b5facfb90398a74df07b30c273f1ad4e64a2352 Mon Sep 17 00:00:00 2001 From: haohao0103 <956322745@qq.com> Date: Mon, 23 Oct 2023 11:14:19 +0800 Subject: [PATCH] #255 close the FileSystem Object --- spark/src/main/scala/com/alibaba/graphar/util/FileSystem.scala | 1 + 1 file changed, 1 insertion(+) diff --git a/spark/src/main/scala/com/alibaba/graphar/util/FileSystem.scala b/spark/src/main/scala/com/alibaba/graphar/util/FileSystem.scala index d1f69e096..0575e104f 100644 --- 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 = {