This is an automated email from the ASF dual-hosted git repository.
michaelsmith pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/impala.git
from c9bfdbb27 IMPALA-14682: Use centralized async cleanup for admission
state cleanup
new 2360a06e4 IMPALA-14525: Calcite planner: Add support for RexSimplify
new 543f0206e IMPALA-14661: Optimize admissiond memory usage by
compressing exec requests
new 03e9b63d1 IMPALA-14563: Throw AnalysisException when aggregating
complex type
new 00c233cc4 IMPALA-14692: Fix test_spilling_hash_join
The 4 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/rpc/sidecar-util.h | 48 +-
be/src/rpc/thrift-util-test.cc | 32 +
be/src/rpc/thrift-util.h | 108 +-
be/src/scheduling/admission-control-service.cc | 35 +-
be/src/scheduling/admission-control-service.h | 13 +
be/src/scheduling/admission-controller-test.cc | 8 +-
be/src/scheduling/admission-controller.cc | 123 +-
be/src/scheduling/admission-controller.h | 91 +-
.../scheduling/remote-admission-control-client.cc | 20 +-
be/src/service/client-request-state.cc | 13 +-
be/src/service/client-request-state.h | 4 +
common/protobuf/admission_control_service.proto | 3 +
common/thrift/Query.thrift | 8 +
common/thrift/metrics.json | 30 +
.../apache/impala/analysis/FunctionCallExpr.java | 2 +-
.../org/apache/impala/analysis/InPredicate.java | 28 +-
.../org/apache/impala/analysis/SelectStmt.java | 16 +-
.../apache/impala/analysis/AnalyzeStmtsTest.java | 6 +
.../calcite/coercenodes/CoerceOperandShuttle.java | 60 +-
...inaryCompExpr.java => AnalyzedInPredicate.java} | 29 +-
.../impala/calcite/functions/RexCallConverter.java | 20 +
.../calcite/functions/RexLiteralConverter.java | 8 +-
.../calcite/operators/ImpalaCastFunction.java | 6 +-
.../impala/calcite/operators/ImpalaInOperator.java | 26 +-
.../impala/calcite/operators/ImpalaRexBuilder.java | 56 -
.../calcite/operators/ImpalaRexSimplify.java | 81 +
.../impala/calcite/operators/ImpalaRexUtil.java | 228 +
.../impala/calcite/rel/node/ImpalaJoinRel.java | 5 +-
.../impala/calcite/rel/util/CreateExprVisitor.java | 13 +-
.../calcite/rel/util/ExprConjunctsConverter.java | 14 +-
.../impala/calcite/rules/ImpalaCoreRules.java | 209 +
.../calcite/rules/ImpalaFilterSimplifyRule.java | 62 +
.../calcite/rules/ImpalaProjectSimplifyRule.java | 78 +
.../calcite/schema/FilterSelectivityEstimator.java | 30 +-
.../impala/calcite/service/CalciteOptimizer.java | 120 +-
.../calcite/service/CalciteRelNodeConverter.java | 32 +-
.../impala/calcite/type/ImpalaTypeConverter.java | 16 +-
.../calcite/analytic-rank-pushdown-calcite.test | 124 +-
.../calcite/limit-pushdown-analytic-calcite.test | 2 +-
.../PlannerTest/calcite_tpcds/tpcds-q01.test | 403 +-
.../PlannerTest/calcite_tpcds/tpcds-q02.test | 246 +-
.../PlannerTest/calcite_tpcds/tpcds-q03.test | 141 +-
.../PlannerTest/calcite_tpcds/tpcds-q04.test | 2087 +++---
.../PlannerTest/calcite_tpcds/tpcds-q05.test | 480 +-
.../PlannerTest/calcite_tpcds/tpcds-q06.test | 767 +--
.../PlannerTest/calcite_tpcds/tpcds-q07.test | 178 +-
.../PlannerTest/calcite_tpcds/tpcds-q08.test | 762 ++-
.../PlannerTest/calcite_tpcds/tpcds-q10a.test | 1165 ++--
.../PlannerTest/calcite_tpcds/tpcds-q11.test | 788 +--
.../PlannerTest/calcite_tpcds/tpcds-q12.test | 128 +-
.../PlannerTest/calcite_tpcds/tpcds-q13.test | 569 +-
.../PlannerTest/calcite_tpcds/tpcds-q14a.test | 6264 +++++++++---------
.../PlannerTest/calcite_tpcds/tpcds-q14b.test | 3434 +++++-----
.../PlannerTest/calcite_tpcds/tpcds-q15.test | 145 +-
.../PlannerTest/calcite_tpcds/tpcds-q16.test | 1608 ++---
.../PlannerTest/calcite_tpcds/tpcds-q17.test | 723 ++-
.../PlannerTest/calcite_tpcds/tpcds-q18.test | 347 +-
.../PlannerTest/calcite_tpcds/tpcds-q19.test | 213 +-
.../PlannerTest/calcite_tpcds/tpcds-q20.test | 146 +-
.../PlannerTest/calcite_tpcds/tpcds-q21.test | 297 +-
.../PlannerTest/calcite_tpcds/tpcds-q22.test | 59 +-
.../PlannerTest/calcite_tpcds/tpcds-q23a.test | 3586 +++++------
.../PlannerTest/calcite_tpcds/tpcds-q23b.test | 3759 +++++------
.../PlannerTest/calcite_tpcds/tpcds-q24a.test | 744 +--
.../PlannerTest/calcite_tpcds/tpcds-q24b.test | 744 +--
.../PlannerTest/calcite_tpcds/tpcds-q25.test | 719 ++-
.../PlannerTest/calcite_tpcds/tpcds-q26.test | 178 +-
.../PlannerTest/calcite_tpcds/tpcds-q27.test | 232 +-
.../PlannerTest/calcite_tpcds/tpcds-q29.test | 571 +-
.../PlannerTest/calcite_tpcds/tpcds-q30.test | 611 +-
.../PlannerTest/calcite_tpcds/tpcds-q31.test | 2602 ++++----
.../PlannerTest/calcite_tpcds/tpcds-q32.test | 661 +-
.../PlannerTest/calcite_tpcds/tpcds-q33.test | 1397 ++--
.../PlannerTest/calcite_tpcds/tpcds-q34.test | 505 +-
.../PlannerTest/calcite_tpcds/tpcds-q35a.test | 1339 ++--
.../PlannerTest/calcite_tpcds/tpcds-q36.test | 156 +-
.../PlannerTest/calcite_tpcds/tpcds-q37.test | 227 +-
.../PlannerTest/calcite_tpcds/tpcds-q38.test | 429 +-
.../PlannerTest/calcite_tpcds/tpcds-q39a.test | 128 +-
.../PlannerTest/calcite_tpcds/tpcds-q39b.test | 128 +-
.../PlannerTest/calcite_tpcds/tpcds-q40.test | 331 +-
.../PlannerTest/calcite_tpcds/tpcds-q41.test | 91 +-
.../PlannerTest/calcite_tpcds/tpcds-q42.test | 119 +-
.../calcite_tpcds/tpcds-q43-verbose.test | 143 +-
.../PlannerTest/calcite_tpcds/tpcds-q43.test | 283 +-
.../PlannerTest/calcite_tpcds/tpcds-q44.test | 202 +-
.../PlannerTest/calcite_tpcds/tpcds-q45.test | 1031 +--
.../PlannerTest/calcite_tpcds/tpcds-q46.test | 408 +-
.../PlannerTest/calcite_tpcds/tpcds-q47.test | 981 +--
.../PlannerTest/calcite_tpcds/tpcds-q48.test | 444 +-
.../PlannerTest/calcite_tpcds/tpcds-q49.test | 531 +-
.../PlannerTest/calcite_tpcds/tpcds-q50.test | 218 +-
.../PlannerTest/calcite_tpcds/tpcds-q51.test | 416 +-
.../PlannerTest/calcite_tpcds/tpcds-q52.test | 131 +-
.../PlannerTest/calcite_tpcds/tpcds-q53.test | 172 +-
.../PlannerTest/calcite_tpcds/tpcds-q54.test | 391 +-
.../PlannerTest/calcite_tpcds/tpcds-q55.test | 131 +-
.../PlannerTest/calcite_tpcds/tpcds-q56.test | 1258 ++--
.../PlannerTest/calcite_tpcds/tpcds-q57.test | 1063 ++--
.../PlannerTest/calcite_tpcds/tpcds-q58.test | 2615 ++++----
.../PlannerTest/calcite_tpcds/tpcds-q59.test | 260 +-
.../PlannerTest/calcite_tpcds/tpcds-q60.test | 1283 ++--
.../PlannerTest/calcite_tpcds/tpcds-q61.test | 435 +-
.../PlannerTest/calcite_tpcds/tpcds-q62.test | 98 +-
.../PlannerTest/calcite_tpcds/tpcds-q63.test | 180 +-
.../PlannerTest/calcite_tpcds/tpcds-q64.test | 6636 ++++++++++----------
.../PlannerTest/calcite_tpcds/tpcds-q65.test | 255 +-
.../PlannerTest/calcite_tpcds/tpcds-q66.test | 668 +-
.../PlannerTest/calcite_tpcds/tpcds-q67.test | 179 +-
.../PlannerTest/calcite_tpcds/tpcds-q68.test | 329 +-
.../PlannerTest/calcite_tpcds/tpcds-q69.test | 1721 +++--
.../PlannerTest/calcite_tpcds/tpcds-q70.test | 282 +-
.../PlannerTest/calcite_tpcds/tpcds-q71.test | 356 +-
.../PlannerTest/calcite_tpcds/tpcds-q72.test | 412 +-
.../PlannerTest/calcite_tpcds/tpcds-q73.test | 292 +-
.../PlannerTest/calcite_tpcds/tpcds-q74.test | 2128 ++++---
.../PlannerTest/calcite_tpcds/tpcds-q75.test | 1446 +++--
.../PlannerTest/calcite_tpcds/tpcds-q76.test | 480 +-
.../PlannerTest/calcite_tpcds/tpcds-q77.test | 744 ++-
.../PlannerTest/calcite_tpcds/tpcds-q78.test | 425 +-
.../PlannerTest/calcite_tpcds/tpcds-q79.test | 244 +-
.../PlannerTest/calcite_tpcds/tpcds-q80.test | 517 +-
.../PlannerTest/calcite_tpcds/tpcds-q81.test | 631 +-
.../PlannerTest/calcite_tpcds/tpcds-q82.test | 181 +-
.../PlannerTest/calcite_tpcds/tpcds-q83.test | 2393 +++----
.../PlannerTest/calcite_tpcds/tpcds-q84.test | 212 +-
.../PlannerTest/calcite_tpcds/tpcds-q85.test | 775 +--
.../PlannerTest/calcite_tpcds/tpcds-q86.test | 89 +-
.../PlannerTest/calcite_tpcds/tpcds-q87.test | 429 +-
.../PlannerTest/calcite_tpcds/tpcds-q88.test | 2770 ++++----
.../PlannerTest/calcite_tpcds/tpcds-q89.test | 254 +-
.../PlannerTest/calcite_tpcds/tpcds-q90.test | 302 +-
.../PlannerTest/calcite_tpcds/tpcds-q91.test | 286 +-
.../PlannerTest/calcite_tpcds/tpcds-q92.test | 649 +-
.../PlannerTest/calcite_tpcds/tpcds-q93.test | 412 +-
.../PlannerTest/calcite_tpcds/tpcds-q94.test | 1779 +++---
.../PlannerTest/calcite_tpcds/tpcds-q95.test | 1553 ++---
.../PlannerTest/calcite_tpcds/tpcds-q96.test | 348 +-
.../PlannerTest/calcite_tpcds/tpcds-q97.test | 248 +-
.../PlannerTest/calcite_tpcds/tpcds-q98.test | 146 +-
.../PlannerTest/calcite_tpcds/tpcds-q99.test | 98 +-
.../queries/QueryTest/query-impala-13138.test | 2 +-
tests/custom_cluster/test_admission_controller.py | 6 +
143 files changed, 44997 insertions(+), 40368 deletions(-)
copy
java/calcite-planner/src/main/java/org/apache/impala/calcite/functions/{AnalyzedBinaryCompExpr.java
=> AnalyzedInPredicate.java} (69%)
copy fe/src/main/java/org/apache/impala/analysis/SystemTableRef.java =>
java/calcite-planner/src/main/java/org/apache/impala/calcite/operators/ImpalaInOperator.java
(55%)
delete mode 100644
java/calcite-planner/src/main/java/org/apache/impala/calcite/operators/ImpalaRexBuilder.java
create mode 100644
java/calcite-planner/src/main/java/org/apache/impala/calcite/operators/ImpalaRexSimplify.java
create mode 100644
java/calcite-planner/src/main/java/org/apache/impala/calcite/operators/ImpalaRexUtil.java
create mode 100644
java/calcite-planner/src/main/java/org/apache/impala/calcite/rules/ImpalaCoreRules.java
create mode 100644
java/calcite-planner/src/main/java/org/apache/impala/calcite/rules/ImpalaFilterSimplifyRule.java
create mode 100644
java/calcite-planner/src/main/java/org/apache/impala/calcite/rules/ImpalaProjectSimplifyRule.java
