Hadoop: close session (#5305)

juicedata · Nov 19, 2024 · 47b02d5 · 47b02d5
1 parent e026721
commit 47b02d5
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pkg/fs/fs.go b/pkg/fs/fs.go
@@ -873,6 +873,7 @@ func (fs *FileSystem) Flush() error {
 	if buffer != nil {
 		buffer <- "" // flush
 	}
+	fs.Meta().FlushSession()
 	return nil
 }