diff --git a/tests/queries/0_stateless/02972_insert_deduplication_token_hierarchical_inserts.reference b/tests/queries/0_stateless/02972_insert_deduplication_token_hierarchical_inserts.reference index b0aa78d061c4..71c9053d644a 100644 --- a/tests/queries/0_stateless/02972_insert_deduplication_token_hierarchical_inserts.reference +++ b/tests/queries/0_stateless/02972_insert_deduplication_token_hierarchical_inserts.reference @@ -7,9 +7,3 @@ ds_3_1 all_1_1_0 0 ds_3_1 all_2_2_0 0 landing all_1_1_0 0 10 ------ -0 -ds_1_1_fix all_1_1_0 0 -ds_1_1_fix all_2_2_0 0 -landing_fix all_1_1_0 0 -10 diff --git a/tests/queries/0_stateless/02972_insert_deduplication_token_hierarchical_inserts.sql b/tests/queries/0_stateless/02972_insert_deduplication_token_hierarchical_inserts.sql index c033b500e141..242133e9122d 100644 --- a/tests/queries/0_stateless/02972_insert_deduplication_token_hierarchical_inserts.sql +++ b/tests/queries/0_stateless/02972_insert_deduplication_token_hierarchical_inserts.sql @@ -101,54 +101,3 @@ DROP VIEW mv_2_2; DROP TABLE ds_3_1; DROP VIEW mv_3_1; - -SELECT '-----'; - -DROP TABLE IF EXISTS landing_fix; -CREATE TABLE landing_fix -( - timestamp UInt64, - value UInt64 -) -ENGINE = MergeTree ORDER BY tuple() SETTINGS non_replicated_deduplication_window = 1000; - -DROP TABLE IF EXISTS ds_1_1_fix; -CREATE TABLE ds_1_1_fix -( - t UInt64, - v UInt64 -) -ENGINE = MergeTree ORDER BY tuple() SETTINGS non_replicated_deduplication_window = 1000; - -DROP VIEW IF EXISTS mv_1_1; -CREATE MATERIALIZED VIEW mv_1_1 TO ds_1_1_fix as -SELECT - timestamp t, sum(value) v -FROM landing_fix -GROUP BY t; - -DROP VIEW IF EXISTS mv_1_2; -CREATE MATERIALIZED VIEW mv_1_2 TO ds_1_1_fix as -SELECT - timestamp t, sum(value) v -FROM landing_fix -GROUP BY t; - -INSERT INTO landing_fix SELECT 1 as timestamp, 1 AS value FROM numbers(10); - -SELECT sleep(3); - -INSERT INTO landing_fix SELECT 1 as timestamp, 1 AS value FROM numbers(10); - -SYSTEM FLUSH LOGS; -SELECT table, name, error FROM system.part_log -WHERE database = currentDatabase() AND table LIKE '%_fix' -ORDER BY table, name; - -SELECT count() FROM landing_fix; - -DROP TABLE landing_fix; - -DROP TABLE ds_1_1_fix; -DROP VIEW mv_1_1; -DROP VIEW mv_1_2; diff --git a/tests/queries/0_stateless/02972_insert_deduplication_token_hierarchical_inserts_views.reference b/tests/queries/0_stateless/02972_insert_deduplication_token_hierarchical_inserts_views.reference new file mode 100644 index 000000000000..e1bcc64aaeb2 --- /dev/null +++ b/tests/queries/0_stateless/02972_insert_deduplication_token_hierarchical_inserts_views.reference @@ -0,0 +1,5 @@ +0 +ds_1_1 all_1_1_0 0 +ds_1_1 all_2_2_0 0 +landing all_1_1_0 0 +10 diff --git a/tests/queries/0_stateless/02972_insert_deduplication_token_hierarchical_inserts_views.sql b/tests/queries/0_stateless/02972_insert_deduplication_token_hierarchical_inserts_views.sql new file mode 100644 index 000000000000..d82ff4afd931 --- /dev/null +++ b/tests/queries/0_stateless/02972_insert_deduplication_token_hierarchical_inserts_views.sql @@ -0,0 +1,53 @@ +SET insert_deduplicate = 1; +SET deduplicate_blocks_in_dependent_materialized_views = 1; +SET update_insert_deduplication_token_in_dependent_materialized_views = 1; +SET insert_deduplication_token = 'test'; + +DROP TABLE IF EXISTS landing; +CREATE TABLE landing +( + timestamp UInt64, + value UInt64 +) +ENGINE = MergeTree ORDER BY tuple() SETTINGS non_replicated_deduplication_window = 1000; + +DROP TABLE IF EXISTS ds_1_1; +CREATE TABLE ds_1_1 +( + t UInt64, + v UInt64 +) +ENGINE = MergeTree ORDER BY tuple() SETTINGS non_replicated_deduplication_window = 1000; + +DROP VIEW IF EXISTS mv_1_1; +CREATE MATERIALIZED VIEW mv_1_1 TO ds_1_1 as +SELECT + timestamp t, sum(value) v +FROM landing +GROUP BY t; + +DROP VIEW IF EXISTS mv_1_2; +CREATE MATERIALIZED VIEW mv_1_2 TO ds_1_1 as +SELECT + timestamp t, sum(value) v +FROM landing +GROUP BY t; + +INSERT INTO landing SELECT 1 as timestamp, 1 AS value FROM numbers(10); + +SELECT sleep(3); + +INSERT INTO landing SELECT 1 as timestamp, 1 AS value FROM numbers(10); + +SYSTEM FLUSH LOGS; +SELECT table, name, error FROM system.part_log +WHERE database = currentDatabase() +ORDER BY table, name; + +SELECT count() FROM landing; + +DROP TABLE landing; + +DROP TABLE ds_1_1; +DROP VIEW mv_1_1; +DROP VIEW mv_1_2;