From 10be7809cd8bf7a86320f7034a6e8ffc3ba6dc85 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Cl=C3=A9ment=20Rodriguez?= <50376986+clemrodriguez@users.noreply.github.com> Date: Tue, 10 Sep 2019 10:21:13 +0200 Subject: [PATCH] Fix connection to early MySQL connection closure in MySQLBlockInputStream.cpp --- dbms/src/Formats/MySQLBlockInputStream.cpp | 2 -- 1 file changed, 2 deletions(-) diff --git a/dbms/src/Formats/MySQLBlockInputStream.cpp b/dbms/src/Formats/MySQLBlockInputStream.cpp index dcf609f62c..4f8291ffeb 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)); }