diff --git a/chunjun-connectors/chunjun-connector-ftp/src/main/java/com/dtstack/chunjun/connector/ftp/sink/FtpOutputFormat.java b/chunjun-connectors/chunjun-connector-ftp/src/main/java/com/dtstack/chunjun/connector/ftp/sink/FtpOutputFormat.java
index 30eb1f27ba..6778400f8c 100644
--- a/chunjun-connectors/chunjun-connector-ftp/src/main/java/com/dtstack/chunjun/connector/ftp/sink/FtpOutputFormat.java
+++ b/chunjun-connectors/chunjun-connector-ftp/src/main/java/com/dtstack/chunjun/connector/ftp/sink/FtpOutputFormat.java
@@ -135,7 +135,7 @@ protected void closeSource() {
                 os = null;
             }
             // avoid Failure of FtpClient operating
-            this.ftpHandler.completePendingCommand();
+            this.ftpHandler.logoutFtpServer();
         } catch (Exception e) {
             throw new ChunJunRuntimeException("can't close source.", e);
         }
diff --git a/chunjun-connectors/chunjun-connector-ftp/src/main/java/com/dtstack/chunjun/connector/ftp/sink/FtpOutputFormatBuilder.java b/chunjun-connectors/chunjun-connector-ftp/src/main/java/com/dtstack/chunjun/connector/ftp/sink/FtpOutputFormatBuilder.java
index 676175513a..cddb48c3ad 100644
--- a/chunjun-connectors/chunjun-connector-ftp/src/main/java/com/dtstack/chunjun/connector/ftp/sink/FtpOutputFormatBuilder.java
+++ b/chunjun-connectors/chunjun-connector-ftp/src/main/java/com/dtstack/chunjun/connector/ftp/sink/FtpOutputFormatBuilder.java
@@ -31,9 +31,7 @@
  *
  * @author huyifan.zju@163.com
  */
-public class FtpOutputFormatBuilder extends FileOutputFormatBuilder {
-
-    private FtpOutputFormat format;
+public class FtpOutputFormatBuilder extends FileOutputFormatBuilder<FtpOutputFormat> {
 
     public FtpOutputFormatBuilder() {
         super(new FtpOutputFormat());
diff --git a/chunjun-core/src/main/java/com/dtstack/chunjun/sink/format/FileOutputFormatBuilder.java b/chunjun-core/src/main/java/com/dtstack/chunjun/sink/format/FileOutputFormatBuilder.java
index 530d5b653b..05fc9ae936 100644
--- a/chunjun-core/src/main/java/com/dtstack/chunjun/sink/format/FileOutputFormatBuilder.java
+++ b/chunjun-core/src/main/java/com/dtstack/chunjun/sink/format/FileOutputFormatBuilder.java
@@ -24,10 +24,10 @@
  *
  * @author tudou
  */
-public abstract class FileOutputFormatBuilder
-        extends BaseRichOutputFormatBuilder<BaseFileOutputFormat> {
+public abstract class FileOutputFormatBuilder<T extends BaseFileOutputFormat>
+        extends BaseRichOutputFormatBuilder<T> {
 
-    public FileOutputFormatBuilder(BaseFileOutputFormat format) {
+    public FileOutputFormatBuilder(T format) {
         super(format);
     }