From 11269cf3545e5f6b9fb67d25f09aa5f0069322b9 Mon Sep 17 00:00:00 2001
From: Nikita Taranov <nikita.taranov@clickhouse.com>
Date: Mon, 9 Dec 2024 22:51:13 +0100
Subject: [PATCH] add test

---
 ...llel_join_with_additional_filter.reference |  8 ++++++
 ...2_parallel_join_with_additional_filter.sql | 26 +++++++++++++++++++
 2 files changed, 34 insertions(+)
 create mode 100644 tests/queries/0_stateless/03282_parallel_join_with_additional_filter.reference
 create mode 100644 tests/queries/0_stateless/03282_parallel_join_with_additional_filter.sql

diff --git a/tests/queries/0_stateless/03282_parallel_join_with_additional_filter.reference b/tests/queries/0_stateless/03282_parallel_join_with_additional_filter.reference
new file mode 100644
index 00000000000..2f5cded0ed5
--- /dev/null
+++ b/tests/queries/0_stateless/03282_parallel_join_with_additional_filter.reference
@@ -0,0 +1,8 @@
+---- HASH
+1	10	alpha	1	5	ALPHA
+2	15	beta	2	10	beta
+3	20	gamma	0	0	
+---- PARALLEL HASH
+1	10	alpha	1	5	ALPHA
+2	15	beta	2	10	beta
+3	20	gamma	0	0	
diff --git a/tests/queries/0_stateless/03282_parallel_join_with_additional_filter.sql b/tests/queries/0_stateless/03282_parallel_join_with_additional_filter.sql
new file mode 100644
index 00000000000..b04b466eb2a
--- /dev/null
+++ b/tests/queries/0_stateless/03282_parallel_join_with_additional_filter.sql
@@ -0,0 +1,26 @@
+CREATE TABLE t1 (
+    key UInt32,
+    a UInt32,
+    attr String
+) ENGINE = MergeTree ORDER BY key;
+
+CREATE TABLE t2 (
+    key UInt32,
+    a UInt32,
+    attr String
+) ENGINE = MergeTree ORDER BY key;
+
+INSERT INTO t1 (key, a, attr) VALUES (1, 10, 'alpha'), (2, 15, 'beta'), (3, 20, 'gamma');
+INSERT INTO t2 (key, a, attr) VALUES (1, 5, 'ALPHA'), (2, 10, 'beta'), (4, 25, 'delta');
+
+SET allow_experimental_join_condition = 1;
+SET enable_analyzer = 1;
+SET max_threads = 16;
+
+SELECT '---- HASH';
+SELECT t1.*, t2.* FROM t1 LEFT JOIN t2 ON t1.key = t2.key AND (t1.key < t2.a OR t1.a % 2 = 0) ORDER BY ALL SETTINGS join_algorithm = 'hash';
+
+SELECT '---- PARALLEL HASH';
+SELECT t1.*, t2.* FROM t1 LEFT JOIN t2 ON t1.key = t2.key AND (t1.key < t2.a OR t1.a % 2 = 0) ORDER BY ALL SETTINGS join_algorithm = 'parallel_hash'; -- { serverError NOT_IMPLEMENTED}
+
+SELECT t1.*, t2.* FROM t1 LEFT JOIN t2 ON t1.key = t2.key AND (t1.key < t2.a OR t1.a % 2 = 0) ORDER BY ALL;