Fix incorrect unit test

This commit is contained in:
Alexey Milovidov 2020-07-16 05:37:12 +03:00
parent a6016b95ce
commit 82ea884d01

View File

@ -100,6 +100,7 @@ std::string writeData(int rows, DB::StoragePtr & table, const DB::Context & cont
BlockOutputStreamPtr out = table->write({}, metadata_snapshot, context); BlockOutputStreamPtr out = table->write({}, metadata_snapshot, context);
out->write(block); out->write(block);
out->writeSuffix();
return data; return data;
} }
@ -115,7 +116,8 @@ std::string readData(DB::StoragePtr & table, const DB::Context & context)
QueryProcessingStage::Enum stage = table->getQueryProcessingStage(context); QueryProcessingStage::Enum stage = table->getQueryProcessingStage(context);
BlockInputStreamPtr in = std::make_shared<TreeExecutorBlockInputStream>(std::move(table->read(column_names, metadata_snapshot, {}, context, stage, 8192, 1)[0])); BlockInputStreamPtr in = std::make_shared<TreeExecutorBlockInputStream>(
std::move(table->read(column_names, metadata_snapshot, {}, context, stage, 8192, 1)[0]));
Block sample; Block sample;
{ {