thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-24 18:50:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

Try fix tests.

Browse Source
This commit is contained in:
Nikolai Kochetov 2020-03-26 22:15:14 +03:00
parent af7f3fc251
commit d1d54ab1df
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
dbms/src/Processors/Merges/IMergingTransform.cpp
View File

@ -99,7 +99,7 @@ IProcessor::Status IMergingTransform::prepareInitializeInputs()
if (input.isFinished())
continue;
if (!input_states[i].is_initialized)
if (input_states[i].is_initialized)
{
// input.setNotNeeded();
continue;

4
dbms/src/Processors/Merges/MergingSortedTransform.cpp
View File

@ -116,7 +116,7 @@ void MergingSortedTransform::merge(TSortingHeap & queue)
return false;
}
return merged_data.hasEnoughRows();
return !merged_data.hasEnoughRows();
};
/// Take rows in required order and put them into `merged_data`, while the rows are no more than `max_block_size`
@ -218,7 +218,7 @@ void MergingSortedTransform::onFinish()
if (quiet)
return;
auto * log = &Logger::get("MergingSortedBlockInputStream");
auto * log = &Logger::get("MergingSortedTransform");
double seconds = total_stopwatch.elapsedSeconds();