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 e9e46995cce [branch-2.1](regression-test) fix test_chema_change_fail
(#33753) #33788
new 6ce8267ce7a [fix](restore) Reset index id for restore (#33648)
new 895b3a6f7ab [Fix](executor)Fix routine load failed when can not find
group (#33596)
new ef4cc599df1 Improve analyze mv/mtmv wait row count report logic.
(#33695)
new 2dccf9fd1e6 [fix](move-memtable) close wait on all sinks (#33710)
new 060eaaf3d94 [test](xor) add test for xor #33731
new ce971b1da46 [fix](chore) update some CHECK to CHECK_EQ, to print more
details while CHECK failed (#33709)
new 7e0b808622d [Improvement](runtime-filter) make sync rf size work when
need_local_merge (#33717)
new 34984539637 [FIX](load)fix load with split-by-string (#33713)
new 77d7df9d0b3 [refactor](pipelineX) Reduce prepare overhead (PART III)
(#33689)
new 223af45351f [Fix](Json type) forbit schema change adding JSON columns
with none null default value (#33686)
new 63b3e8b0b17 [fix](test) remove array_intersect case since its result
is not stable (#33742)
new e6725e99e38 [Fix](inverted index) fix memory leak when inverted index
writer not close (#33724)
new 6fa2c6c5ecb [feature](windows function)Improve error handling for
window functions (#33673)
new 5ca0b43e3a0 [enhancement](auditlog) ignore any errors in write audit
log (#33750)
new eab05ebed51 [fix](restore) add indexes as part of table signature
(#33650)
new 560f325dddb [chore](variable) update nereids timeout second default
value to 30 (#33749)
new d6a6b37f19e [shuffle](minor) Log error status if exchange is shutdown
early (#33748)
new bdf9bf0e9fb [improvement](spill) avoid occuping too much memory while
spill build block during the hash join build phase (#33747)
new fb54f8ad2db [fix](inverted index) normal process query for null
condition when index is missing (#33663)
new 5045caf10ea [fix](conf) make be conf disable_storage_page_cache
modifiable (#33773)
new e9eccb08a5a [minor](Nereids): remove useless stream filter() in
Translator (#33758)
new 5985266fb44 [fix](Nereids) dphyper support evaluate join that has one
side condition (#33702)
new 055624ee6b3 Add workload group id in workload policy's property
(#33483)
The 23 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/agent/workload_sched_policy_listener.cpp | 8 +-
be/src/common/config.cpp | 2 +-
be/src/exprs/runtime_filter.cpp | 5 +-
be/src/exprs/runtime_filter_slots.h | 4 +-
be/src/olap/rowset/segment_v2/column_writer.cpp | 38 ++++-
.../rowset/segment_v2/inverted_index_reader.cpp | 22 ++-
.../olap/rowset/segment_v2/inverted_index_reader.h | 2 +
.../rowset/segment_v2/inverted_index_writer.cpp | 7 +-
be/src/olap/rowset/segment_v2/segment_writer.cpp | 6 +-
.../rowset/segment_v2/vertical_segment_writer.cpp | 6 +-
be/src/pipeline/exec/hashjoin_build_sink.cpp | 4 +-
be/src/pipeline/exec/join_probe_operator.cpp | 17 ++-
be/src/pipeline/exec/join_probe_operator.h | 1 +
.../exec/multi_cast_data_stream_source.cpp | 19 ++-
.../pipeline/exec/multi_cast_data_stream_source.h | 6 +-
.../exec/nested_loop_join_build_operator.cpp | 16 +-
.../exec/nested_loop_join_build_operator.h | 1 +
.../exec/nested_loop_join_probe_operator.cpp | 10 +-
.../exec/nested_loop_join_probe_operator.h | 1 +
.../exec/partitioned_hash_join_probe_operator.cpp | 3 +-
.../exec/partitioned_hash_join_probe_operator.h | 2 +-
.../exec/partitioned_hash_join_sink_operator.cpp | 166 ++++++++++++++++-----
.../exec/partitioned_hash_join_sink_operator.h | 4 +-
be/src/runtime/fragment_mgr.cpp | 2 +
be/src/runtime/runtime_state.cpp | 4 +-
.../workload_management/workload_query_info.h | 1 +
.../workload_management/workload_sched_policy.cpp | 11 +-
.../workload_management/workload_sched_policy.h | 2 +
.../workload_sched_policy_mgr.cpp | 1 -
be/src/vec/sink/load_stream_map_pool.cpp | 16 +-
be/src/vec/sink/vdata_stream_sender.cpp | 10 +-
be/src/vec/sink/writer/vtablet_writer_v2.cpp | 8 +-
.../java/org/apache/doris/analysis/ColumnDef.java | 12 +-
.../java/org/apache/doris/backup/RestoreJob.java | 15 +-
.../main/java/org/apache/doris/catalog/Env.java | 4 +
.../java/org/apache/doris/catalog/OlapTable.java | 55 +++++--
.../src/main/java/org/apache/doris/load/Load.java | 6 +-
.../doris/load/routineload/KafkaTaskInfo.java | 52 ++++---
.../glue/translator/PhysicalPlanTranslator.java | 6 +-
.../nereids/rules/analysis/CheckAfterRewrite.java | 3 +-
.../plans/commands/info/ColumnDefinition.java | 4 +
.../java/org/apache/doris/qe/AuditLogHelper.java | 16 ++
.../java/org/apache/doris/qe/SessionVariable.java | 3 +-
.../resource/workloadgroup/WorkloadGroupMgr.java | 41 ++++-
.../workloadschedpolicy/WorkloadSchedPolicy.java | 41 +++--
.../WorkloadSchedPolicyMgr.java | 50 ++++++-
.../doris/tablefunction/MetadataGenerator.java | 1 +
.../WorkloadSchedPolicyTableValuedFunction.java | 3 +-
.../jobs/joinorder/hypergraph/OtherJoinTest.java | 18 +++
.../doris/nereids/util/HyperGraphBuilder.java | 5 +-
gensrc/thrift/BackendService.thrift | 1 +
.../data/correctness_p0/test_bit_function.out | 17 +++
.../test_no_index_null_fault_injection.out} | 0
.../stream_load/test_array_split_string.csv | 1 +
.../stream_load/test_array_with_func_load.out} | 3 +-
...> test_backup_restore_overwrite_indexes.groovy} | 28 ++--
.../suites/correctness_p0/test_bit_function.groovy | 9 ++
.../test_window_function_error.groovy} | 36 +++--
.../test_no_index_null_fault_injection.groovy | 65 ++++++++
.../stream_load/test_array_with_func_load.groovy} | 58 +++----
.../nereids_function_p0/agg_function/agg.groovy | 131 ++++++++--------
.../test_unique_model_schema_key_change.groovy | 14 +-
.../suites/statistics/test_analyze_mtmv.groovy | 11 +-
.../suites/statistics/test_analyze_mv.groovy | 14 +-
.../test_workload_sched_policy.groovy | 77 +++++++++-
65 files changed, 894 insertions(+), 311 deletions(-)
copy regression-test/data/{inverted_index_p0/test_compound.out =>
fault_injection_p0/test_no_index_null_fault_injection.out} (100%)
create mode 100644
regression-test/data/load_p0/stream_load/test_array_split_string.csv
copy regression-test/data/{correctness/test_forbidden_infer_filter_rule.out =>
load_p0/stream_load/test_array_with_func_load.out} (85%)
copy
regression-test/suites/backup_restore/{test_backup_restore_ngram_bloom_filter.groovy
=> test_backup_restore_overwrite_indexes.groovy} (83%)
copy regression-test/suites/{insert_p0/test_array_insert_overflow.groovy =>
correctness_p0/test_window_function_error.groovy} (61%)
create mode 100644
regression-test/suites/fault_injection_p0/test_no_index_null_fault_injection.groovy
copy regression-test/suites/{datatype_p2/complex_types/test_big_kv_map.groovy
=> load_p0/stream_load/test_array_with_func_load.groovy} (51%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
