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 5aed3abb8a8 [Fix](Nereids) Fix rewrite by materialized view fail when
join input has agg (#30734)
new d749fc3d279 [improvement](binlog) Change BinlogConfig default
TTL_SECONDS to 86400 (1day) (#30771)
new 3cc409b14ff [bug](function) fix date_sub function failed when arg type
is datev2 (#30443)
new c9ab243153b [feat-wip](join) support mark join for right semi
join(without mark join conjunct) (#30767)
new 36b27127097 [chore](Nereids) turn on nereids dml when update to 2.1
(#30776)
new 6442663735d [Function](exec) upport atan2 math function (#30672)
new e10defeaba5 [enhancement](plubin)support json format and other options
in logstash doris output plugin (#27318)
new b275cb0f44b [feature](mtmv) mtmv support workload group (#29595)
new 383850ef12b [Opt](multi-catalog) Opt split assignment to resolve
uneven distribution. (#30390)
new 121d52dd37b [test](mtmv) Add mtmv basic one and two dimensional test
cases (#30651)
new 1d39e16eda0 [Bug](compaction) pass arena to function->add_batch_range
(#30709)
new 91a669f5fde [chore](mac compile) remove using regex to avoid mac
compile failed frequently #30783
The 11 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/olap/delete_handler.cpp | 7 +-
be/src/pipeline/exec/hashjoin_probe_operator.cpp | 2 +-
be/src/pipeline/exec/join_build_sink_operator.cpp | 6 +-
be/src/vec/common/hash_table/join_hash_table.h | 34 +-
be/src/vec/exec/join/process_hash_table_probe.h | 2 +-
.../vec/exec/join/process_hash_table_probe_impl.h | 22 +-
be/src/vec/exec/join/vhash_join_node.cpp | 2 +-
be/src/vec/exec/join/vjoin_node_base.cpp | 6 +-
be/src/vec/functions/math.cpp | 16 +
be/src/vec/olap/vertical_block_reader.cpp | 13 +-
be/src/vec/olap/vertical_block_reader.h | 1 +
docs/en/docs/ecosystem/logstash.md | 6 +
.../sql-functions/numeric-functions/atan2.md | 52 ++
docs/sidebars.json | 1 +
docs/zh-CN/docs/ecosystem/logstash.md | 6 +
.../sql-functions/numeric-functions/atan2.md | 52 ++
extension/logstash/lib/logstash/outputs/doris.rb | 21 +
extension/logstash/logstash-output-doris.gemspec | 2 +-
.../main/java/org/apache/doris/common/Config.java | 23 +-
.../doris/analysis/TimestampArithmeticExpr.java | 12 +
.../org/apache/doris/catalog/BinlogConfig.java | 2 +-
.../doris/catalog/BuiltinScalarFunctions.java | 2 +
.../main/java/org/apache/doris/catalog/Env.java | 4 +
.../main/java/org/apache/doris/catalog/MTMV.java | 10 +
.../apache/doris/common/IndexedPriorityQueue.java | 228 +++++++
.../doris/{spi/Split.java => common/Queue.java} | 21 +-
.../doris/common/ResettableRandomizedIterator.java | 63 ++
.../UpdateablePriorityQueue.java} | 18 +-
.../apache/doris/common/util/ConsistentHash.java | 39 +-
.../apache/doris/common/util/PropertyAnalyzer.java | 1 +
.../java/org/apache/doris/mtmv/MTMVPlanUtil.java | 5 +
.../trees/expressions/functions/scalar/Atan2.java | 68 ++
.../expressions/visitor/ScalarFunctionVisitor.java | 5 +
.../plans/commands/info/AlterMTMVPropertyInfo.java | 13 +
.../trees/plans/commands/info/CreateMTMVInfo.java | 13 +
.../doris/planner/external/ExternalScanNode.java | 6 +-
.../planner/external/FederationBackendPolicy.java | 361 +++++++++-
.../doris/planner/external/FileQueryScanNode.java | 129 ++--
.../apache/doris/planner/external/FileSplit.java | 7 +
.../external/NodeSelectionStrategy.java} | 16 +-
.../apache/doris/planner/external/SplitWeight.java | 130 ++++
.../main/java/org/apache/doris/qe/VariableMgr.java | 20 +
.../java/org/apache/doris/rewrite/FEFunctions.java | 15 +
.../apache/doris/rewrite/FoldConstantsRule.java | 6 +-
.../src/main/java/org/apache/doris/spi/Split.java | 23 +
.../main/java/org/apache/doris/system/Backend.java | 2 +-
.../doris/planner/FederationBackendPolicyTest.java | 730 ++++++++++++++++++---
gensrc/script/doris_builtins_functions.py | 1 +
.../test_vertical_compaction_agg_state.out | 12 +
.../test_group_commit_interval_ms_property.out | 8 +-
.../data/mtmv_p0/test_workload_group_mtmv.out | 7 +
.../data/nereids_function_p0/scalar_function/A.out | 29 +
.../data/query_p0/show/test_show_create_table.out | 4 +-
.../show_p0/test_show_create_table_and_views.out | 8 +-
.../org/apache/doris/regression/suite/Suite.groovy | 21 +
.../test_vertical_compaction_agg_state.groovy | 131 ++++
.../suites/delete_p0/test_delete.groovy | 22 +
.../suites/mtmv_p0/test_workload_group_mtmv.groovy | 65 ++
.../nereids_function_p0/scalar_function/A.groovy | 4 +-
.../mv/dimension/dimension_1.groovy | 689 +++++++++++++++++++
.../mv/dimension/dimension_2_1.groovy | 433 ++++++++++++
.../mv/dimension/dimension_2_2.groovy | 432 ++++++++++++
.../mv/dimension/dimension_2_3.groovy | 373 +++++++++++
.../mv/dimension/dimension_2_4.groovy | 715 ++++++++++++++++++++
.../mv/dimension/dimension_2_5.groovy | 424 ++++++++++++
.../mv/dimension/dimension_2_6.groovy | 409 ++++++++++++
66 files changed, 5750 insertions(+), 260 deletions(-)
create mode 100644
docs/en/docs/sql-manual/sql-functions/numeric-functions/atan2.md
create mode 100644
docs/zh-CN/docs/sql-manual/sql-functions/numeric-functions/atan2.md
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/common/IndexedPriorityQueue.java
copy fe/fe-core/src/main/java/org/apache/doris/{spi/Split.java =>
common/Queue.java} (68%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/common/ResettableRandomizedIterator.java
copy fe/fe-core/src/main/java/org/apache/doris/{spi/Split.java =>
common/UpdateablePriorityQueue.java} (69%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/Atan2.java
copy fe/fe-core/src/main/java/org/apache/doris/{spi/Split.java =>
planner/external/NodeSelectionStrategy.java} (83%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/planner/external/SplitWeight.java
create mode 100644
regression-test/data/compaction/test_vertical_compaction_agg_state.out
create mode 100644 regression-test/data/mtmv_p0/test_workload_group_mtmv.out
create mode 100644
regression-test/suites/compaction/test_vertical_compaction_agg_state.groovy
create mode 100644
regression-test/suites/mtmv_p0/test_workload_group_mtmv.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/mv/dimension/dimension_1.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/mv/dimension/dimension_2_1.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/mv/dimension/dimension_2_2.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/mv/dimension/dimension_2_3.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/mv/dimension/dimension_2_4.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/mv/dimension/dimension_2_5.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/mv/dimension/dimension_2_6.groovy
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
