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 58347aa2b75 [branch-2.1](bugfix) fix alter tablet not have memtracker
new 3081fc584d3 [Improvement](runtime-filter) support sync join node build
side's size to init bloom runtime filter (#32180)
new 326eee5d04f [Fix](schema change) Fix schema change fault when add
complex type column (#31824)
new 38b2e58d59d [Improvement](executor)cancel query when a query is queued
(#33339)
new 2708641bee9 [Fix]fix insert overwrite non-partition table null pointer
exception (#33205)
new ea1e542e31a [fix](partial-update) remove unnecessary DECHEK on
IndexChannel::num_rows_filtered (#33160)
new a38b97fbdd5 [bugfix](profile) should use backend ip:heartbeat port as
key during merge profile (#33368)
new f35dd3fc356 [chore](test) let some case suitable for legacy planner
and nereids (#33352)
new 3070eda58c5 [Bug](load) fix stream load file on hll type mv column
(#33373)
new ef26479282e [improve](serde) support complex type in write/read pb
serde (#33124)
new e4eb76212a8 [fix](Nereids): add order for constraint test (#33323)
new bc929686e37 [feature](debug point) add macro DBUG_RUN_CALLBACK (#33407)
new f7d52b5b1cc [feature](expr) add type check when expr prepare (#33330)
new b5a84f7d232 Fix alter column stats without min max value deserialize
failure. (#33406)
new ff38e7c4977 [log](chore) print isBad in Replica::toString() (#33427)
new 08427560ccc [fix](merge-cloud) fix possible data leak when creating
tables (#33416)
new 86dc1a04f2d [fix](cases) Add check status timeout for backup/restore
cases (#32975)
The 16 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/exec/exec_node.cpp | 12 +-
be/src/exprs/bloom_filter_func.h | 4 +-
be/src/exprs/runtime_filter.cpp | 457 +++++++++++--------
be/src/exprs/runtime_filter.h | 25 +-
be/src/exprs/runtime_filter_slots.h | 167 +++----
be/src/pipeline/exec/hashjoin_build_sink.cpp | 86 ++--
be/src/pipeline/exec/hashjoin_build_sink.h | 9 +-
be/src/pipeline/exec/join_build_sink_operator.cpp | 3 +-
be/src/pipeline/exec/join_build_sink_operator.h | 1 +
be/src/pipeline/exec/olap_scan_operator.cpp | 1 -
be/src/pipeline/pipeline_x/dependency.cpp | 10 +
be/src/pipeline/pipeline_x/dependency.h | 31 +-
be/src/pipeline/pipeline_x/operator.cpp | 5 +
be/src/pipeline/pipeline_x/operator.h | 2 +
be/src/runtime/fragment_mgr.cpp | 159 ++++---
be/src/runtime/fragment_mgr.h | 4 +
be/src/runtime/runtime_filter_mgr.cpp | 95 +++-
be/src/runtime/runtime_filter_mgr.h | 32 +-
be/src/service/backend_options.cpp | 1 +
be/src/service/internal_service.cpp | 33 +-
be/src/service/internal_service.h | 10 +
be/src/util/brpc_client_cache.h | 4 +
be/src/util/debug_points.h | 72 +--
be/src/vec/columns/column_array.cpp | 3 +-
be/src/vec/columns/column_map.cpp | 6 +-
be/src/vec/core/columns_with_type_and_name.h | 2 +-
.../vec/data_types/serde/data_type_array_serde.cpp | 30 ++
.../vec/data_types/serde/data_type_array_serde.h | 8 +-
.../vec/data_types/serde/data_type_decimal_serde.h | 7 +-
.../vec/data_types/serde/data_type_ipv4_serde.cpp | 20 +
be/src/vec/data_types/serde/data_type_ipv4_serde.h | 3 +
.../vec/data_types/serde/data_type_ipv6_serde.cpp | 24 +
be/src/vec/data_types/serde/data_type_ipv6_serde.h | 3 +
.../vec/data_types/serde/data_type_jsonb_serde.cpp | 28 ++
.../vec/data_types/serde/data_type_jsonb_serde.h | 3 +
.../vec/data_types/serde/data_type_map_serde.cpp | 37 ++
be/src/vec/data_types/serde/data_type_map_serde.h | 8 +-
.../data_types/serde/data_type_nullable_serde.cpp | 16 +-
.../vec/data_types/serde/data_type_number_serde.h | 35 +-
.../vec/data_types/serde/data_type_string_serde.h | 8 +-
.../data_types/serde/data_type_struct_serde.cpp | 71 ++-
.../vec/data_types/serde/data_type_struct_serde.h | 20 +-
be/src/vec/exec/join/vhash_join_node.cpp | 6 +-
be/src/vec/exec/join/vhash_join_node.h | 12 +-
be/src/vec/exec/join/vjoin_node_base.cpp | 1 +
be/src/vec/exec/join/vjoin_node_base.h | 1 +
be/src/vec/exec/scan/vscanner.cpp | 7 +-
be/src/vec/exprs/vexpr.cpp | 35 ++
be/src/vec/exprs/vexpr.h | 3 +
.../vec/runtime/shared_hash_table_controller.cpp | 11 +-
be/src/vec/runtime/shared_hash_table_controller.h | 20 +-
be/src/vec/sink/writer/vtablet_writer.h | 1 -
be/src/vec/utils/util.hpp | 19 +-
be/test/util/debug_points_test.cpp | 23 +-
.../data_types/serde/data_type_serde_pb_test.cpp | 492 ++++++++++++++++++++-
.../org/apache/doris/analysis/AddColumnClause.java | 4 +
.../java/org/apache/doris/analysis/ColumnDef.java | 12 +-
.../apache/doris/analysis/ModifyColumnClause.java | 4 +
.../java/org/apache/doris/catalog/Replica.java | 2 +
.../doris/common/profile/ExecutionProfile.java | 19 +-
.../apache/doris/datasource/InternalCatalog.java | 2 +
.../src/main/java/org/apache/doris/load/Load.java | 9 +-
.../nereids/rules/analysis/BindExpression.java | 3 +-
.../org/apache/doris/planner/RuntimeFilter.java | 4 +
.../main/java/org/apache/doris/qe/Coordinator.java | 21 +-
.../java/org/apache/doris/qe/QeProcessorImpl.java | 2 +-
.../java/org/apache/doris/qe/SessionVariable.java | 9 +
.../java/org/apache/doris/qe/StmtExecutor.java | 3 +
.../doris/resource/workloadgroup/QueueToken.java | 25 +-
.../doris/statistics/StatisticsRepository.java | 6 +-
.../main/java/org/apache/doris/system/Backend.java | 9 +
gensrc/proto/internal_service.proto | 30 +-
gensrc/proto/types.proto | 7 +
gensrc/thrift/PlanNodes.thrift | 2 +
.../routine_load_hll.out} | 10 +-
.../test | 0
.../insert_into_table/partial_update.out | 36 ++
.../data/nereids_syntax_p0/constraint.out | 8 +-
.../apache/doris/regression/suite/Syncer.groovy | 33 ++
.../account_p0/test_nereids_authentication.groovy | 14 +-
.../backup_restore/test_MoW_backup_restore.groovy | 48 +-
.../backup_restore/test_backup_restore.groovy | 8 +-
.../test_backup_restore_alias.groovy | 8 +-
.../test_backup_restore_bloom_filter.groovy | 8 +-
.../backup_restore/test_backup_restore_db.groovy | 8 +-
...t_backup_restore_diff_repo_same_snapshot.groovy | 16 +-
..._backup_restore_dup_without_default_keys.groovy | 8 +-
.../test_backup_restore_exclude.groovy | 8 +-
.../test_backup_restore_inverted_index.groovy | 8 +-
.../test_backup_restore_keep_on_local.groovy | 4 +-
.../test_backup_restore_multi_tables.groovy | 8 +-
...st_backup_restore_multi_tables_overwrite.groovy | 8 +-
.../test_backup_restore_partition.groovy | 12 +-
..._restore_reserve_dynamic_partition_false.groovy | 10 +-
...p_restore_reserve_dynamic_partition_true.groovy | 9 +-
.../test_backup_restore_table_auto_bucket.groovy | 8 +-
.../backup_restore/test_backup_restore_with.groovy | 8 +-
..._backup_restore_with_two_phase_fetch_opt.groovy | 8 +-
.../test_duplicate_backup_restore.groovy | 20 +-
.../test_restore_mix_exists_and_new_table.groovy | 8 +-
.../test_restore_to_new_table.groovy | 8 +-
.../test_unique_backup_restore.groovy | 16 +-
.../ccr_mow_syncer_p1/test_backup_restore.groovy | 10 +-
.../ccr_syncer_p1/test_backup_restore.groovy | 10 +-
.../correctness_p0/test_group_having_alias.groovy | 3 +
.../insert_overwrite_legacy_unpartitioned.groovy} | 28 +-
.../inverted_index_p0/test_null_index.groovy | 5 -
.../routine_load_hll.groovy} | 29 +-
.../insert_into_table/partial_update.groovy | 37 ++
.../suites/nereids_syntax_p0/constraint.groovy | 14 +-
.../window_functions/test_ntile_function.groovy | 4 +-
.../test_alter_table_replace.groovy | 2 +-
.../test_schema_change_duplicate.groovy | 7 +
.../test_schema_change_unique.groovy | 8 +
.../test_schema_change_unique_mow.groovy | 7 +
115 files changed, 1992 insertions(+), 879 deletions(-)
copy regression-test/data/mv_p0/{test_base/test_base.out =>
routine_load_hll/routine_load_hll.out} (57%)
copy regression-test/data/mv_p0/{routine_load_mapping =>
routine_load_hll}/test (100%)
copy
regression-test/suites/{datatype_p0/decimalv3/test_decimalv3_key/test_decimalv3_key.groovy
=> insert_overwrite_p0/insert_overwrite_legacy_unpartitioned.groovy} (62%)
copy
regression-test/suites/mv_p0/{routine_load_mapping/routine_load_mapping.groovy
=> routine_load_hll/routine_load_hll.groovy} (59%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
