[EXPORTER] Close fs in Task.close() (opensource4you#1819)

* close fs in Task.close() * using Utils.close()
garyparrot · Jun 21, 2023 · e5721e1 · e5721e1
1 parent cdde1b0
commit e5721e1
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/connector/src/main/java/org/astraea/connector/backup/Exporter.java b/connector/src/main/java/org/astraea/connector/backup/Exporter.java
@@ -408,6 +408,7 @@ private void checkSeekOffset(Record<byte[], byte[]> r) {
     protected void close() {
       this.closed.set(true);
       Utils.packException(() -> writerFuture.toCompletableFuture().get(10, TimeUnit.SECONDS));
+      Utils.close(this.fs);
     }
 
     boolean isWriterDone() {