fixed test aggregating_stream. [#METR-9365]

This commit is contained in:
Michael Kolupaev 2014-02-28 13:28:53 +04:00
parent 6bfb411b51
commit 60a03ff451

View File

@ -93,7 +93,7 @@ int main(int argc, char ** argv)
}
DB::BlockInputStreamPtr stream = new DB::OneBlockInputStream(block);
stream = new DB::AggregatingBlockInputStream(stream, key_column_numbers, aggregate_descriptions, false, false, true, 0, DB::OverflowMode::THROW);
stream = new DB::AggregatingBlockInputStream(stream, key_column_numbers, aggregate_descriptions, false, true, 0, DB::OverflowMode::THROW);
DB::WriteBufferFromOStream ob(std::cout);
DB::RowOutputStreamPtr row_out = new DB::TabSeparatedRowOutputStream(ob, sample);