Fix tests.

This commit is contained in:
Nikolai Kochetov 2020-05-19 00:38:28 +03:00
parent 0ec321a811
commit 075ccceee9

View File

@ -306,7 +306,7 @@ Block InterpreterKillQueryQuery::getSelectResult(const String & columns, const S
auto stream = block_io.getInputStream(); auto stream = block_io.getInputStream();
Block res = stream->read(); Block res = stream->read();
if (res && block_io.in->read()) if (res && stream->read())
throw Exception("Expected one block from input stream", ErrorCodes::LOGICAL_ERROR); throw Exception("Expected one block from input stream", ErrorCodes::LOGICAL_ERROR);
return res; return res;