This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a change to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
from 0ab1dd09548 [opt](Nereids) support set operation minus (#33582)
new 913ced5891c [Improvementation](stream-load) improve streamLoadPut log
warning detail (#33535)
new 97f204cb7b0 [Fix](inverted index) fix build index error status when
batch_next (#33532)
new 7678c0e3548 [bug](not in) if not in (null) could eos early (#33482)
new ffdb0effe0e [improve](fold) support complex type for constant folding
(#32867)
new 6d066a701c6 [Chore](code comment) add comment for #32999 (#33548)
new f50fd931db0 [FIX](regresstest) fix array_range case for regress test
(#33337)
new 4ba9be4b54e [refactor](heap sort) Simplify sorted block view (#33477)
new eae93710583 [pipelineX](fix) Fix data pooling judgement for bucket
join (#33533)
new b2fb8359ff9 [Feature](Variant) support aggregation model for Variant
type (#33493)
new c8724c67126 [fix](fs) Close local file writer when downloading
finished (#33556)
new 92be8ee320c [chore](Nereids) better way to return error (#33507)
new d7759d0b2aa [feat](nereids) support create view in nereids (#32743)
new 0f82e1e72d5 [opt](Nereids) support select async mv partition (#33560)
new 5e1ba655176 [chore](test) update one join case for nereids because
ambiguous name (#33562)
new 985d5931d02 [fix](routine-load) fix consumer hang when kafka exception
causing can not query (#33492)
new 52b6af9382f [fix](timeout) query timeout was not correctly set
(#33444)
new 8ff3ca615ae [feature](profile) add non-zero counter in profile(#33342)
new 398ae2aa3c0 [Fix] fix compile problem (#33578)
new 9c5947cbcc4 [Fix](Nereids) fix leading hint should have all tables in
one query block (#33517)
new 5c6c1bdb259 [pipelineX](broadcast) Set dependency ready if a limited
exchange returns EOS (#33525)
new c6906763b90 [fix](schema change) CastStringConverter is compiled
failed in g++ (#33546)
new cae71f722f6 [test](bi) add dbeaver and datagrip connect doris test
(#33487)
new 19ce67af570 [k8s](improve)add docker resource script for k8s (#33329)
new be38b0c2370 [enhancement](merge-iterator) catch exception to avoid
coredump when copy_rows (#33567)
The 24 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/io/fs/hdfs_file_system.cpp | 3 +-
be/src/olap/tablet_schema.h | 21 +-
be/src/olap/task/index_builder.cpp | 6 +
be/src/pipeline/exec/exchange_sink_buffer.cpp | 2 +
be/src/pipeline/exec/exchange_sink_buffer.h | 9 +-
be/src/pipeline/exec/exchange_sink_operator.cpp | 7 +-
be/src/pipeline/exec/exchange_source_operator.cpp | 4 +-
be/src/runtime/fold_constant_executor.cpp | 61 ++--
be/src/runtime/runtime_state.cpp | 7 +-
be/src/util/runtime_profile.cpp | 29 +-
be/src/util/runtime_profile.h | 34 ++
be/src/vec/columns/column_array.h | 16 +-
be/src/vec/columns/column_map.h | 18 +-
be/src/vec/columns/column_object.cpp | 21 +-
be/src/vec/columns/column_object.h | 10 +-
be/src/vec/columns/column_string.h | 29 +-
be/src/vec/columns/column_struct.h | 14 +-
be/src/vec/common/schema_util.cpp | 7 +-
be/src/vec/common/schema_util.h | 4 +-
be/src/vec/common/sort/heap_sorter.cpp | 16 +-
be/src/vec/core/sort_cursor.h | 47 +--
be/src/vec/exec/format/column_type_convert.h | 6 +-
be/src/vec/exec/scan/new_olap_scanner.cpp | 2 +-
be/src/vec/exec/scan/vscan_node.cpp | 3 +-
be/src/vec/olap/block_reader.cpp | 4 +-
be/src/vec/olap/vertical_block_reader.cpp | 4 +-
be/src/vec/olap/vgeneric_iterators.cpp | 34 +-
be/src/vec/olap/vgeneric_iterators.h | 10 +-
docker/runtime/be/Dockerfile | 5 +-
docker/runtime/be/resource/be_entrypoint.sh | 244 +++++++++++++
docker/runtime/be/resource/be_prestop.sh | 21 ++
docker/runtime/be/resource/entry_point.sh | 0
docker/runtime/be/resource/init_be.sh | 2 +-
docker/runtime/broker/Dockerfile | 54 ++-
.../runtime/broker/resource/broker_entrypoint.sh | 222 +++++++++++
docker/runtime/broker/resource/broker_is_alive.sh | 39 ++
docker/runtime/broker/resource/broker_prestop.sh | 21 ++
docker/runtime/broker/resource/init_broker.sh | 2 +-
docker/runtime/fe/Dockerfile | 6 +-
docker/runtime/fe/resource/fe_check_master.sh | 42 +++
docker/runtime/fe/resource/fe_entrypoint.sh | 395 ++++++++++++++++++++
docker/runtime/fe/resource/fe_prestop.sh | 21 ++
docker/runtime/fe/resource/init_fe.sh | 6 +-
.../java/org/apache/doris/catalog/ScalarType.java | 4 +
.../antlr4/org/apache/doris/nereids/DorisParser.g4 | 3 +
.../org/apache/doris/analysis/BaseViewStmt.java | 2 -
.../java/org/apache/doris/analysis/CastExpr.java | 5 +
.../org/apache/doris/analysis/CreateViewStmt.java | 9 +
.../java/org/apache/doris/analysis/MapLiteral.java | 2 +-
.../org/apache/doris/nereids/StatementContext.java | 14 +
.../doris/nereids/analyzer/UnboundRelation.java | 31 +-
.../apache/doris/nereids/analyzer/UnboundStar.java | 16 +-
.../glue/translator/PlanTranslatorContext.java | 2 +
.../org/apache/doris/nereids/hint/LeadingHint.java | 59 ++-
.../doris/nereids/parser/LogicalPlanBuilder.java | 51 ++-
.../apache/doris/nereids/parser/NereidsParser.java | 15 +-
.../nereids/rules/analysis/BindExpression.java | 14 +
.../doris/nereids/rules/analysis/BindRelation.java | 14 +-
.../doris/nereids/rules/analysis/LeadingJoin.java | 2 +-
.../expression/rules/FoldConstantRuleOnBE.java | 406 ++++++++++++++++++---
.../nereids/trees/expressions/SlotReference.java | 5 +
.../nereids/trees/expressions/WindowFrame.java | 28 +-
.../trees/expressions/functions/scalar/Lambda.java | 2 +-
.../trees/expressions/literal/MapLiteral.java | 5 +-
.../trees/expressions/literal/StructLiteral.java | 5 +-
.../apache/doris/nereids/trees/plans/PlanType.java | 3 +-
.../trees/plans/commands/CreateViewCommand.java | 49 +++
.../trees/plans/commands/info/CreateViewInfo.java | 330 +++++++++++++++++
.../commands/info/SimpleColumnDefinition.java | 6 +
.../trees/plans/visitor/CommandVisitor.java | 5 +
.../java/org/apache/doris/nereids/util/Utils.java | 17 +
.../org/apache/doris/planner/OlapScanNode.java | 5 +
.../java/org/apache/doris/planner/ScanNode.java | 7 +-
.../main/java/org/apache/doris/qe/Coordinator.java | 8 +-
.../java/org/apache/doris/qe/ResultReceiver.java | 41 ++-
.../java/org/apache/doris/qe/StmtExecutor.java | 3 +-
.../apache/doris/rewrite/FoldConstantsRule.java | 1 +
.../apache/doris/service/FrontendServiceImpl.java | 4 +-
.../org/apache/doris/analysis/MapLiteralTest.java | 12 +-
.../apache/doris/analysis/StructLiteralTest.java | 4 +-
.../nereids/trees/expressions/LiteralTest.java | 265 ++++++++++++++
gensrc/thrift/PaloInternalService.thrift | 1 +
.../data/ddl_p0/test_create_view_nereids.out | 228 ++++++++++++
.../fault_injection_p0/test_build_index_fault.out | 6 +
.../data/nereids_p0/hint/fix_leading.out | 25 ++
.../data/nereids_p0/hint/multi_leading.out | 4 +-
.../conditional_functions/test_query_in.out | 2 +
.../test_show_create_table_and_views_nereids.out | 46 +++
regression-test/data/variant_p0/agg.out | 78 ++++
.../data/variant_p0/compaction/test_compaction.out | 104 ++++++
regression-test/data/variant_p0/desc.out | 230 ++++++------
.../suites/ddl_p0/test_create_view.groovy | 5 +-
.../suites/ddl_p0/test_create_view_nereids.groovy | 280 ++++++++++++++
.../test_build_index_fault.groovy | 24 +-
.../scalar_function/Array.groovy | 14 +-
.../suites/nereids_p0/hint/fix_leading.groovy | 4 +
.../suites/nereids_p0/hint/multi_leading.groovy | 8 +-
.../conditional_functions/test_query_in.groovy | 46 +++
.../push_filter_inside_join.groovy | 1 +
.../filter_push_down/push_filter_through.groovy | 1 +
.../suites/query_p0/bi_p0/datagrip.groovy | 43 +++
.../suites/query_p0/bi_p0/dbeaver.groovy | 44 +++
.../suites/query_p0/join/test_join.groovy | 6 +-
.../test_show_create_table_and_views.groovy | 2 +
...est_show_create_table_and_views_nereids.groovy} | 8 +-
regression-test/suites/variant_p0/agg.groovy | 63 ++++
.../variant_p0/compaction/test_compaction.groovy | 11 +-
thirdparty/patches/librdkafka-1.9.2.patch | 31 ++
108 files changed, 3768 insertions(+), 509 deletions(-)
create mode 100755 docker/runtime/be/resource/be_entrypoint.sh
create mode 100755 docker/runtime/be/resource/be_prestop.sh
mode change 100644 => 100755 docker/runtime/be/resource/entry_point.sh
create mode 100755 docker/runtime/broker/resource/broker_entrypoint.sh
create mode 100755 docker/runtime/broker/resource/broker_is_alive.sh
create mode 100755 docker/runtime/broker/resource/broker_prestop.sh
create mode 100755 docker/runtime/fe/resource/fe_check_master.sh
create mode 100755 docker/runtime/fe/resource/fe_entrypoint.sh
create mode 100755 docker/runtime/fe/resource/fe_prestop.sh
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/CreateViewCommand.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/info/CreateViewInfo.java
create mode 100644 regression-test/data/ddl_p0/test_create_view_nereids.out
create mode 100644
regression-test/data/show_p0/test_show_create_table_and_views_nereids.out
create mode 100644 regression-test/data/variant_p0/agg.out
create mode 100644
regression-test/suites/ddl_p0/test_create_view_nereids.groovy
create mode 100644 regression-test/suites/query_p0/bi_p0/datagrip.groovy
create mode 100644 regression-test/suites/query_p0/bi_p0/dbeaver.groovy
copy regression-test/suites/show_p0/{test_show_create_table_and_views.groovy
=> test_show_create_table_and_views_nereids.groovy} (93%)
create mode 100644 regression-test/suites/variant_p0/agg.groovy
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
