You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@impala.apache.org by ta...@apache.org on 2019/01/14 15:32:33 UTC
impala git commit: IMPALA-8064: Fix intermittent test failures from
test_min_max_filters
Repository: impala
Updated Branches:
refs/heads/master 85b9c6c42 -> f8c3e4c0a
IMPALA-8064: Fix intermittent test failures from test_min_max_filters
test_min_max_filters and test_decimal_min_max_filters records the aggregated probe rows to
check whether min-max filter was exercised. In the case of ASAN builds, the probe side
started processing before the filters reached the probe side, because ASAN builds are a
little slower. The resolution is to increase RUNTIME_FILTER_WAIT_TIME_MS to accommodate ASAN.
This issue was also seen earlier on a runtime filter tests and fixed through IMPALA-6201. This
fix mimics the same, by setting RUNTIME_FILTER_WAIT_TIME_MS to $RUNTIME_FILTER_WAIT_TIME_MS.
Change-Id: I111ed15947bd2812753ae68d3bbb8a9871e25b08
Reviewed-on: http://gerrit.cloudera.org:8080/12224
Reviewed-by: Tim Armstrong <ta...@cloudera.com>
Tested-by: Impala Public Jenkins <im...@cloudera.com>
Project: http://git-wip-us.apache.org/repos/asf/impala/repo
Commit: http://git-wip-us.apache.org/repos/asf/impala/commit/f8c3e4c0
Tree: http://git-wip-us.apache.org/repos/asf/impala/tree/f8c3e4c0
Diff: http://git-wip-us.apache.org/repos/asf/impala/diff/f8c3e4c0
Branch: refs/heads/master
Commit: f8c3e4c0a44dbfa389c195c399e17a64d38a0824
Parents: 85b9c6c
Author: Janaki Lahorani <ja...@cloudera.com>
Authored: Fri Jan 11 11:04:19 2019 -0800
Committer: Impala Public Jenkins <im...@cloudera.com>
Committed: Mon Jan 14 09:07:03 2019 +0000
----------------------------------------------------------------------
.../QueryTest/decimal_min_max_filters.test | 252 +++++++++----------
.../queries/QueryTest/min_max_filters.test | 76 +++---
tests/query_test/test_runtime_filters.py | 6 +-
3 files changed, 169 insertions(+), 165 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/impala/blob/f8c3e4c0/testdata/workloads/functional-query/queries/QueryTest/decimal_min_max_filters.test
----------------------------------------------------------------------
diff --git a/testdata/workloads/functional-query/queries/QueryTest/decimal_min_max_filters.test b/testdata/workloads/functional-query/queries/QueryTest/decimal_min_max_filters.test
index 39001c0..bebf04f 100644
--- a/testdata/workloads/functional-query/queries/QueryTest/decimal_min_max_filters.test
+++ b/testdata/workloads/functional-query/queries/QueryTest/decimal_min_max_filters.test
@@ -14,7 +14,7 @@
#
# Test case 1.1: Decimal Min-max filters multiple 4 bytes
#########################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select STRAIGHT_JOIN a.d5_0, a.d5_1, a.d5_3, a.d5_5
from decimal_rtf_tbl a
join [BROADCAST] decimal_rtf_tiny_tbl b
@@ -71,7 +71,7 @@ aggregation(SUM, ProbeRows): 102
#########################################################
# Test case 1.2: Decimal Min-max filters multiple 4 bytes
#########################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select STRAIGHT_JOIN a.d9_0, a.d9_1, a.d9_5, a.d9_9
from decimal_rtf_tbl a
join [BROADCAST] decimal_rtf_tiny_tbl b
@@ -128,7 +128,7 @@ aggregation(SUM, ProbeRows): 99
#########################################################
# Test case 1.3: Decimal Min-max filters multiple 8 bytes
#########################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select STRAIGHT_JOIN a.d14_0, a.d14_1, a.d14_7, a.d14_14
from decimal_rtf_tbl a
join [BROADCAST] decimal_rtf_tiny_tbl b
@@ -185,7 +185,7 @@ aggregation(SUM, ProbeRows): 97
#########################################################
# Test case 1.4: Decimal Min-max filters multiple 8 bytes
#########################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select STRAIGHT_JOIN a.d18_0, a.d18_1, a.d18_9, a.d18_18
from decimal_rtf_tbl a
join [BROADCAST] decimal_rtf_tiny_tbl b
@@ -242,7 +242,7 @@ aggregation(SUM, ProbeRows): 99
##########################################################
# Test case 1.5: Decimal Min-max filters multiple 16 bytes
##########################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select STRAIGHT_JOIN a.d28_0, a.d28_1, a.d28_14, a.d28_28
from decimal_rtf_tbl a
join [BROADCAST] decimal_rtf_tiny_tbl b
@@ -299,7 +299,7 @@ aggregation(SUM, ProbeRows): 97
##########################################################
# Test case 1.6: Decimal Min-max filters multiple 16 bytes
##########################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select STRAIGHT_JOIN a.d38_0, a.d38_1, a.d38_19, a.d38_38
from decimal_rtf_tbl a
join [BROADCAST] decimal_rtf_tiny_tbl b
@@ -358,7 +358,7 @@ aggregation(SUM, ProbeRows): 97
# d5_0 = d9_0 uses cast and will not use minmax
# filters. The other 3 will.
####################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select STRAIGHT_JOIN a.d5_0, a.d5_1, a.d5_3, a.d5_5
from decimal_rtf_tbl a
join [BROADCAST] decimal_rtf_tiny_tbl b
@@ -417,7 +417,7 @@ aggregation(SUM, ProbeRows): 102
# d9_1 = d14_1 uses cast and will not use minmax
# filters. The other 3 will.
####################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select STRAIGHT_JOIN a.d9_0, a.d9_1, a.d9_5, a.d9_9
from decimal_rtf_tbl a
join [BROADCAST] decimal_rtf_tiny_tbl b
@@ -476,7 +476,7 @@ aggregation(SUM, ProbeRows): 99
# d14_7 = d18_9 uses cast and will not use minmax
# filters. The other 3 will.
####################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select STRAIGHT_JOIN a.d14_0, a.d14_1, a.d14_7, a.d14_14
from decimal_rtf_tbl a
join [BROADCAST] decimal_rtf_tiny_tbl b
@@ -505,7 +505,7 @@ aggregation(SUM, ProbeRows): 107
# d18_18 = d28_28 uses cast and will not use minmax
# filters. The other 3 will.
####################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select STRAIGHT_JOIN a.d18_0, a.d18_1, a.d18_9, a.d18_18
from decimal_rtf_tbl a
join [BROADCAST] decimal_rtf_tiny_tbl b
@@ -545,7 +545,7 @@ aggregation(SUM, ProbeRows): 102
# d28_0 = d38_0 uses cast and will not use minmax
# filters. The other 3 will.
####################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select STRAIGHT_JOIN a.d28_0, a.d28_1, a.d28_14, a.d28_28
from decimal_rtf_tbl a
join [BROADCAST] decimal_rtf_tiny_tbl b
@@ -604,7 +604,7 @@ aggregation(SUM, ProbeRows): 97
# d38_1 = d5_1 uses cast and will not use minmax
# filters. The other 3 will.
####################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select STRAIGHT_JOIN a.d38_0, a.d38_1, a.d38_19, a.d38_38
from decimal_rtf_tbl a
join [BROADCAST] decimal_rtf_tiny_tbl b
@@ -662,7 +662,7 @@ aggregation(SUM, ProbeRows): 97
######################################################################
# Test case 3.1: Two DecimalMinMaxFilters with shuffle join - 4 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join a.d5_0
from decimal_rtf_tbl a
inner join /* +shuffle */ decimal_rtf_tiny_tbl b on a.d5_0 = b.d5_0
@@ -714,7 +714,7 @@ aggregation(SUM, ProbeRows): 149
######################################################################
# Test case 3.2: Two DecimalMinMaxFilters with shuffle join - 4 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join a.d5_1
from decimal_rtf_tbl a
inner join /* +shuffle */ decimal_rtf_tiny_tbl b on a.d5_1 = b.d5_1
@@ -766,7 +766,7 @@ aggregation(SUM, ProbeRows): 148
######################################################################
# Test case 3.3: Two DecimalMinMaxFilters with shuffle join - 4 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join a.d5_3
from decimal_rtf_tbl a
inner join /* +shuffle */ decimal_rtf_tiny_tbl b on a.d5_3 = b.d5_3
@@ -818,7 +818,7 @@ aggregation(SUM, ProbeRows): 143
#######################################################################
# Test case 3.4.1: Two DecimalMinMaxFilters with shuffle join - 4 bytes
#######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join a.d5_5
from decimal_rtf_tbl a
inner join /* +shuffle */ decimal_rtf_tiny_tbl b on a.d5_5 = b.d5_5
@@ -870,7 +870,7 @@ aggregation(SUM, ProbeRows): 347
#######################################################################
# Test case 3.4.2: Two DecimalMinMaxFilters with shuffle join - 4 bytes
#######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join count(a.d5_5)
from decimal_rtf_tbl a
inner join /* +shuffle */ decimal_rtf_tiny_tbl b on a.d5_5 = b.d5_5
@@ -885,7 +885,7 @@ aggregation(SUM, ProbeRows): 360
######################################################################
# Test case 3.5: Two DecimalMinMaxFilters with shuffle join - 8 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join a.d9_0
from decimal_rtf_tbl a
inner join /* +shuffle */ decimal_rtf_tiny_tbl b on a.d9_0 = b.d9_0
@@ -937,7 +937,7 @@ aggregation(SUM, ProbeRows): 149
######################################################################
# Test case 3.6: Two DecimalMinMaxFilters with shuffle join - 4 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join a.d9_1
from decimal_rtf_tbl a
inner join /* +shuffle */ decimal_rtf_tiny_tbl b on a.d9_1 = b.d9_1
@@ -989,7 +989,7 @@ aggregation(SUM, ProbeRows): 148
######################################################################
# Test case 3.7: Two DecimalMinMaxFilters with shuffle join - 4 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join a.d9_5
from decimal_rtf_tbl a
inner join /* +shuffle */ decimal_rtf_tiny_tbl b on a.d9_5 = b.d9_5
@@ -1041,7 +1041,7 @@ aggregation(SUM, ProbeRows): 174
#######################################################################
# Test case 3.8.1: Two DecimalMinMaxFilters with shuffle join - 4 bytes
#######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join a.d9_9
from decimal_rtf_tbl a
inner join /* +shuffle */ decimal_rtf_tiny_tbl b on a.d9_9 = b.d9_9
@@ -1093,7 +1093,7 @@ aggregation(SUM, ProbeRows): 379
#######################################################################
# Test case 3.8.2: Two DecimalMinMaxFilters with shuffle join - 4 bytes
#######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join count(a.d9_9)
from decimal_rtf_tbl a
inner join /* +shuffle */ decimal_rtf_tiny_tbl b on a.d9_9 = b.d9_9
@@ -1108,7 +1108,7 @@ aggregation(SUM, ProbeRows): 612
######################################################################
# Test case 3.9: Two DecimalMinMaxFilters with shuffle join - 8 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join a.d14_0
from decimal_rtf_tbl a
inner join /* +shuffle */ decimal_rtf_tiny_tbl b on a.d14_0 = b.d14_0
@@ -1160,7 +1160,7 @@ aggregation(SUM, ProbeRows): 149
######################################################################
# Test case 3.10: Two DecimalMinMaxFilters with shuffle join - 8 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join a.d14_1
from decimal_rtf_tbl a
inner join /* +shuffle */ decimal_rtf_tiny_tbl b on a.d14_1 = b.d14_1
@@ -1212,7 +1212,7 @@ aggregation(SUM, ProbeRows): 148
######################################################################
# Test case 3.11: Two DecimalMinMaxFilters with shuffle join - 8 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join a.d14_7
from decimal_rtf_tbl a
inner join /* +shuffle */ decimal_rtf_tiny_tbl b on a.d14_7 = b.d14_7
@@ -1264,7 +1264,7 @@ aggregation(SUM, ProbeRows): 235
########################################################################
# Test case 3.12.1: Two DecimalMinMaxFilters with shuffle join - 8 bytes
########################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join a.d14_14
from decimal_rtf_tbl a
inner join /* +shuffle */ decimal_rtf_tiny_tbl b on a.d14_14 = b.d14_14
@@ -1316,7 +1316,7 @@ aggregation(SUM, ProbeRows): 479
########################################################################
# Test case 3.12.2: Two DecimalMinMaxFilters with shuffle join - 8 bytes
########################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join count(a.d14_14)
from decimal_rtf_tbl a
inner join /* +shuffle */ decimal_rtf_tiny_tbl b on a.d14_14 = b.d14_14
@@ -1331,7 +1331,7 @@ aggregation(SUM, ProbeRows): 882
######################################################################
# Test case 3.13: Two DecimalMinMaxFilters with shuffle join - 8 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join a.d18_0
from decimal_rtf_tbl a
inner join /* +shuffle */ decimal_rtf_tiny_tbl b on a.d18_0 = b.d18_0
@@ -1383,7 +1383,7 @@ aggregation(SUM, ProbeRows): 149
######################################################################
# Test case 3.14: Two DecimalMinMaxFilters with shuffle join - 8 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join a.d18_1
from decimal_rtf_tbl a
inner join /* +shuffle */ decimal_rtf_tiny_tbl b on a.d18_1 = b.d18_1
@@ -1435,7 +1435,7 @@ aggregation(SUM, ProbeRows): 148
######################################################################
# Test case 3.15: Two DecimalMinMaxFilters with shuffle join - 8 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join a.d18_9
from decimal_rtf_tbl a
inner join /* +shuffle */ decimal_rtf_tiny_tbl b on a.d18_9 = b.d18_9
@@ -1487,7 +1487,7 @@ aggregation(SUM, ProbeRows): 296
########################################################################
# Test case 3.16.1: Two DecimalMinMaxFilters with shuffle join - 8 bytes
########################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join a.d18_18
from decimal_rtf_tbl a
inner join /* +shuffle */ decimal_rtf_tiny_tbl b on a.d18_18 = b.d18_18
@@ -1539,7 +1539,7 @@ aggregation(SUM, ProbeRows): 536
########################################################################
# Test case 3.16.2: Two DecimalMinMaxFilters with shuffle join - 8 bytes
########################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join count(a.d18_18)
from decimal_rtf_tbl a
inner join /* +shuffle */ decimal_rtf_tiny_tbl b on a.d18_18 = b.d18_18
@@ -1554,7 +1554,7 @@ aggregation(SUM, ProbeRows): 1062
#######################################################################
# Test case 3.17: Two DecimalMinMaxFilters with shuffle join - 16 bytes
#######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join a.d28_0
from decimal_rtf_tbl a
inner join /* +shuffle */ decimal_rtf_tiny_tbl b on a.d28_0 = b.d28_0
@@ -1606,7 +1606,7 @@ aggregation(SUM, ProbeRows): 149
#######################################################################
# Test case 3.18: Two DecimalMinMaxFilters with shuffle join - 16 bytes
#######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join a.d28_1
from decimal_rtf_tbl a
inner join /* +shuffle */ decimal_rtf_tiny_tbl b on a.d28_1 = b.d28_1
@@ -1658,7 +1658,7 @@ aggregation(SUM, ProbeRows): 148
#######################################################################
# Test case 3.19: Two DecimalMinMaxFilters with shuffle join - 16 bytes
#######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join a.d28_14
from decimal_rtf_tbl a
inner join /* +shuffle */ decimal_rtf_tiny_tbl b on a.d28_14 = b.d28_14
@@ -1710,7 +1710,7 @@ aggregation(SUM, ProbeRows): 424
#########################################################################
# Test case 3.20.1: Two DecimalMinMaxFilters with shuffle join - 16 bytes
#########################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join a.d28_28
from decimal_rtf_tbl a
inner join /* +shuffle */ decimal_rtf_tiny_tbl b on a.d28_28 = b.d28_28
@@ -1762,7 +1762,7 @@ aggregation(SUM, ProbeRows): 656
#########################################################################
# Test case 3.20.2: Two DecimalMinMaxFilters with shuffle join - 16 bytes
#########################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join count(a.d28_28)
from decimal_rtf_tbl a
inner join /* +shuffle */ decimal_rtf_tiny_tbl b on a.d28_28 = b.d28_28
@@ -1777,7 +1777,7 @@ aggregation(SUM, ProbeRows): 1372
#######################################################################
# Test case 3.21: Two DecimalMinMaxFilters with shuffle join - 16 bytes
#######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join a.d38_0
from decimal_rtf_tbl a
inner join /* +shuffle */ decimal_rtf_tiny_tbl b on a.d38_0 = b.d38_0
@@ -1829,7 +1829,7 @@ aggregation(SUM, ProbeRows): 149
#######################################################################
# Test case 3.22: Two DecimalMinMaxFilters with shuffle join - 16 bytes
#######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join a.d38_1
from decimal_rtf_tbl a
inner join /* +shuffle */ decimal_rtf_tiny_tbl b on a.d38_1 = b.d38_1
@@ -1881,7 +1881,7 @@ aggregation(SUM, ProbeRows): 148
#######################################################################
# Test case 3.23: Two DecimalMinMaxFilters with shuffle join - 16 bytes
#######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join a.d38_19
from decimal_rtf_tbl a
inner join /* +shuffle */ decimal_rtf_tiny_tbl b on a.d38_19 = b.d38_19
@@ -1933,7 +1933,7 @@ aggregation(SUM, ProbeRows): 529
#########################################################################
# Test case 3.24.1: Two DecimalMinMaxFilters with shuffle join - 16 bytes
#########################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join a.d38_38
from decimal_rtf_tbl a
inner join /* +shuffle */ decimal_rtf_tiny_tbl b on a.d38_38 = b.d38_38
@@ -1985,7 +1985,7 @@ aggregation(SUM, ProbeRows): 680
#########################################################################
# Test case 3.24.2: Two DecimalMinMaxFilters with shuffle join - 16 bytes
#########################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join count(a.d38_38)
from decimal_rtf_tbl a
inner join /* +shuffle */ decimal_rtf_tiny_tbl b on a.d38_38 = b.d38_38
@@ -2001,7 +2001,7 @@ aggregation(SUM, ProbeRows): 1464
######################################################################
# Test case 4.1: DecimalMinMaxFilters with right outer join - 4 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join count(b.d5_0)
from decimal_rtf_tbl a
right outer join decimal_rtf_tiny_tbl b on a.d5_0 = b.d5_0
@@ -2014,7 +2014,7 @@ aggregation(SUM, ProbeRows): 111
######################################################################
# Test case 4.2: DecimalMinMaxFilters with right outer join - 4 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join count(b.d5_1)
from decimal_rtf_tbl a
right outer join decimal_rtf_tiny_tbl b on a.d5_1 = b.d5_1
@@ -2027,7 +2027,7 @@ aggregation(SUM, ProbeRows): 110
######################################################################
# Test case 4.3: DecimalMinMaxFilters with right outer join - 4 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join count(b.d5_3)
from decimal_rtf_tbl a
right outer join decimal_rtf_tiny_tbl b on a.d5_3 = b.d5_3
@@ -2040,7 +2040,7 @@ aggregation(SUM, ProbeRows): 105
#######################################################################
# Test case 4.4.1: DecimalMinMaxFilters with right outer join - 4 bytes
#######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join count(b.d5_5)
from decimal_rtf_tbl a
right outer join decimal_rtf_tiny_tbl b on a.d5_5 = b.d5_5
@@ -2054,7 +2054,7 @@ aggregation(SUM, ProbeRows): 310
#######################################################################
# Test case 4.4.2: DecimalMinMaxFilters with right outer join - 4 bytes
#######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join count(b.d5_5)
from decimal_rtf_tbl a
right outer join decimal_rtf_tiny_tbl b on a.d5_5 = b.d5_5
@@ -2068,7 +2068,7 @@ aggregation(SUM, ProbeRows): 180
######################################################################
# Test case 4.5: DecimalMinMaxFilters with right outer join - 8 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join count(b.d9_0)
from decimal_rtf_tbl a
right outer join decimal_rtf_tiny_tbl b on a.d9_0 = b.d9_0
@@ -2081,7 +2081,7 @@ aggregation(SUM, ProbeRows): 111
######################################################################
# Test case 4.6: DecimalMinMaxFilters with right outer join - 4 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join count(b.d9_1)
from decimal_rtf_tbl a
right outer join decimal_rtf_tiny_tbl b on a.d9_1 = b.d9_1
@@ -2094,7 +2094,7 @@ aggregation(SUM, ProbeRows): 110
######################################################################
# Test case 4.7: DecimalMinMaxFilters with right outer join - 4 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join count(b.d9_5)
from decimal_rtf_tbl a
right outer join decimal_rtf_tiny_tbl b on a.d9_5 = b.d9_5
@@ -2107,7 +2107,7 @@ aggregation(SUM, ProbeRows): 136
#######################################################################
# Test case 4.8.1: DecimalMinMaxFilters with right outer join - 4 bytes
#######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join count(b.d9_9)
from decimal_rtf_tbl a
right outer join decimal_rtf_tiny_tbl b on a.d9_9 = b.d9_9
@@ -2121,7 +2121,7 @@ aggregation(SUM, ProbeRows): 342
#######################################################################
# Test case 4.8.2: DecimalMinMaxFilters with right outer join - 4 bytes
#######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join count(b.d9_9)
from decimal_rtf_tbl a
right outer join decimal_rtf_tiny_tbl b on a.d9_9 = b.d9_9
@@ -2135,7 +2135,7 @@ aggregation(SUM, ProbeRows): 306
######################################################################
# Test case 4.9: DecimalMinMaxFilters with right outer join - 8 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join count(b.d14_0)
from decimal_rtf_tbl a
right outer join decimal_rtf_tiny_tbl b on a.d14_0 = b.d14_0
@@ -2148,7 +2148,7 @@ aggregation(SUM, ProbeRows): 111
######################################################################
# Test case 4.10: DecimalMinMaxFilters with right outer join - 8 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join count(b.d14_1)
from decimal_rtf_tbl a
right outer join decimal_rtf_tiny_tbl b on a.d14_1 = b.d14_1
@@ -2161,7 +2161,7 @@ aggregation(SUM, ProbeRows): 110
######################################################################
# Test case 4.11: DecimalMinMaxFilters with right outer join - 8 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join count(b.d14_7)
from decimal_rtf_tbl a
right outer join decimal_rtf_tiny_tbl b on a.d14_7 = b.d14_7
@@ -2174,7 +2174,7 @@ aggregation(SUM, ProbeRows): 197
########################################################################
# Test case 4.12.1: DecimalMinMaxFilters with right outer join - 8 bytes
########################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join count(b.d14_14)
from decimal_rtf_tbl a
right outer join decimal_rtf_tiny_tbl b on a.d14_14 = b.d14_14
@@ -2188,7 +2188,7 @@ aggregation(SUM, ProbeRows): 444
########################################################################
# Test case 4.12.2: DecimalMinMaxFilters with right outer join - 8 bytes
########################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join count(b.d14_14)
from decimal_rtf_tbl a
right outer join decimal_rtf_tiny_tbl b on a.d14_14 = b.d14_14
@@ -2202,7 +2202,7 @@ aggregation(SUM, ProbeRows): 441
######################################################################
# Test case 4.13: DecimalMinMaxFilters with right outer join - 8 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join count(b.d18_0)
from decimal_rtf_tbl a
right outer join decimal_rtf_tiny_tbl b on a.d18_0 = b.d18_0
@@ -2215,7 +2215,7 @@ aggregation(SUM, ProbeRows): 111
######################################################################
# Test case 4.14: DecimalMinMaxFilters with right outer join - 8 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join count(b.d18_1)
from decimal_rtf_tbl a
right outer join decimal_rtf_tiny_tbl b on a.d18_1 = b.d18_1
@@ -2228,7 +2228,7 @@ aggregation(SUM, ProbeRows): 110
######################################################################
# Test case 4.15: DecimalMinMaxFilters with right outer join - 8 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join count(b.d18_9)
from decimal_rtf_tbl a
right outer join decimal_rtf_tiny_tbl b on a.d18_9 = b.d18_9
@@ -2241,7 +2241,7 @@ aggregation(SUM, ProbeRows): 258
########################################################################
# Test case 4.16.1: DecimalMinMaxFilters with right outer join - 8 bytes
########################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join count(b.d18_18)
from decimal_rtf_tbl a
right outer join decimal_rtf_tiny_tbl b on a.d18_18 = b.d18_18
@@ -2255,7 +2255,7 @@ aggregation(SUM, ProbeRows): 501
########################################################################
# Test case 4.16.2: DecimalMinMaxFilters with right outer join - 8 bytes
########################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join count(b.d18_18)
from decimal_rtf_tbl a
right outer join decimal_rtf_tiny_tbl b on a.d18_18 = b.d18_18
@@ -2269,7 +2269,7 @@ aggregation(SUM, ProbeRows): 531
#######################################################################
# Test case 4.17: DecimalMinMaxFilters with right outer join - 16 bytes
#######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join count(b.d28_0)
from decimal_rtf_tbl a
right outer join decimal_rtf_tiny_tbl b on a.d28_0 = b.d28_0
@@ -2282,7 +2282,7 @@ aggregation(SUM, ProbeRows): 111
#######################################################################
# Test case 4.18: DecimalMinMaxFilters with right outer join - 16 bytes
#######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join count(b.d28_1)
from decimal_rtf_tbl a
right outer join decimal_rtf_tiny_tbl b on a.d28_1 = b.d28_1
@@ -2295,7 +2295,7 @@ aggregation(SUM, ProbeRows): 110
#######################################################################
# Test case 4.19: DecimalMinMaxFilters with right outer join - 16 bytes
#######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join count(b.d28_14)
from decimal_rtf_tbl a
right outer join decimal_rtf_tiny_tbl b on a.d28_14 = b.d28_14
@@ -2308,7 +2308,7 @@ aggregation(SUM, ProbeRows): 386
#########################################################################
# Test case 4.20.1: DecimalMinMaxFilters with right outer join - 16 bytes
#########################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join count(b.d28_28)
from decimal_rtf_tbl a
right outer join decimal_rtf_tiny_tbl b on a.d28_28 = b.d28_28
@@ -2322,7 +2322,7 @@ aggregation(SUM, ProbeRows): 620
#########################################################################
# Test case 4.20.2: DecimalMinMaxFilters with right outer join - 16 bytes
#########################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join count(b.d28_28)
from decimal_rtf_tbl a
right outer join decimal_rtf_tiny_tbl b on a.d28_28 = b.d28_28
@@ -2336,7 +2336,7 @@ aggregation(SUM, ProbeRows): 686
#######################################################################
# Test case 4.21: DecimalMinMaxFilters with right outer join - 16 bytes
#######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join count(b.d38_0)
from decimal_rtf_tbl a
right outer join decimal_rtf_tiny_tbl b on a.d38_0 = b.d38_0
@@ -2349,7 +2349,7 @@ aggregation(SUM, ProbeRows): 111
#######################################################################
# Test case 4.22: DecimalMinMaxFilters with right outer join - 16 bytes
#######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join count(b.d38_1)
from decimal_rtf_tbl a
right outer join decimal_rtf_tiny_tbl b on a.d38_1 = b.d38_1
@@ -2362,7 +2362,7 @@ aggregation(SUM, ProbeRows): 110
#######################################################################
# Test case 4.23: DecimalMinMaxFilters with right outer join - 16 bytes
#######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join count(b.d38_19)
from decimal_rtf_tbl a
right outer join decimal_rtf_tiny_tbl b on a.d38_19 = b.d38_19
@@ -2375,7 +2375,7 @@ aggregation(SUM, ProbeRows): 491
#########################################################################
# Test case 4.24.1: DecimalMinMaxFilters with right outer join - 16 bytes
#########################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join count(b.d38_38)
from decimal_rtf_tbl a
right outer join decimal_rtf_tiny_tbl b on a.d38_38 = b.d38_38
@@ -2389,7 +2389,7 @@ aggregation(SUM, ProbeRows): 643
#########################################################################
# Test case 4.24.2: DecimalMinMaxFilters with right outer join - 16 bytes
#########################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join count(b.d38_38)
from decimal_rtf_tbl a
right outer join decimal_rtf_tiny_tbl b on a.d38_38 = b.d38_38
@@ -2403,7 +2403,7 @@ aggregation(SUM, ProbeRows): 732
######################################################################
# Test case 5.1: DecimalMinMaxFilters with left semi join - 4 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select a.d5_0
from decimal_rtf_tbl a
left semi join decimal_rtf_tiny_tbl b on a.d5_0 = b.d5_0
@@ -2454,7 +2454,7 @@ aggregation(SUM, ProbeRows): 111
######################################################################
# Test case 5.2: DecimalMinMaxFilters with left semi join - 4 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select a.d5_1
from decimal_rtf_tbl a
left semi join decimal_rtf_tiny_tbl b on a.d5_1 = b.d5_1
@@ -2505,7 +2505,7 @@ aggregation(SUM, ProbeRows): 110
######################################################################
# Test case 5.3: DecimalMinMaxFilters with left semi join - 4 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select a.d5_3
from decimal_rtf_tbl a
left semi join decimal_rtf_tiny_tbl b on a.d5_3 = b.d5_3
@@ -2556,7 +2556,7 @@ aggregation(SUM, ProbeRows): 105
######################################################################
# Test case 5.4.1: DecimalMinMaxFilters with left semi join - 4 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select a.d5_5
from decimal_rtf_tbl a
left semi join decimal_rtf_tiny_tbl b on a.d5_5 = b.d5_5
@@ -2607,7 +2607,7 @@ aggregation(SUM, ProbeRows): 310
######################################################################
# Test case 5.4.2: DecimalMinMaxFilters with left semi join - 4 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select count(a.d5_5)
from decimal_rtf_tbl a
left semi join decimal_rtf_tiny_tbl b on a.d5_5 = b.d5_5
@@ -2621,7 +2621,7 @@ aggregation(SUM, ProbeRows): 180
######################################################################
# Test case 5.5: DecimalMinMaxFilters with left semi join - 8 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select a.d9_0
from decimal_rtf_tbl a
left semi join decimal_rtf_tiny_tbl b on a.d9_0 = b.d9_0
@@ -2672,7 +2672,7 @@ aggregation(SUM, ProbeRows): 111
######################################################################
# Test case 5.6: DecimalMinMaxFilters with left semi join - 4 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select a.d9_1
from decimal_rtf_tbl a
left semi join decimal_rtf_tiny_tbl b on a.d9_1 = b.d9_1
@@ -2723,7 +2723,7 @@ aggregation(SUM, ProbeRows): 110
######################################################################
# Test case 5.7: DecimalMinMaxFilters with left semi join - 4 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select a.d9_5
from decimal_rtf_tbl a
left semi join decimal_rtf_tiny_tbl b on a.d9_5 = b.d9_5
@@ -2774,7 +2774,7 @@ aggregation(SUM, ProbeRows): 136
######################################################################
# Test case 5.8.1: DecimalMinMaxFilters with left semi join - 4 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select a.d9_9
from decimal_rtf_tbl a
left semi join decimal_rtf_tiny_tbl b on a.d9_9 = b.d9_9
@@ -2825,7 +2825,7 @@ aggregation(SUM, ProbeRows): 342
######################################################################
# Test case 5.8.2: DecimalMinMaxFilters with left semi join - 4 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select count(a.d9_9)
from decimal_rtf_tbl a
left semi join decimal_rtf_tiny_tbl b on a.d9_9 = b.d9_9
@@ -2839,7 +2839,7 @@ aggregation(SUM, ProbeRows): 306
######################################################################
# Test case 5.9: DecimalMinMaxFilters with left semi join - 8 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select a.d14_0
from decimal_rtf_tbl a
left semi join decimal_rtf_tiny_tbl b on a.d14_0 = b.d14_0
@@ -2890,7 +2890,7 @@ aggregation(SUM, ProbeRows): 111
######################################################################
# Test case 5.10: DecimalMinMaxFilters with left semi join - 8 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select a.d14_1
from decimal_rtf_tbl a
left semi join decimal_rtf_tiny_tbl b on a.d14_1 = b.d14_1
@@ -2941,7 +2941,7 @@ aggregation(SUM, ProbeRows): 110
######################################################################
# Test case 5.11: DecimalMinMaxFilters with left semi join - 8 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select a.d14_7
from decimal_rtf_tbl a
left semi join decimal_rtf_tiny_tbl b on a.d14_7 = b.d14_7
@@ -2992,7 +2992,7 @@ aggregation(SUM, ProbeRows): 197
######################################################################
# Test case 5.12.1: DecimalMinMaxFilters with left semi join - 8 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select a.d14_14
from decimal_rtf_tbl a
left semi join decimal_rtf_tiny_tbl b on a.d14_14 = b.d14_14
@@ -3043,7 +3043,7 @@ aggregation(SUM, ProbeRows): 442
######################################################################
# Test case 5.12.2: DecimalMinMaxFilters with left semi join - 8 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select count(a.d14_14)
from decimal_rtf_tbl a
left semi join decimal_rtf_tiny_tbl b on a.d14_14 = b.d14_14
@@ -3058,7 +3058,7 @@ aggregation(SUM, ProbeRows): 441
######################################################################
# Test case 5.13: DecimalMinMaxFilters with left semi join - 8 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select a.d18_0
from decimal_rtf_tbl a
left semi join decimal_rtf_tiny_tbl b on a.d18_0 = b.d18_0
@@ -3109,7 +3109,7 @@ aggregation(SUM, ProbeRows): 111
######################################################################
# Test case 5.14: DecimalMinMaxFilters with left semi join - 8 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select a.d18_1
from decimal_rtf_tbl a
left semi join decimal_rtf_tiny_tbl b on a.d18_1 = b.d18_1
@@ -3160,7 +3160,7 @@ aggregation(SUM, ProbeRows): 110
######################################################################
# Test case 5.15: DecimalMinMaxFilters with left semi join - 8 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select a.d18_9
from decimal_rtf_tbl a
left semi join decimal_rtf_tiny_tbl b on a.d18_9 = b.d18_9
@@ -3211,7 +3211,7 @@ aggregation(SUM, ProbeRows): 258
######################################################################
# Test case 5.16.1: DecimalMinMaxFilters with left semi join - 8 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select a.d18_18
from decimal_rtf_tbl a
left semi join decimal_rtf_tiny_tbl b on a.d18_18 = b.d18_18
@@ -3262,7 +3262,7 @@ aggregation(SUM, ProbeRows): 499
######################################################################
# Test case 5.16.2: DecimalMinMaxFilters with left semi join - 8 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select count(a.d18_18)
from decimal_rtf_tbl a
left semi join decimal_rtf_tiny_tbl b on a.d18_18 = b.d18_18
@@ -3276,7 +3276,7 @@ aggregation(SUM, ProbeRows): 531
#######################################################################
# Test case 5.17: DecimalMinMaxFilters with left semi join - 16 bytes
#######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select a.d28_0
from decimal_rtf_tbl a
left semi join decimal_rtf_tiny_tbl b on a.d28_0 = b.d28_0
@@ -3327,7 +3327,7 @@ aggregation(SUM, ProbeRows): 111
#######################################################################
# Test case 5.18: DecimalMinMaxFilters with left semi join - 16 bytes
#######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select a.d28_1
from decimal_rtf_tbl a
left semi join decimal_rtf_tiny_tbl b on a.d28_1 = b.d28_1
@@ -3378,7 +3378,7 @@ aggregation(SUM, ProbeRows): 110
#######################################################################
# Test case 5.19: DecimalMinMaxFilters with left semi join - 16 bytes
#######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select a.d28_14
from decimal_rtf_tbl a
left semi join decimal_rtf_tiny_tbl b on a.d28_14 = b.d28_14
@@ -3429,7 +3429,7 @@ aggregation(SUM, ProbeRows): 386
#######################################################################
# Test case 5.20.1: DecimalMinMaxFilters with left semi join - 16 bytes
#######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select a.d28_28
from decimal_rtf_tbl a
left semi join decimal_rtf_tiny_tbl b on a.d28_28 = b.d28_28
@@ -3480,7 +3480,7 @@ aggregation(SUM, ProbeRows): 619
#######################################################################
# Test case 5.20.2: DecimalMinMaxFilters with left semi join - 16 bytes
#######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select count(a.d28_28)
from decimal_rtf_tbl a
left semi join decimal_rtf_tiny_tbl b on a.d28_28 = b.d28_28
@@ -3495,7 +3495,7 @@ aggregation(SUM, ProbeRows): 686
#######################################################################
# Test case 5.21: DecimalMinMaxFilters with left semi join - 16 bytes
#######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select a.d38_0
from decimal_rtf_tbl a
left semi join decimal_rtf_tiny_tbl b on a.d38_0 = b.d38_0
@@ -3546,7 +3546,7 @@ aggregation(SUM, ProbeRows): 111
#######################################################################
# Test case 5.22: DecimalMinMaxFilters with left semi join - 16 bytes
#######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select a.d38_1
from decimal_rtf_tbl a
left semi join decimal_rtf_tiny_tbl b on a.d38_1 = b.d38_1
@@ -3597,7 +3597,7 @@ aggregation(SUM, ProbeRows): 110
#######################################################################
# Test case 5.23: DecimalMinMaxFilters with left semi join - 16 bytes
#######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select a.d38_19
from decimal_rtf_tbl a
left semi join decimal_rtf_tiny_tbl b on a.d38_19 = b.d38_19
@@ -3648,7 +3648,7 @@ aggregation(SUM, ProbeRows): 491
#######################################################################
# Test case 5.24.1: DecimalMinMaxFilters with left semi join - 16 bytes
#######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select a.d38_38
from decimal_rtf_tbl a
left semi join decimal_rtf_tiny_tbl b on a.d38_38 = b.d38_38
@@ -3699,7 +3699,7 @@ aggregation(SUM, ProbeRows): 643
#######################################################################
# Test case 5.24.2: DecimalMinMaxFilters with left semi join - 16 bytes
#######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select count(a.d38_38)
from decimal_rtf_tbl a
left semi join decimal_rtf_tiny_tbl b on a.d38_38 = b.d38_38
@@ -3715,7 +3715,7 @@ aggregation(SUM, ProbeRows): 732
######################################################################
# Test case 6.1: DecimalMinMaxFilters with right semi join - 4 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select b.d5_0
from decimal_rtf_tbl a
right semi join decimal_rtf_tiny_tbl b on a.d5_0 = b.d5_0
@@ -3766,7 +3766,7 @@ aggregation(SUM, ProbeRows): 111
######################################################################
# Test case 6.2: DecimalMinMaxFilters with right semi join - 4 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select b.d5_1
from decimal_rtf_tbl a
right semi join decimal_rtf_tiny_tbl b on a.d5_1 = b.d5_1
@@ -3817,7 +3817,7 @@ aggregation(SUM, ProbeRows): 110
######################################################################
# Test case 6.3: DecimalMinMaxFilters with right semi join - 4 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select b.d5_3
from decimal_rtf_tbl a
right semi join decimal_rtf_tiny_tbl b on a.d5_3 = b.d5_3
@@ -3868,7 +3868,7 @@ aggregation(SUM, ProbeRows): 105
######################################################################
# Test case 6.4: DecimalMinMaxFilters with right semi join - 4 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select b.d5_5
from decimal_rtf_tbl a
right semi join decimal_rtf_tiny_tbl b on a.d5_5 = b.d5_5
@@ -3919,7 +3919,7 @@ aggregation(SUM, ProbeRows): 490
######################################################################
# Test case 6.5: DecimalMinMaxFilters with right semi join - 8 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select b.d9_0
from decimal_rtf_tbl a
right semi join decimal_rtf_tiny_tbl b on a.d9_0 = b.d9_0
@@ -3970,7 +3970,7 @@ aggregation(SUM, ProbeRows): 111
######################################################################
# Test case 6.6: DecimalMinMaxFilters with right semi join - 4 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select b.d9_1
from decimal_rtf_tbl a
right semi join decimal_rtf_tiny_tbl b on a.d9_1 = b.d9_1
@@ -4021,7 +4021,7 @@ aggregation(SUM, ProbeRows): 110
######################################################################
# Test case 6.7: DecimalMinMaxFilters with right semi join - 4 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select b.d9_5
from decimal_rtf_tbl a
right semi join decimal_rtf_tiny_tbl b on a.d9_5 = b.d9_5
@@ -4072,7 +4072,7 @@ aggregation(SUM, ProbeRows): 136
######################################################################
# Test case 6.8: DecimalMinMaxFilters with right semi join - 4 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select b.d9_9
from decimal_rtf_tbl a
right semi join decimal_rtf_tiny_tbl b on a.d9_9 = b.d9_9
@@ -4123,7 +4123,7 @@ aggregation(SUM, ProbeRows): 648
######################################################################
# Test case 6.9: DecimalMinMaxFilters with right semi join - 8 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select b.d14_0
from decimal_rtf_tbl a
right semi join decimal_rtf_tiny_tbl b on a.d14_0 = b.d14_0
@@ -4174,7 +4174,7 @@ aggregation(SUM, ProbeRows): 111
######################################################################
# Test case 6.10: DecimalMinMaxFilters with right semi join - 8 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select b.d14_1
from decimal_rtf_tbl a
right semi join decimal_rtf_tiny_tbl b on a.d14_1 = b.d14_1
@@ -4225,7 +4225,7 @@ aggregation(SUM, ProbeRows): 110
######################################################################
# Test case 6.11: DecimalMinMaxFilters with right semi join - 8 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select b.d14_7
from decimal_rtf_tbl a
right semi join decimal_rtf_tiny_tbl b on a.d14_7 = b.d14_7
@@ -4276,7 +4276,7 @@ aggregation(SUM, ProbeRows): 197
######################################################################
# Test case 6.12: DecimalMinMaxFilters with right semi join - 8 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select b.d14_14
from decimal_rtf_tbl a
right semi join decimal_rtf_tiny_tbl b on a.d14_14 = b.d14_14
@@ -4327,7 +4327,7 @@ aggregation(SUM, ProbeRows): 885
######################################################################
# Test case 6.13: DecimalMinMaxFilters with right semi join - 8 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select b.d18_0
from decimal_rtf_tbl a
right semi join decimal_rtf_tiny_tbl b on a.d18_0 = b.d18_0
@@ -4378,7 +4378,7 @@ aggregation(SUM, ProbeRows): 111
######################################################################
# Test case 6.14: DecimalMinMaxFilters with right semi join - 8 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select b.d18_1
from decimal_rtf_tbl a
right semi join decimal_rtf_tiny_tbl b on a.d18_1 = b.d18_1
@@ -4429,7 +4429,7 @@ aggregation(SUM, ProbeRows): 110
######################################################################
# Test case 6.15: DecimalMinMaxFilters with right semi join - 8 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select b.d18_9
from decimal_rtf_tbl a
right semi join decimal_rtf_tiny_tbl b on a.d18_9 = b.d18_9
@@ -4480,7 +4480,7 @@ aggregation(SUM, ProbeRows): 258
######################################################################
# Test case 6.16: DecimalMinMaxFilters with right semi join - 8 bytes
######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select b.d18_18
from decimal_rtf_tbl a
right semi join decimal_rtf_tiny_tbl b on a.d18_18 = b.d18_18
@@ -4531,7 +4531,7 @@ aggregation(SUM, ProbeRows): 1032
#######################################################################
# Test case 6.17: DecimalMinMaxFilters with right semi join - 16 bytes
#######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select b.d28_0
from decimal_rtf_tbl a
right semi join decimal_rtf_tiny_tbl b on a.d28_0 = b.d28_0
@@ -4582,7 +4582,7 @@ aggregation(SUM, ProbeRows): 111
#######################################################################
# Test case 6.18: DecimalMinMaxFilters with right semi join - 16 bytes
#######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select b.d28_1
from decimal_rtf_tbl a
right semi join decimal_rtf_tiny_tbl b on a.d28_1 = b.d28_1
@@ -4633,7 +4633,7 @@ aggregation(SUM, ProbeRows): 110
#######################################################################
# Test case 6.19: DecimalMinMaxFilters with right semi join - 16 bytes
#######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select b.d28_14
from decimal_rtf_tbl a
right semi join decimal_rtf_tiny_tbl b on a.d28_14 = b.d28_14
@@ -4684,7 +4684,7 @@ aggregation(SUM, ProbeRows): 386
#######################################################################
# Test case 6.20: DecimalMinMaxFilters with right semi join - 16 bytes
#######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select b.d28_28
from decimal_rtf_tbl a
right semi join decimal_rtf_tiny_tbl b on a.d28_28 = b.d28_28
@@ -4735,7 +4735,7 @@ aggregation(SUM, ProbeRows): 1306
#######################################################################
# Test case 6.21: DecimalMinMaxFilters with right semi join - 16 bytes
#######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select b.d38_0
from decimal_rtf_tbl a
right semi join decimal_rtf_tiny_tbl b on a.d38_0 = b.d38_0
@@ -4786,7 +4786,7 @@ aggregation(SUM, ProbeRows): 111
#######################################################################
# Test case 6.22: DecimalMinMaxFilters with right semi join - 16 bytes
#######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select b.d38_1
from decimal_rtf_tbl a
right semi join decimal_rtf_tiny_tbl b on a.d38_1 = b.d38_1
@@ -4837,7 +4837,7 @@ aggregation(SUM, ProbeRows): 110
#######################################################################
# Test case 6.23: DecimalMinMaxFilters with right semi join - 16 bytes
#######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select b.d38_19
from decimal_rtf_tbl a
right semi join decimal_rtf_tiny_tbl b on a.d38_19 = b.d38_19
@@ -4888,7 +4888,7 @@ aggregation(SUM, ProbeRows): 491
#######################################################################
# Test case 6.24: DecimalMinMaxFilters with right semi join - 16 bytes
#######################################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select b.d38_38
from decimal_rtf_tbl a
right semi join decimal_rtf_tiny_tbl b on a.d38_38 = b.d38_38
http://git-wip-us.apache.org/repos/asf/impala/blob/f8c3e4c0/testdata/workloads/functional-query/queries/QueryTest/min_max_filters.test
----------------------------------------------------------------------
diff --git a/testdata/workloads/functional-query/queries/QueryTest/min_max_filters.test b/testdata/workloads/functional-query/queries/QueryTest/min_max_filters.test
index 4401537..1f48194 100644
--- a/testdata/workloads/functional-query/queries/QueryTest/min_max_filters.test
+++ b/testdata/workloads/functional-query/queries/QueryTest/min_max_filters.test
@@ -3,70 +3,70 @@
####################################################
# Test case 1: Min-max filters of all possible types.
####################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select STRAIGHT_JOIN count(*) from alltypes a join [BROADCAST] alltypestiny b
where a.bool_col = (b.bool_col && !b.bool_col)
---- RESULTS
29200
====
---- QUERY
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select STRAIGHT_JOIN count(*) from alltypes a join [BROADCAST] alltypestiny b
where a.tinyint_col = b.tinyint_col
---- RESULTS
5840
====
---- QUERY
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select STRAIGHT_JOIN count(*) from alltypes a join [BROADCAST] alltypestiny b
where a.smallint_col = b.smallint_col
---- RESULTS
5840
====
---- QUERY
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select STRAIGHT_JOIN count(*) from alltypes a join [BROADCAST] alltypestiny b
where a.int_col = b.int_col
---- RESULTS
5840
====
---- QUERY
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select STRAIGHT_JOIN count(*) from alltypes a join [BROADCAST] alltypestiny b
where a.bigint_col = b.bigint_col
---- RESULTS
5840
====
---- QUERY
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select STRAIGHT_JOIN count(*) from alltypes a join [BROADCAST] alltypestiny b
where a.float_col = b.float_col
---- RESULTS
5840
====
---- QUERY
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select STRAIGHT_JOIN count(*) from alltypes a join [BROADCAST] alltypestiny b
where a.double_col = b.double_col
---- RESULTS
5840
====
---- QUERY
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select STRAIGHT_JOIN count(*) from alltypes a join [BROADCAST] alltypestiny b
where a.string_col = b.string_col
---- RESULTS
5840
====
---- QUERY
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select STRAIGHT_JOIN count(*) from alltypes a join [BROADCAST] alltypestiny b
where a.timestamp_col = b.timestamp_col
---- RESULTS
8
====
---- QUERY
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select STRAIGHT_JOIN count(*) from decimal_rtf_tbl a
join [BROADCAST] decimal_rtf_tiny_tbl b
where a.d5_0 = b.d5_0
@@ -76,7 +76,7 @@ where a.d5_0 = b.d5_0
aggregation(SUM, ProbeRows): 111
====
---- QUERY
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select STRAIGHT_JOIN count(*) from decimal_rtf_tbl a
join [BROADCAST] decimal_rtf_tiny_tbl b
where a.d5_1 = b.d5_1
@@ -86,7 +86,7 @@ where a.d5_1 = b.d5_1
aggregation(SUM, ProbeRows): 110
====
---- QUERY
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select STRAIGHT_JOIN count(*) from decimal_rtf_tbl a
join [BROADCAST] decimal_rtf_tiny_tbl b
where a.d5_3 = b.d5_3
@@ -96,7 +96,7 @@ where a.d5_3 = b.d5_3
aggregation(SUM, ProbeRows): 105
====
---- QUERY
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select STRAIGHT_JOIN count(*) from decimal_rtf_tbl a
join [BROADCAST] decimal_rtf_tiny_tbl b
where a.d5_5 = b.d5_5 and b.d5_5 != 0
@@ -106,7 +106,7 @@ where a.d5_5 = b.d5_5 and b.d5_5 != 0
aggregation(SUM, ProbeRows): 310
====
---- QUERY
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select STRAIGHT_JOIN count(*) from decimal_rtf_tbl a
join [BROADCAST] decimal_rtf_tiny_tbl b
where a.d5_5 = b.d5_5 and b.d5_5 = 0
@@ -116,7 +116,7 @@ where a.d5_5 = b.d5_5 and b.d5_5 = 0
aggregation(SUM, ProbeRows): 180
====
---- QUERY
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select STRAIGHT_JOIN count(*) from decimal_rtf_tbl a
join [BROADCAST] decimal_rtf_tiny_tbl b
where a.d9_0 = b.d9_0
@@ -126,7 +126,7 @@ where a.d9_0 = b.d9_0
aggregation(SUM, ProbeRows): 111
====
---- QUERY
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select STRAIGHT_JOIN count(*) from decimal_rtf_tbl a
join [BROADCAST] decimal_rtf_tiny_tbl b
where a.d9_1 = b.d9_1
@@ -136,7 +136,7 @@ where a.d9_1 = b.d9_1
aggregation(SUM, ProbeRows): 110
====
---- QUERY
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select STRAIGHT_JOIN count(*) from decimal_rtf_tbl a
join [BROADCAST] decimal_rtf_tiny_tbl b
where a.d9_5 = b.d9_5
@@ -146,7 +146,7 @@ where a.d9_5 = b.d9_5
aggregation(SUM, ProbeRows): 136
====
---- QUERY
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select STRAIGHT_JOIN count(*) from decimal_rtf_tbl a
join [BROADCAST] decimal_rtf_tiny_tbl b
where a.d9_9 = b.d9_9 and b.d9_9 != 0
@@ -156,7 +156,7 @@ where a.d9_9 = b.d9_9 and b.d9_9 != 0
aggregation(SUM, ProbeRows): 342
====
---- QUERY
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select STRAIGHT_JOIN count(*) from decimal_rtf_tbl a
join [BROADCAST] decimal_rtf_tiny_tbl b
where a.d9_9 = b.d9_9 and b.d9_9 = 0
@@ -166,7 +166,7 @@ where a.d9_9 = b.d9_9 and b.d9_9 = 0
aggregation(SUM, ProbeRows): 306
====
---- QUERY
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select STRAIGHT_JOIN count(*) from decimal_rtf_tbl a
join [BROADCAST] decimal_rtf_tiny_tbl b
where a.d14_0 = b.d14_0
@@ -176,7 +176,7 @@ where a.d14_0 = b.d14_0
aggregation(SUM, ProbeRows): 111
====
---- QUERY
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select STRAIGHT_JOIN count(*) from decimal_rtf_tbl a
join [BROADCAST] decimal_rtf_tiny_tbl b
where a.d14_1 = b.d14_1
@@ -186,7 +186,7 @@ where a.d14_1 = b.d14_1
aggregation(SUM, ProbeRows): 110
====
---- QUERY
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select STRAIGHT_JOIN count(*) from decimal_rtf_tbl a
join [BROADCAST] decimal_rtf_tiny_tbl b
where a.d14_7 = b.d14_7
@@ -196,7 +196,7 @@ where a.d14_7 = b.d14_7
aggregation(SUM, ProbeRows): 197
====
---- QUERY
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select STRAIGHT_JOIN count(*) from decimal_rtf_tbl a
join [BROADCAST] decimal_rtf_tiny_tbl b
where a.d14_14 = b.d14_14 and b.d14_14 != 0
@@ -206,7 +206,7 @@ where a.d14_14 = b.d14_14 and b.d14_14 != 0
aggregation(SUM, ProbeRows): 442
====
---- QUERY
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select STRAIGHT_JOIN count(*) from decimal_rtf_tbl a
join [BROADCAST] decimal_rtf_tiny_tbl b
where a.d14_14 = b.d14_14 and b.d14_14 = 0
@@ -216,7 +216,7 @@ where a.d14_14 = b.d14_14 and b.d14_14 = 0
aggregation(SUM, ProbeRows): 441
====
---- QUERY
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select STRAIGHT_JOIN count(*) from decimal_rtf_tbl a
join [BROADCAST] decimal_rtf_tiny_tbl b
where a.d28_0 = b.d28_0
@@ -226,7 +226,7 @@ where a.d28_0 = b.d28_0
aggregation(SUM, ProbeRows): 111
====
---- QUERY
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select STRAIGHT_JOIN count(*) from decimal_rtf_tbl a
join [BROADCAST] decimal_rtf_tiny_tbl b
where a.d28_1 = b.d28_1
@@ -236,7 +236,7 @@ where a.d28_1 = b.d28_1
aggregation(SUM, ProbeRows): 110
====
---- QUERY
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select STRAIGHT_JOIN count(*) from decimal_rtf_tbl a
join [BROADCAST] decimal_rtf_tiny_tbl b
where a.d28_14 = b.d28_14
@@ -246,7 +246,7 @@ where a.d28_14 = b.d28_14
aggregation(SUM, ProbeRows): 386
====
---- QUERY
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select STRAIGHT_JOIN count(*) from decimal_rtf_tbl a
join [BROADCAST] decimal_rtf_tiny_tbl b
where a.d28_28 = b.d28_28 and b.d28_28 != 0
@@ -256,7 +256,7 @@ where a.d28_28 = b.d28_28 and b.d28_28 != 0
aggregation(SUM, ProbeRows): 619
====
---- QUERY
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select STRAIGHT_JOIN count(*) from decimal_rtf_tbl a
join [BROADCAST] decimal_rtf_tiny_tbl b
where a.d28_28 = b.d28_28 and b.d28_28 = 0
@@ -266,7 +266,7 @@ where a.d28_28 = b.d28_28 and b.d28_28 = 0
aggregation(SUM, ProbeRows): 686
====
---- QUERY
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select STRAIGHT_JOIN count(*) from decimal_rtf_tbl a
join [BROADCAST] decimal_rtf_tiny_tbl b
where a.d38_0 = b.d38_0
@@ -276,7 +276,7 @@ where a.d38_0 = b.d38_0
aggregation(SUM, ProbeRows): 111
====
---- QUERY
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select STRAIGHT_JOIN count(*) from decimal_rtf_tbl a
join [BROADCAST] decimal_rtf_tiny_tbl b
where a.d38_1 = b.d38_1
@@ -286,7 +286,7 @@ where a.d38_1 = b.d38_1
aggregation(SUM, ProbeRows): 110
====
---- QUERY
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select STRAIGHT_JOIN count(*) from decimal_rtf_tbl a
join [BROADCAST] decimal_rtf_tiny_tbl b
where a.d38_19 = b.d38_19
@@ -296,7 +296,7 @@ where a.d38_19 = b.d38_19
aggregation(SUM, ProbeRows): 491
====
---- QUERY
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select STRAIGHT_JOIN count(*) from decimal_rtf_tbl a
join [BROADCAST] decimal_rtf_tiny_tbl b
where a.d38_38 = b.d38_38 and b.d38_38 != 0
@@ -306,7 +306,7 @@ where a.d38_38 = b.d38_38 and b.d38_38 != 0
aggregation(SUM, ProbeRows): 643
====
---- QUERY
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select STRAIGHT_JOIN count(*) from decimal_rtf_tbl a
join [BROADCAST] decimal_rtf_tiny_tbl b
where a.d38_38 = b.d38_38 and b.d38_38 = 0
@@ -320,7 +320,7 @@ aggregation(SUM, ProbeRows): 732
####################################################
# Test case 2: Min-max filters on a primary key/partition column
####################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select STRAIGHT_JOIN a.id, a.tinyint_col, b.id, b.tinyint_col
from alltypes a join [BROADCAST] alltypestiny b
where a.id = b.tinyint_col * 2;
@@ -342,7 +342,7 @@ INT,TINYINT,INT,TINYINT
####################################################
# Test case 3: Target expr has an implicit integer cast
####################################################
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select STRAIGHT_JOIN count(*)
from alltypes a join [BROADCAST] alltypes b
where a.tinyint_col = b.int_col and b.int_col in (0, 1)
@@ -352,7 +352,7 @@ where a.tinyint_col = b.int_col and b.int_col in (0, 1)
---- QUERY
# The min/max values in the filter are both above the range of the target col so all rows
# are filtered.
-SET RUNTIME_FILTER_WAIT_TIME_MS=30000;
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select STRAIGHT_JOIN count(*)
from alltypes a join [BROADCAST] alltypes b
where a.tinyint_col = b.int_col + 10000
@@ -362,6 +362,7 @@ where a.tinyint_col = b.int_col + 10000
---- QUERY
# The min/max values in the filter are below/above the range for the target col,
# respectively, so no rows are filtered.
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select STRAIGHT_JOIN count(*)
from alltypes a join [BROADCAST]
(values (min_int() x), (max_int()), (0)) v
@@ -375,6 +376,7 @@ where a.tinyint_col = v.x
####################################################
# Test case 4: Two StringMinMaxFilters generated in the same fragment (IMPALA-7272).
###################################################
+SET RUNTIME_FILTER_WAIT_TIME_MS=$RUNTIME_FILTER_WAIT_TIME_MS;
select straight_join a.l_orderkey
from tpch_kudu.lineitem a
inner join /* +shuffle */ tpch_kudu.lineitem b on a.l_comment = b.l_comment
http://git-wip-us.apache.org/repos/asf/impala/blob/f8c3e4c0/tests/query_test/test_runtime_filters.py
----------------------------------------------------------------------
diff --git a/tests/query_test/test_runtime_filters.py b/tests/query_test/test_runtime_filters.py
index 68db622..daf7321 100644
--- a/tests/query_test/test_runtime_filters.py
+++ b/tests/query_test/test_runtime_filters.py
@@ -110,12 +110,14 @@ class TestMinMaxFilters(ImpalaTestSuite):
lambda v: v.get_value('table_format').file_format in ['kudu'])
def test_min_max_filters(self, vector):
- self.run_test_case('QueryTest/min_max_filters', vector)
+ self.run_test_case('QueryTest/min_max_filters', vector,
+ test_file_vars={'$RUNTIME_FILTER_WAIT_TIME_MS': str(WAIT_TIME_MS)})
def test_decimal_min_max_filters(self, vector):
if self.exploration_strategy() != 'exhaustive':
pytest.skip("skip decimal min max filter test with various joins")
- self.run_test_case('QueryTest/decimal_min_max_filters', vector)
+ self.run_test_case('QueryTest/decimal_min_max_filters', vector,
+ test_file_vars={'$RUNTIME_FILTER_WAIT_TIME_MS': str(WAIT_TIME_MS)})
def test_large_strings(self, cursor, unique_database):
"""Tests that truncation of large strings by min-max filters still gives correct