This is an automated email from the ASF dual-hosted git repository.
csringhofer pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/impala.git
from 68fe57ff8 IMPALA-12313: (part 3) Add UPDATE support for Iceberg tables.
new 4391595f0 IMPALA-12500: Reduce flakyness of
test_global_exchange_counters
new b6ce98b0b IMPALA-12606: Sporadic failures around
query_test.test_queries.TestQueries.test_intersect
new b37a35aa1 IMPALA-12018: Consider runtime filter for cardinality
reduction
The 3 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
be/src/codegen/gen_ir_descriptions.py | 1 +
be/src/exec/hash-table.cc | 6 +-
be/src/runtime/smallable-string.h | 9 +-
be/src/runtime/string-value-ir.cc | 4 +
be/src/runtime/string-value.h | 5 +
be/src/service/query-options-test.cc | 59 +-
be/src/service/query-options.cc | 7 +
be/src/service/query-options.h | 4 +-
common/thrift/ImpalaService.thrift | 12 +-
common/thrift/Query.thrift | 3 +
.../org/apache/impala/planner/AggregationNode.java | 2 +
.../org/apache/impala/planner/DataStreamSink.java | 5 +-
.../org/apache/impala/planner/ExchangeNode.java | 9 +
.../org/apache/impala/planner/HashJoinNode.java | 4 +-
.../org/apache/impala/planner/HdfsScanNode.java | 23 +-
.../apache/impala/planner/IcebergDeleteNode.java | 2 +-
.../java/org/apache/impala/planner/JoinNode.java | 48 +-
.../apache/impala/planner/NestedLoopJoinNode.java | 21 +-
.../java/org/apache/impala/planner/PlanNode.java | 47 +-
.../java/org/apache/impala/planner/Planner.java | 18 +
.../impala/planner/RuntimeFilterGenerator.java | 104 ++-
.../java/org/apache/impala/planner/ScanNode.java | 197 ++++-
.../java/org/apache/impala/service/Frontend.java | 1 +
.../org/apache/impala/planner/PlannerTest.java | 19 +
.../queries/PlannerTest/aggregation.test | 2 +-
.../PlannerTest/bloom-filter-assignment.test | 16 +-
.../queries/PlannerTest/convert-to-cnf.test | 20 +-
.../PlannerTest/explain-verbose-mt_dop.test | 8 +-
.../queries/PlannerTest/fk-pk-join-detection.test | 6 +-
.../queries/PlannerTest/kudu.test | 2 +-
.../queries/PlannerTest/max-row-size.test | 4 +-
.../PlannerTest/min-max-runtime-filters.test | 8 +-
.../queries/PlannerTest/nested-collections.test | 4 +-
.../queries/PlannerTest/outer-to-inner-joins.test | 2 +-
.../queries/PlannerTest/predicate-propagation.test | 16 +-
.../queries/PlannerTest/resource-requirements.test | 6 +-
...ntime-filter-cardinality-reduction-on-kudu.test | 113 +++
.../runtime-filter-cardinality-reduction.test | 792 +++++++++++++++++++++
.../PlannerTest/spillable-buffer-sizing.test | 8 +-
.../queries/PlannerTest/tpcds-dist-method.test | 12 +-
.../queries/PlannerTest/tpcds-processing-cost.test | 606 ++++++++--------
.../queries/PlannerTest/tpcds/tpcds-q01.test | 18 +-
.../queries/PlannerTest/tpcds/tpcds-q03.test | 6 +-
.../queries/PlannerTest/tpcds/tpcds-q04.test | 48 +-
.../queries/PlannerTest/tpcds/tpcds-q07.test | 12 +-
.../queries/PlannerTest/tpcds/tpcds-q08.test | 18 +-
.../queries/PlannerTest/tpcds/tpcds-q10a.test | 30 +-
.../queries/PlannerTest/tpcds/tpcds-q11.test | 48 +-
.../queries/PlannerTest/tpcds/tpcds-q12.test | 6 +-
.../queries/PlannerTest/tpcds/tpcds-q13.test | 2 +-
.../queries/PlannerTest/tpcds/tpcds-q14a.test | 24 +-
.../queries/PlannerTest/tpcds/tpcds-q15.test | 6 +-
.../queries/PlannerTest/tpcds/tpcds-q16.test | 6 +-
.../queries/PlannerTest/tpcds/tpcds-q17.test | 32 +-
.../queries/PlannerTest/tpcds/tpcds-q18.test | 10 +-
.../queries/PlannerTest/tpcds/tpcds-q19.test | 16 +-
.../queries/PlannerTest/tpcds/tpcds-q20.test | 6 +-
.../queries/PlannerTest/tpcds/tpcds-q21.test | 6 +-
.../queries/PlannerTest/tpcds/tpcds-q23a.test | 60 +-
.../queries/PlannerTest/tpcds/tpcds-q23b.test | 62 +-
.../queries/PlannerTest/tpcds/tpcds-q24a.test | 18 +-
.../queries/PlannerTest/tpcds/tpcds-q24b.test | 18 +-
.../queries/PlannerTest/tpcds/tpcds-q25.test | 32 +-
.../queries/PlannerTest/tpcds/tpcds-q26.test | 6 +-
.../queries/PlannerTest/tpcds/tpcds-q27.test | 12 +-
.../queries/PlannerTest/tpcds/tpcds-q29.test | 32 +-
.../queries/PlannerTest/tpcds/tpcds-q30.test | 30 +-
.../queries/PlannerTest/tpcds/tpcds-q31.test | 54 +-
.../queries/PlannerTest/tpcds/tpcds-q32.test | 8 +-
.../queries/PlannerTest/tpcds/tpcds-q33.test | 36 +-
.../queries/PlannerTest/tpcds/tpcds-q34.test | 20 +-
.../queries/PlannerTest/tpcds/tpcds-q35a.test | 30 +-
.../queries/PlannerTest/tpcds/tpcds-q36.test | 12 +-
.../queries/PlannerTest/tpcds/tpcds-q37.test | 12 +-
.../queries/PlannerTest/tpcds/tpcds-q39a.test | 12 +-
.../queries/PlannerTest/tpcds/tpcds-q39b.test | 12 +-
.../queries/PlannerTest/tpcds/tpcds-q40.test | 12 +-
.../queries/PlannerTest/tpcds/tpcds-q42.test | 12 +-
.../queries/PlannerTest/tpcds/tpcds-q43.test | 12 +-
.../queries/PlannerTest/tpcds/tpcds-q44.test | 4 +-
.../queries/PlannerTest/tpcds/tpcds-q45.test | 6 +-
.../queries/PlannerTest/tpcds/tpcds-q46.test | 12 +-
.../queries/PlannerTest/tpcds/tpcds-q47.test | 36 +-
.../queries/PlannerTest/tpcds/tpcds-q48.test | 2 +-
.../queries/PlannerTest/tpcds/tpcds-q49.test | 42 +-
.../queries/PlannerTest/tpcds/tpcds-q52.test | 12 +-
.../queries/PlannerTest/tpcds/tpcds-q53.test | 12 +-
.../queries/PlannerTest/tpcds/tpcds-q54.test | 10 +-
.../queries/PlannerTest/tpcds/tpcds-q55.test | 12 +-
.../queries/PlannerTest/tpcds/tpcds-q56.test | 44 +-
.../queries/PlannerTest/tpcds/tpcds-q57.test | 18 +-
.../queries/PlannerTest/tpcds/tpcds-q58.test | 18 +-
.../queries/PlannerTest/tpcds/tpcds-q60.test | 44 +-
.../queries/PlannerTest/tpcds/tpcds-q61.test | 36 +-
.../queries/PlannerTest/tpcds/tpcds-q63.test | 12 +-
.../queries/PlannerTest/tpcds/tpcds-q64.test | 56 +-
.../queries/PlannerTest/tpcds/tpcds-q66.test | 36 +-
.../queries/PlannerTest/tpcds/tpcds-q68.test | 6 +-
.../queries/PlannerTest/tpcds/tpcds-q69.test | 30 +-
.../queries/PlannerTest/tpcds/tpcds-q71.test | 26 +-
.../queries/PlannerTest/tpcds/tpcds-q73.test | 8 +-
.../queries/PlannerTest/tpcds/tpcds-q74.test | 36 +-
.../queries/PlannerTest/tpcds/tpcds-q75.test | 44 +-
.../queries/PlannerTest/tpcds/tpcds-q76.test | 16 +-
.../queries/PlannerTest/tpcds/tpcds-q78.test | 42 +-
.../queries/PlannerTest/tpcds/tpcds-q79.test | 14 +-
.../queries/PlannerTest/tpcds/tpcds-q80.test | 36 +-
.../queries/PlannerTest/tpcds/tpcds-q81.test | 30 +-
.../queries/PlannerTest/tpcds/tpcds-q82.test | 6 +-
.../queries/PlannerTest/tpcds/tpcds-q83.test | 36 +-
.../queries/PlannerTest/tpcds/tpcds-q84.test | 18 +-
.../queries/PlannerTest/tpcds/tpcds-q85.test | 10 +-
.../queries/PlannerTest/tpcds/tpcds-q88.test | 48 +-
.../queries/PlannerTest/tpcds/tpcds-q89.test | 12 +-
.../queries/PlannerTest/tpcds/tpcds-q90.test | 12 +-
.../queries/PlannerTest/tpcds/tpcds-q91.test | 12 +-
.../queries/PlannerTest/tpcds/tpcds-q92.test | 8 +-
.../queries/PlannerTest/tpcds/tpcds-q94.test | 6 +-
.../queries/PlannerTest/tpcds/tpcds-q95.test | 6 +-
.../queries/PlannerTest/tpcds/tpcds-q96.test | 6 +-
.../queries/PlannerTest/tpcds/tpcds-q98.test | 6 +-
.../queries/PlannerTest/tpch-kudu.test | 50 +-
tests/query_test/test_observability.py | 3 +-
123 files changed, 2671 insertions(+), 1299 deletions(-)
create mode 100644
testdata/workloads/functional-planner/queries/PlannerTest/runtime-filter-cardinality-reduction-on-kudu.test
create mode 100644
testdata/workloads/functional-planner/queries/PlannerTest/runtime-filter-cardinality-reduction.test