thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-10 01:25:21 +00:00
Code Issues Packages Projects Releases Wiki Activity

upd

Browse Source
This commit is contained in:
vdimir 2023-10-23 10:36:09 +00:00
parent d254c4e4a0
commit 3332f70275
No known key found for this signature in database
GPG Key ID: 6EE4CE2BEDC51862
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/Interpreters/InterpreterCheckQuery.cpp
View File

@ -80,7 +80,7 @@ protected:
return {};
/// We can omit manual `progess` call, ISource will may count it automatically by returned chunk
/// However, we want to report only rows in progress
/// However, we want to report only rows in progress, since bytes doesn't make sense here
progress(1, 0);
if (!check_result->success)
@ -184,9 +184,10 @@ BlockIO InterpreterCheckQuery::execute()
auto resize_inport_it = resize_inputs.begin();
for (size_t i = 0; i < worker_ports.size(); ++i, ++resize_inport_it)
connect(*worker_ports[i], *resize_inport_it);
resize_outport = &resize_processor->getOutputs().front();
processors->emplace_back(resize_processor);
assert(resize_processor->getOutputs().size() == 1);
resize_outport = &resize_processor->getOutputs().front();
}
if (settings.check_query_single_value_result)

1
tests/integration/test_check_table/test.py
View File

@ -141,7 +141,6 @@ def test_check_normal_table_corruption(started_cluster):
).strip().split("\t")[0:2] == ["201901_2_2_0", "0"]
def test_check_replicated_table_simple(started_cluster):
for node in [node1, node2]:
node.query("DROP TABLE IF EXISTS replicated_mt")