clickhouse: fixed arrayJoin with distributed tables [#CONV-7444].

This commit is contained in:
Michael Kolupaev 2013-06-17 14:57:03 +00:00
parent 106c3aad4a
commit c5a92790db

View File

@ -210,6 +210,11 @@ BlockInputStreamPtr InterpreterSelectQuery::execute()
final_projection = chain.getLastActions();
chain.finalize();
/// Если предыдущая стадия запроса выполнялась отдельно, нам могли дать лишних столбцов (например, используемых только в секции WHERE).
/// Уберем их. Они могут существенно мешать, например, при arrayJoin.
if (from_stage == QueryProcessingStage::WithMergeableState)
before_order_and_select->prependProjectInput();
/// Перед выполнением HAVING уберем из блока лишние столбцы (в основном, ключи агрегации).
if (has_having)
before_having->prependProjectInput();