This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a change to branch 2.1-tmp
in repository https://gitbox.apache.org/repos/asf/doris.git
from 77ad3f6a193 [feature](hive)Get updated information from coordinate and
commit (#32441) (#33466)
new 0ab8b57db7c [enhance](mtmv)support create mtmv with other mtmv (#32984)
new 6798a24a27c [Enhencement](Nereids) reduce child output rows if agg
child is literal (#32188)
new 8fd6d4c41b8 [Chore](build) add -Wconversion and remove some unused
code (#33127)
new 2e40e395844 [chore](spill) add timers for performance tuning (#33185)
new 67bb5196137 [Fix](nereids) forward the user define variables to master
(#33013)
new 5e59c09a602 [Fix](nereids) modify the binding aggregate function in
order by (#32758)
new 9670422d61e [fix](inverted index) fix the incorrect result issue of
COUNT_ON_INDEX for key columns (#33164)
new edd17019633 [fix](Nereids) convert agg state type failed in some cases
(#33208)
new b696909775e [fix](plsql) Fix plsql variable initialization (#33186)
new 2b1ab89b5ba [fix](memory) Fix memory log compile by ASAN (#33162)
new 96867ff3fd7 [fix](Nereids) support update without filter (#33214)
new 7fae123b01f [FIX](inverted_index) fix inverted index write array with
_doc is empty (#33170)
new b85bf3b6b06 [test](cast) add test for stream load cast (#33189)
The 13 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/CMakeLists.txt | 11 +-
be/src/clucene | 2 +-
be/src/exprs/bloom_filter_func.h | 4 +-
be/src/glibc-compatibility/CMakeLists.txt | 1 +
be/src/http/http_client.h | 2 +-
be/src/olap/cumulative_compaction_policy.cpp | 2 +-
be/src/olap/memtable.cpp | 4 +-
be/src/olap/olap_server.cpp | 2 +-
be/src/olap/rowset/segment_v2/bloom_filter.cpp | 2 +-
.../rowset/segment_v2/inverted_index_cache.cpp | 4 +-
.../rowset/segment_v2/inverted_index_writer.cpp | 9 +-
be/src/olap/rowset/segment_v2/segment_iterator.cpp | 20 +-
be/src/olap/rowset/segment_v2/segment_iterator.h | 5 +-
be/src/olap/wal/wal_table.cpp | 15 +-
.../exec/partitioned_aggregation_sink_operator.cpp | 5 +-
.../partitioned_aggregation_source_operator.cpp | 7 +-
.../exec/partitioned_hash_join_probe_operator.cpp | 100 ++-
.../exec/partitioned_hash_join_probe_operator.h | 24 +-
.../exec/partitioned_hash_join_sink_operator.cpp | 53 +-
.../exec/partitioned_hash_join_sink_operator.h | 12 +-
be/src/pipeline/exec/set_probe_sink_operator.cpp | 4 +-
be/src/pipeline/exec/spill_sort_sink_operator.cpp | 10 +-
.../pipeline/exec/spill_sort_source_operator.cpp | 9 +-
be/src/pipeline/pipeline_x/operator.h | 6 +
be/src/pipeline/pipeline_x/pipeline_x_task.cpp | 2 +-
be/src/pipeline/task_queue.cpp | 2 +-
be/src/pipeline/task_queue.h | 2 +-
be/src/runtime/decimalv2_value.cpp | 2 +-
be/src/runtime/memory/mem_tracker_limiter.cpp | 8 +-
be/src/runtime/workload_group/workload_group.cpp | 2 +-
.../workload_group/workload_group_manager.cpp | 4 +-
be/src/util/counts.h | 4 +-
be/src/util/cpu_info.cpp | 2 +-
be/src/util/date_func.cpp | 4 +-
be/src/util/hash_util.hpp | 2 +-
be/src/util/mem_info.cpp | 21 +-
be/src/util/os_util.cpp | 6 +-
be/src/util/parse_util.cpp | 6 +-
be/src/util/perf_counters.cpp | 4 +
be/src/util/runtime_profile.cpp | 2 +-
be/src/util/url_coding.cpp | 2 +-
.../aggregate_function_avg_weighted.h | 2 +-
.../aggregate_function_stddev.h | 2 +-
be/src/vec/columns/column.h | 7 -
be/src/vec/columns/column_array.h | 4 -
be/src/vec/columns/column_complex.h | 6 -
be/src/vec/columns/column_const.cpp | 16 -
be/src/vec/columns/column_const.h | 2 -
be/src/vec/columns/column_decimal.h | 5 -
be/src/vec/columns/column_dictionary.h | 6 -
be/src/vec/columns/column_dummy.h | 14 -
be/src/vec/columns/column_fixed_length_object.h | 6 -
be/src/vec/columns/column_impl.h | 27 -
be/src/vec/columns/column_map.h | 3 -
be/src/vec/columns/column_nullable.h | 4 -
be/src/vec/columns/column_object.h | 5 -
be/src/vec/columns/column_string.h | 4 -
be/src/vec/columns/column_struct.cpp | 23 -
be/src/vec/columns/column_struct.h | 1 -
be/src/vec/columns/column_vector.h | 17 +-
be/src/vec/columns/predicate_column.h | 6 -
be/src/vec/common/uint128.h | 7 +
be/src/vec/core/types.h | 6 +-
be/src/vec/data_types/data_type.h | 2 +-
be/src/vec/data_types/data_type_decimal.h | 3 +-
.../vec/data_types/serde/data_type_number_serde.h | 2 +-
be/src/vec/exec/scan/scanner_context.cpp | 4 +-
be/src/vec/exec/vset_operation_node.cpp | 4 +-
.../exprs/table_function/vexplode_json_array.cpp | 2 +-
be/src/vec/functions/array/function_array_join.h | 2 +-
be/src/vec/functions/function_cast.h | 12 +-
be/src/vec/functions/function_quantile_state.cpp | 2 +-
be/src/vec/functions/int_div.h | 6 +-
be/src/vec/sink/writer/vtablet_writer.cpp | 8 +-
be/test/olap/wal/wal_manager_test.cpp | 4 +-
be/test/vec/core/block_spill_test.cpp | 8 +-
be/test/vec/core/block_test.cpp | 4 +-
.../serde/data_type_serde_arrow_test.cpp | 2 +-
.../serde/data_type_serde_mysql_test.cpp | 2 +-
.../data_types/serde/data_type_serde_pb_test.cpp | 2 +-
.../vec/data_types/serde/data_type_serde_test.cpp | 2 +-
be/test/vec/jsonb/serialize_test.cpp | 2 +-
.../antlr4/org/apache/doris/nereids/DorisParser.g4 | 2 +-
.../antlr4/org/apache/doris/nereids/PLLexer.g4 | 4 -
.../antlr4/org/apache/doris/nereids/PLParser.g4 | 2 +-
.../org/apache/doris/analysis/LiteralExpr.java | 20 +
.../doris/nereids/jobs/executor/Rewriter.java | 2 +
.../doris/nereids/parser/LogicalPlanBuilder.java | 2 +-
.../org/apache/doris/nereids/rules/RuleType.java | 1 +
.../nereids/rules/analysis/BindExpression.java | 57 +-
.../nereids/rules/analysis/FillUpMissingSlots.java | 2 +-
.../expression/rules/ConvertAggStateCast.java | 38 +-
.../rewrite/ReduceAggregateChildOutputRows.java | 89 ++
.../trees/plans/commands/info/CreateMTMVInfo.java | 11 -
.../src/main/java/org/apache/doris/plsql/Exec.java | 6 -
.../doris/plsql/executor/DorisRowResult.java | 2 +-
.../java/org/apache/doris/qe/ConnectContext.java | 8 +
.../java/org/apache/doris/qe/ConnectProcessor.java | 25 +-
.../java/org/apache/doris/qe/MasterOpExecutor.java | 17 +-
.../rules/analysis/FillUpMissingSlotsTest.java | 2 +-
gensrc/thrift/FrontendService.thrift | 3 +-
.../data/inverted_index_p0/test_index_delete.out | 16 +
.../data/load_p0/stream_load/test_cast1.csv | 1 +
.../data/load_p0/stream_load/test_cast1.json | 1 +
.../data/load_p0/stream_load/test_cast2.csv | 1 +
.../data/load_p0/stream_load/test_cast2.json | 1 +
.../data/load_p0/stream_load/test_cast3.csv | 1 +
.../data/load_p0/stream_load/test_cast3.json | 1 +
.../load_p0/stream_load/test_stream_load_cast.out | 19 +
.../data/mtmv_p0/test_multi_level_mtmv.out | 13 +
.../eliminate_aggregate_constant.out | 993 +++++++++++++++++++++
.../nereids_syntax_p0/order_by_bind_priority.out | 25 +
.../data/plsql_p0/test_plsql_variable.out | 13 +
.../inverted_index_p0/test_index_delete.groovy | 65 ++
.../stream_load/test_stream_load_cast.groovy | 336 +++++++
.../suites/mtmv_p0/test_build_mtmv.groovy | 15 -
.../suites/mtmv_p0/test_multi_level_mtmv.groovy | 81 ++
.../eliminate_aggregate_constant.groovy | 285 ++++++
.../order_by_bind_priority.groovy | 38 +
.../suites/plsql_p0/test_plsql_loop_cursor.groovy | 7 +
.../suites/plsql_p0/test_plsql_variable.groovy | 110 +++
121 files changed, 2546 insertions(+), 403 deletions(-)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/ReduceAggregateChildOutputRows.java
create mode 100644 regression-test/data/inverted_index_p0/test_index_delete.out
create mode 100644 regression-test/data/load_p0/stream_load/test_cast1.csv
create mode 100644 regression-test/data/load_p0/stream_load/test_cast1.json
create mode 100644 regression-test/data/load_p0/stream_load/test_cast2.csv
create mode 100644 regression-test/data/load_p0/stream_load/test_cast2.json
create mode 100644 regression-test/data/load_p0/stream_load/test_cast3.csv
create mode 100644 regression-test/data/load_p0/stream_load/test_cast3.json
create mode 100644
regression-test/data/load_p0/stream_load/test_stream_load_cast.out
create mode 100644 regression-test/data/mtmv_p0/test_multi_level_mtmv.out
create mode 100644
regression-test/data/nereids_rules_p0/eliminate_aggregate_constant/eliminate_aggregate_constant.out
create mode 100644
regression-test/data/nereids_syntax_p0/order_by_bind_priority.out
create mode 100644 regression-test/data/plsql_p0/test_plsql_variable.out
create mode 100644
regression-test/suites/inverted_index_p0/test_index_delete.groovy
create mode 100644
regression-test/suites/load_p0/stream_load/test_stream_load_cast.groovy
create mode 100644 regression-test/suites/mtmv_p0/test_multi_level_mtmv.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/eliminate_aggregate_constant/eliminate_aggregate_constant.groovy
create mode 100644
regression-test/suites/nereids_syntax_p0/order_by_bind_priority.groovy
create mode 100644 regression-test/suites/plsql_p0/test_plsql_variable.groovy
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
