diff --git a/src/main/java/org/embulk/output/sftp/provider/sftp/SftpFileProvider.java b/src/main/java/org/embulk/output/sftp/provider/sftp/SftpFileProvider.java index 30fc6f3..aa5cfee 100644 --- a/src/main/java/org/embulk/output/sftp/provider/sftp/SftpFileProvider.java +++ b/src/main/java/org/embulk/output/sftp/provider/sftp/SftpFileProvider.java @@ -79,7 +79,7 @@ protected FileSystem doCreateFileSystem(final FileName name, final FileSystemOpt throw new FileSystemException("vfs.provider.sftp/connect.error", name, e); } finally { - if(session != null && session.isConnected()){ + if (session != null && session.isConnected()) { session.disconnect(); } UserAuthenticatorUtils.cleanup(authData);