Try to fix tests.

This commit is contained in:
Nikolai Kochetov 2020-01-24 12:09:47 +03:00
parent 4a4de82648
commit 0bfc267f4b

View File

@ -119,7 +119,12 @@ BlockIO InterpreterInsertQuery::execute()
out_streams_size = std::min(size_t(settings.max_insert_threads), in_streams.size());
}
else
in_streams.emplace_back(interpreter_select.execute().in);
{
res = interpreter_select.execute();
in_streams.emplace_back(res.in);
res.in = nullptr;
res.out = nullptr;
}
}
BlockOutputStreams out_streams;