diff --git a/dbms/src/Storages/MergeTree/MergeTreeDataSelectExecutor.cpp b/dbms/src/Storages/MergeTree/MergeTreeDataSelectExecutor.cpp index f7bda85653c182fcd261769f23e1a4d55af88b5c..33b5ac4999d44312182abd25ff9580d4531dcc47 100644 --- a/dbms/src/Storages/MergeTree/MergeTreeDataSelectExecutor.cpp +++ b/dbms/src/Storages/MergeTree/MergeTreeDataSelectExecutor.cpp @@ -1272,8 +1272,8 @@ MarkRanges MergeTreeDataSelectExecutor::filterMarksUsingIndex( const size_t min_marks_for_seek = roundRowsOrBytesToMarks( settings.merge_tree_min_rows_for_seek, settings.merge_tree_min_bytes_for_seek, - part->index_granularity_info.index_granularity_bytes, - part->index_granularity_info.fixed_index_granularity); + part->index_granularity_info.fixed_index_granularity, + part->index_granularity_info.index_granularity_bytes); size_t granules_dropped = 0; diff --git a/dbms/src/Storages/StorageDistributed.cpp b/dbms/src/Storages/StorageDistributed.cpp index ddf727c21def87ec34cea0b14f856fbbaf661afc..3dabc4aa701ec25be63c954a7fa0ab82d39a363c 100644 --- a/dbms/src/Storages/StorageDistributed.cpp +++ b/dbms/src/Storages/StorageDistributed.cpp @@ -399,7 +399,7 @@ BlockInputStreams StorageDistributed::read( if (force) { std::stringstream exception_message; - if (has_sharding_key) + if (!has_sharding_key) exception_message << "No sharding key"; else exception_message << "Sharding key " << sharding_key_column_name << " is not used"; diff --git a/dbms/tests/queries/0_stateless/01071_force_optimize_skip_unused_shards.sql b/dbms/tests/queries/0_stateless/01071_force_optimize_skip_unused_shards.sql index f12d5f8846d680d95cc5a906528bf5a167876923..8a2ed3ca0f9f98b817fe3004ec1c4ac367d6f7b1 100644 --- a/dbms/tests/queries/0_stateless/01071_force_optimize_skip_unused_shards.sql +++ b/dbms/tests/queries/0_stateless/01071_force_optimize_skip_unused_shards.sql @@ -1,26 +1,26 @@ set optimize_skip_unused_shards=1; -drop table if exists data_01068; -drop table if exists dist_01068; +drop table if exists data_01071; +drop table if exists dist_01071; -create table data_01068 (key Int) Engine=Null(); +create table data_01071 (key Int) Engine=Null(); -create table dist_01068 as data_01068 Engine=Distributed(test_cluster_two_shards, currentDatabase(), data_01068); +create table dist_01071 as data_01071 Engine=Distributed(test_cluster_two_shards, currentDatabase(), data_01071); set force_optimize_skip_unused_shards=0; -select * from dist_01068; +select * from dist_01071; set force_optimize_skip_unused_shards=1; -select * from dist_01068; +select * from dist_01071; set force_optimize_skip_unused_shards=2; -select * from dist_01068; -- { serverError 507 } +select * from dist_01071; -- { serverError 507 } -drop table if exists dist_01068; -create table dist_01068 as data_01068 Engine=Distributed(test_cluster_two_shards, currentDatabase(), data_01068, key%2); +drop table if exists dist_01071; +create table dist_01071 as data_01071 Engine=Distributed(test_cluster_two_shards, currentDatabase(), data_01071, key%2); set force_optimize_skip_unused_shards=0; -select * from dist_01068; +select * from dist_01071; set force_optimize_skip_unused_shards=1; -select * from dist_01068; -- { serverError 507 } +select * from dist_01071; -- { serverError 507 } set force_optimize_skip_unused_shards=2; -select * from dist_01068; -- { serverError 507 } +select * from dist_01071; -- { serverError 507 } -drop table if exists data_01068; -drop table if exists dist_01068; +drop table if exists data_01071; +drop table if exists dist_01071;