mirror of
https://github.com/ClickHouse/ClickHouse.git
synced 2024-11-21 15:12:02 +00:00
Get back 01555_system_distribution_queue_mask
This reverts commit bfb330452c
.
Since now use_compact_format_in_distributed_parts_names works on fly for
internal_replication=true.
This commit is contained in:
parent
04db0834bf
commit
34d882b7d3
@ -0,0 +1,4 @@
|
|||||||
|
masked
|
||||||
|
3,"default:*@127%2E0%2E0%2E1:9000,default:*@127%2E0%2E0%2E2:9000"
|
||||||
|
no masking
|
||||||
|
1,"default@localhost:9000"
|
@ -0,0 +1,36 @@
|
|||||||
|
-- force data path with the user/pass in it
|
||||||
|
set use_compact_format_in_distributed_parts_names=0;
|
||||||
|
-- use async send even for localhost
|
||||||
|
set prefer_localhost_replica=0;
|
||||||
|
|
||||||
|
drop table if exists dist_01555;
|
||||||
|
drop table if exists data_01555;
|
||||||
|
create table data_01555 (key Int) Engine=Null();
|
||||||
|
|
||||||
|
--
|
||||||
|
-- masked
|
||||||
|
--
|
||||||
|
SELECT 'masked';
|
||||||
|
create table dist_01555 (key Int) Engine=Distributed(test_cluster_with_incorrect_pw, currentDatabase(), data_01555, key);
|
||||||
|
|
||||||
|
insert into dist_01555 values (1)(2);
|
||||||
|
-- since test_cluster_with_incorrect_pw contains incorrect password ignore error
|
||||||
|
system flush distributed dist_01555; -- { serverError 516; }
|
||||||
|
select length(splitByChar('*', data_path)), replaceRegexpOne(data_path, '^.*/([^/]*)/' , '\\1') from system.distribution_queue where database = currentDatabase() and table = 'dist_01555' format CSV;
|
||||||
|
|
||||||
|
drop table dist_01555;
|
||||||
|
|
||||||
|
--
|
||||||
|
-- no masking
|
||||||
|
--
|
||||||
|
SELECT 'no masking';
|
||||||
|
create table dist_01555 (key Int) Engine=Distributed(test_shard_localhost, currentDatabase(), data_01555, key);
|
||||||
|
|
||||||
|
insert into dist_01555 values (1)(2);
|
||||||
|
-- since test_cluster_with_incorrect_pw contains incorrect password ignore error
|
||||||
|
system flush distributed dist_01555;
|
||||||
|
select length(splitByChar('*', data_path)), replaceRegexpOne(data_path, '^.*/([^/]*)/' , '\\1') from system.distribution_queue where database = currentDatabase() and table = 'dist_01555' format CSV;
|
||||||
|
|
||||||
|
-- cleanup
|
||||||
|
drop table dist_01555;
|
||||||
|
drop table data_01555;
|
Loading…
Reference in New Issue
Block a user