From ed072340b5c8bef443f7ad16d162290ed3551133 Mon Sep 17 00:00:00 2001 From: "Hongbin Ma (Mahone)" Date: Wed, 12 Jun 2024 16:58:46 +0800 Subject: [PATCH] fix it Signed-off-by: Hongbin Ma (Mahone) --- integration_tests/src/main/python/join_test.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/integration_tests/src/main/python/join_test.py b/integration_tests/src/main/python/join_test.py index ef9f4d03f24..ec52539c626 100644 --- a/integration_tests/src/main/python/join_test.py +++ b/integration_tests/src/main/python/join_test.py @@ -933,7 +933,7 @@ def do_join(spark): " or exists (select * from {} as r where l.b < r.b)" ).format(left_table_name, right_table_name)) - capture_regexp = r"GpuBroadcastNestedLoopJoin ExistenceJoin\(exists#[0-9]+\)," + capture_regexp = r"GpuBroadcastNestedLoopJoin \[LOREID=[0-9]+\] ExistenceJoin\(exists#[0-9]+\)," assert_cpu_and_gpu_are_equal_collect_with_capture(do_join, capture_regexp, conf={"spark.sql.adaptive.enabled": aqeEnabled}) @@ -957,7 +957,7 @@ def do_join(spark): " or exists (select * from {} as r where l.b < l.a)" ).format(left_table_name, right_table_name)) - capture_regexp = r"GpuBroadcastNestedLoopJoin ExistenceJoin\(exists#[0-9]+\)," + capture_regexp = r"GpuBroadcastNestedLoopJoin \[LOREID=[0-9]+\] ExistenceJoin\(exists#[0-9]+\)," assert_cpu_and_gpu_are_equal_collect_with_capture(do_join, capture_regexp, conf={"spark.sql.adaptive.enabled": aqeEnabled})