diff --git a/dbms/src/Formats/MySQLBlockInputStream.cpp b/dbms/src/Formats/MySQLBlockInputStream.cpp
index dcf609f62ce..4f8291ffebe 100644
--- a/dbms/src/Formats/MySQLBlockInputStream.cpp
+++ b/dbms/src/Formats/MySQLBlockInputStream.cpp
@@ -131,8 +131,6 @@ Block MySQLBlockInputStream::readImpl()
 
         row = result.fetch();
     }
-    if (auto_close)
-        entry.disconnect();
     return description.sample_block.cloneWithColumns(std::move(columns));
 }