This is an automated email from the ASF dual-hosted git repository.
hellostephen pushed a change to branch hello-stephen-patch-5
in repository https://gitbox.apache.org/repos/asf/doris.git
from 9dbd88fb0f6 Merge branch 'master' into hello-stephen-patch-5
add 31fe4810f4a [clean](planner)routine load removes dependency on the old
optimizer (#51560)
add 8775a1ad19d [Fix](compile) Fix arm compile failure caused by undefined
symbol (#51715)
add d30a00ab53e [Chore](nereids) Remove AlterSystemStmt (#51890)
add d810f78efb1 [fix](inverted_index) fix tokenization issues for some
characters in ik analyzer (#50141)
add f0567be5bc3 [Enhancement][docker] entrypoint parse meta dir (#51693)
add 40ddeabf42f [Fix](Variant) fix serialize with json key contains `.` as
name (#51857)
add eba4bb497b8 [Chore](nereids) remove ShowStmt (#51798)
add 480987a0581 [refactor](jsonb) rename `JsonbValue::length` to
`JsonbValue::numElements` (#51911)
add 2a0e99d3130 [test](mv) Fix mv regression test is not chosen stable by
CBO (#50690)
add 07f2478def4 [Enhancement] (nereids) optimize CleanQueryStatsCommand
and remove CleanQueryStatsStmt (#51840)
add 062c18bcb7b [opt](audit) add many audit info into audit log and table
(#51363)
add 36e9e773c1e [fix](group commit) add bvar for group commit block by
memory counter (#51851)
add 78fdc95b755 [fix](mow) fix update delete bitmap lock not removed if
schema change for empty tablet (#51780)
add f03dc40b9e2 [fix](CI) auto pick to branch-3.1 is not work as expected
(#51954)
add 19b7b3ac7ba [improvement](nereids)Support GROUP BY ... WITH ROLLUP
syntax (#51948)
add ced0a513a23 [feature](nereids) provide error location when can not
find db/table/column in query (#51768)
add 19a571d6d8f [bugfix](memleak) fix memleak in arrow input stream
(#51929)
add f55f937b4d3 [Chore](nereids) Remove remaining showstmt (#51854)
add e748fad0ca8 [Chore](nereids) remove ResumeRoutineLoadStmt (#51829)
add 0fc537ae29b [Enhancement] (nereids) optimize CancelWarmUpJobCommand
and remove CancelCloudWarmUpStmt (#51847)
add 8a44c575903 [fix](nereids) fix Cast cannot be cast to class
org.apache.doris.nereids.trees.expressions.NamedExpression (#51925)
add f7e1d7c43a5 [fix](inverted index) fix error when writing empty index
file (#51984)
add 068af3248d4 [Enchancement](sort) refactor of
SortingQueueImpl::update_batch_size / MergeSortCursorImpl::reverse (#51803)
add 3e6c20d196a [fix](planner)Fix the concurrency issue caused by Expr
setting member variables (#51389)
add 78f318d9fa0 [test](inverted index) add ut for index parser (#52001)
add 7bd3d6374b1 [chore](inverted index) remove useless match predicate
(#52010)
add f3ea5066745 [opt](memory) dynamic adjustment of jemalloc's sampling
rate during runtime (#52003)
add 13280afd041 [enhance](thrift)add id to all enum types in thrift
definition (#51817)
add 7722c74e304 [fix](pipeline) premature exit causing core dump during
concurrent prepare execution (#51492)
add ff5c59e1859 [clear](meta) update minimum meta version required to 140
(#51530)
add a8fdbce0432 [opt](metrics) add metrics pipeline_task_queue_size
(#51878)
add 828a639557e [fix](compile) fix RoutineLoadJob compile error (#52047)
add 27994896a57 [fix](load) print real reason if fetching Kafka meta fail
(#51880)
add d3b7b44d71e [Chore](nereids) remove KillStmt (#51804)
add b1036c0e608 [Chore](nereids) Remove DropResource/PolicyStmt (#51860)
add ee38477d6f5 [chore](regression-test) move test_cold_data_compaction to
`nonConcurrent` (#50699)
add cf0aae9c893 [test](inverted index) add ut for index phrase query
(#52017)
add 9234f8f48df [chore](ci) change stop order from FE BE MS to BE FE MS
(#51945)
add 484a7c296b0 [test](mv)forbid create mv test case (#51777)
add 177c65dab49 [Opt](cloud-mow) Add more delete bitmap verbose log
(#51751)
add 279fa92f0fe [feature](iceberg catalog) support iceberg view query
(#51376)
add af68d8b5077 [feat](profile) support getting query progress (#51400)
add 890d11d9a67 [opt](audit) use one line in audit log and origin
statement in audit table (#52032)
add 7f2c0c31255 [fix](meta) Do not copy it when input rowset meta dont
have load id (#52088)
add 2d1a1735330 [feature](restapi) add broker operate rest api, including
ADD/DROP/DROP_ALL (#51745)
add c26e64ac2f2 [chore](cloud) Implement idempotent injection framework
for meta-service (#51905)
add 52d649ff5fc [test](inverted index) add more unit tests for
InvertedIndexFileWriter exception scenarios (#52016)
add df201633a62 [chore](Be)Optimize the binary size of be by reducing
template instantiations for Corr/Min_By/Max_By. (#51933)
add f40364f5a58 [fix](exception) Use normal exception to represent query
timeout (#51994)
add 24954fc1610 [feature](jsonb) Add decimal type in JsonbDocument (#51766)
add b7d8fafb3da [test](inverted index) add more unit tests for
InvertedIndexCompoundReader exception scenarios (#52063)
add 68c710d1f51 [test](inverted index) add more ut tests for inverted
index file writer (#52112)
add ded28ab112e [test](inverted index) add ut tests for inverted index
file reader (#52111)
add bd7f754cf20 [chore](storage vault) Make CacheHotspotManager exception
msg more distinct (#51861)
add 97ad059f01a [test](inverted index) add more unit tests for
InvertedIndexCompaction ram directory disable scenarios (#52065)
add 1552f2c9621 [fix](load) resolve UBSan error when printing unique IDs
(#52042)
add ec2011314d0 [Bug](agg) make LogicalAggregate pull up comparison
predicate return correct expressions (#51750)
add 7622024e786 [enhancement](filecache) fix default capacity and add
reset_capacity validation (#51711)
add 34d862ec2fd [chore](cloud) rename cloud::put/get to blob_put/blob_get
(#51762)
add 86c17b71f63 [improve](cloud) make meta_service_endpoint configurable
(#51748)
add a9de3516784 [fix](case) fix mow case (#52012)
add c81c6bc6fb4 [fix](case) fix
test_mow_compaction_agg_and_remove_pre_delete_bitmap (#51667)
add cbd5e1c6f8f [fix](case) fix test_group_commit_schema_change (#51950)
add 717d1f1d211 [Chore](nereids) Remove AdminStmt (#51908)
add a99eb34e82c [fix](system-table)fix tablet table tablet id (#51934)
add 5f46bbd947c [Chore](nereids) remove WarmUpStmt (#51789)
add a5fdfb9bb90 [chore](cloud) Add a defer utility `DORIS_CLOUD_DEFER`
(#52041)
add 5710ccd8b9a [chore](http) return NOT_FOUND if dir is not exists
(#51897)
add 823e0a11a5e [refactor](date) Simplify template args for date functions
(#52129)
add 2d2f170f8c2 [chore](Be)Optimize the binary size of be by reducing
template instantiations for Min/Max/Any (#52119)
add ac6e6949b06 [Bug](aggregate) fix bitmap_union return error result in
query sql (#52033)
add fd59cfd3ca6 [Chore](nereids) remove TransactionStmt (#51805)
add a9aebd2d15d [Chore](nereids) remove PauseRoutineLoadStmt (#51832)
add 9a741c6b168 [fix](tvf) support compressed json file for tvf and
refactor code (#51983)
add 4708d9cad6b [fix](mtmv) fix when compatible fail, will throw NPE
(#49875)
add 15c16ad3041 [test](inverted index) add ut tests for inverted index fs
directory (#52115)
add 81ac747fd77 [fix](nereids) fix calc repeat property stack overflow
(#52159)
add 112fde51870 [Enhancement](s3) Support reading directory bucket (#52120)
add 25496122781 [ci](perf) adjust restart doris wait time to 5m (#52181)
add 7b4d330af5c [feature](inverted index) add custom analyzer (#50143)
add 4ec1282e629 [Chore] (nereids) remove CancelStmt (#51848)
add f430a4c785f [Fix](timezone) Fix incorrect DST handling (#51454)
add ced69c501f5 [Fix](FE) Fix wrong time literal cast to other date types
(#52160)
add 4f955c6e5ad [fix](be) Fix be aws-sdk-cpp memory leak (#52185)
add f24c94bf505 [refactor](nereids) Support Origin to provide error
location (#52125)
add e9937a75721 [fix](iceberg)Ensure proper authentication context before
accessing Iceberg Catalog (#52149)
add 6b7cb443f17 Merge branch 'master' into hello-stephen-patch-5
No new revisions were added by this update.
Summary of changes:
.clang-format-ignore | 1 +
.github/workflows/auto-cherry-pick.yml | 2 +-
be/src/agent/agent_server.cpp | 13 +
be/src/agent/heartbeat_server.cpp | 31 +-
be/src/agent/task_worker_pool.cpp | 27 +
be/src/agent/task_worker_pool.h | 4 +
be/src/cloud/cloud_meta_mgr.cpp | 75 +-
be/src/cloud/pb_convert.cpp | 8 +-
be/src/common/config.cpp | 2 +
be/src/common/config.h | 2 +
.../schema_scanner/schema_processlist_scanner.cpp | 39 +-
.../exec/schema_scanner/schema_tablets_scanner.cpp | 2 +-
be/src/http/action/jeprofile_actions.cpp | 21 +-
be/src/http/action/jeprofile_actions.h | 7 +
be/src/http/utils.cpp | 8 +-
be/src/io/cache/block_file_cache_factory.cpp | 62 +-
be/src/olap/inverted_index_parser.cpp | 9 +
be/src/olap/inverted_index_parser.h | 7 +
be/src/olap/match_predicate.cpp | 151 --
be/src/olap/match_predicate.h | 90 -
be/src/olap/predicate_creator.h | 4 -
be/src/olap/push_handler.cpp | 1 -
be/src/olap/rowset/segment_v2/column_reader.cpp | 8 +-
.../rowset/segment_v2/hierarchical_data_reader.h | 8 +
.../inverted_index/abstract_analysis_factory.h | 15 +-
.../inverted_index/analysis_factory_mgr.cpp | 75 +
.../inverted_index/analysis_factory_mgr.h | 51 +
.../inverted_index/analyzer/analyzer.cpp | 148 +-
.../segment_v2/inverted_index/analyzer/analyzer.h | 19 +-
.../analyzer/basic/basic_tokenizer.cpp | 3 +-
.../inverted_index/analyzer/custom_analyzer.cpp | 108 ++
.../inverted_index/analyzer/custom_analyzer.h | 86 +
.../analyzer/custom_analyzer_config.cpp | 62 +
.../analyzer/custom_analyzer_config.h | 76 +
.../inverted_index/analyzer/ik/IKTokenizer.cpp | 9 +-
.../inverted_index/analyzer/ik/cfg/Configuration.h | 1 +
.../analyzer/ik/core/AnalyzeContext.cpp | 11 +-
.../analyzer/ik/core/AnalyzeContext.h | 15 +-
.../analyzer/ik/core/CN_QuantifierSegmenter.h | 1 -
.../analyzer/ik/core/CharacterUtil.cpp | 148 +-
.../analyzer/ik/core/CharacterUtil.h | 6 +-
.../analyzer/ik/core/IKSegmenter.cpp | 1 +
.../inverted_index/analyzer/ik/core/IKSegmenter.h | 1 +
.../analyzer/ik/core/LetterSegmenter.cpp | 52 +-
.../analyzer/ik/core/LetterSegmenter.h | 7 +-
.../analyzer/ik/core/SurrogatePairSegmenter.cpp | 31 +-
.../analyzer/ik/core/SurrogatePairSegmenter.h | 34 +-
.../inverted_index/query/conjunction_query.cpp | 50 +-
.../inverted_index/query/conjunction_query.h | 6 +-
.../inverted_index/query/disjunction_query.cpp | 24 +-
.../inverted_index/query/disjunction_query.h | 2 +-
.../inverted_index/query/phrase_edge_query.cpp | 20 +-
.../inverted_index/query/phrase_edge_query.h | 2 +-
.../inverted_index/query/phrase_prefix_query.cpp | 41 +-
.../inverted_index/query/phrase_query.cpp | 152 +-
.../segment_v2/inverted_index/query/phrase_query.h | 9 +-
.../phrase_query/ordered_sloppy_phrase_matcher.cpp | 15 +-
.../inverted_index/query/prefix_query.cpp | 30 +-
.../segment_v2/inverted_index/query/prefix_query.h | 5 +-
.../rowset/segment_v2/inverted_index/query/query.h | 19 +-
.../segment_v2/inverted_index/query/query_info.h | 58 +
.../inverted_index/query/regexp_query.cpp | 8 +-
.../inverted_index/query_v2/term_query.cpp | 7 +-
.../inverted_index/query_v2/term_query.h | 10 +-
.../rowset/segment_v2/inverted_index/setting.h | 136 ++
.../token_filter/ascii_folding_filter.cpp | 2020 ++++++++++++++++++++
.../ascii_folding_filter.h} | 35 +-
.../token_filter/ascii_folding_filter_factory.h} | 33 +-
.../token_filter/lower_case_filter.h | 84 +
.../token_filter/lower_case_filter_factory.h | 39 +-
.../inverted_index/token_filter/token_filter.h | 48 +-
.../token_filter/token_filter_factory.h | 29 +-
.../token_filter/word_delimiter_filter.cpp | 249 +++
.../token_filter/word_delimiter_filter.h | 143 ++
.../token_filter/word_delimiter_filter_factory.h | 201 ++
.../token_filter/word_delimiter_iterator.cpp | 279 +++
.../token_filter/word_delimiter_iterator.h | 88 +
.../segment_v2/inverted_index/token_stream.h | 60 +
.../tokenizer/keyword/keyword_tokenizer.h | 73 +
.../keyword/keyword_tokenizer_factory.h} | 33 +-
.../inverted_index/tokenizer/ngram/char_matcher.h | 110 ++
.../tokenizer/ngram/edge_ngram_tokenizer.h | 47 +-
.../tokenizer/ngram/edge_ngram_tokenizer_factory.h | 65 +
.../tokenizer/ngram/ngram_tokenizer.cpp | 148 ++
.../tokenizer/ngram/ngram_tokenizer.h | 78 +
.../tokenizer/ngram/ngram_tokenizer_factory.cpp | 83 +
.../tokenizer/ngram/ngram_tokenizer_factory.h | 64 +
.../tokenizer/standard/standard_tokenizer.h | 81 +
.../standard/standard_tokenizer_factory.h} | 31 +-
.../tokenizer/standard/standard_tokenizer_impl.cpp | 1982 +++++++++++++++++++
.../tokenizer/standard/standard_tokenizer_impl.h | 299 +++
.../inverted_index/tokenizer/tokenizer.h | 52 +
.../inverted_index/tokenizer/tokenizer_factory.h | 18 +-
.../inverted_index/util/docid_set_iterator.h | 2 +-
.../inverted_index/util/priority_queue.h | 2 +-
.../segment_v2/inverted_index/util/term_iterator.h | 41 +-
.../inverted_index/util/term_position_iterator.h | 43 +-
.../inverted_index/util/union_term_iterator.h | 30 +-
.../segment_v2/inverted_index_file_writer.cpp | 4 +
.../segment_v2/inverted_index_fs_directory.cpp | 4 +-
.../rowset/segment_v2/inverted_index_reader.cpp | 19 +-
.../rowset/segment_v2/inverted_index_writer.cpp | 37 +-
be/src/olap/rowset/segment_v2/segment_iterator.cpp | 1 -
be/src/pipeline/pipeline_fragment_context.cpp | 38 +-
be/src/pipeline/task_queue.cpp | 5 +-
be/src/runtime/exec_env.h | 8 +
be/src/runtime/exec_env_init.cpp | 8 +
be/src/runtime/fragment_mgr.cpp | 9 +
be/src/runtime/fragment_mgr.h | 2 +
be/src/runtime/group_commit_mgr.cpp | 3 +
be/src/runtime/index_policy/index_policy_mgr.cpp | 173 ++
be/src/runtime/index_policy/index_policy_mgr.h | 52 +
be/src/runtime/load_stream.cpp | 2 +-
be/src/runtime/memory/heap_profiler.cpp | 27 +-
be/src/runtime/memory/heap_profiler.h | 4 +-
be/src/runtime/runtime_query_statistics_mgr.cpp | 13 +
be/src/runtime/runtime_query_statistics_mgr.h | 3 +-
be/src/service/backend_service.cpp | 25 +-
be/src/service/http_service.cpp | 5 +
be/src/service/internal_service.cpp | 7 +-
be/src/util/countdown_latch.h | 7 +
be/src/util/doris_metrics.cpp | 3 +
be/src/util/doris_metrics.h | 1 +
be/src/util/jsonb_document.h | 995 +++++-----
be/src/util/jsonb_parser_simd.h | 16 +-
be/src/util/jsonb_utils.cpp | 42 +
be/src/util/jsonb_utils.h | 127 +-
be/src/util/jsonb_writer.h | 198 +-
be/src/util/uid_util.cpp | 4 +
be/src/util/uid_util.h | 1 +
.../aggregate_function_bitmap.h | 4 +
.../aggregate_function_corr.cpp | 35 +-
.../aggregate_function_min_max.cpp | 86 +-
.../aggregate_function_min_max_by.h | 36 +-
be/src/vec/aggregate_functions/helpers.h | 38 +
be/src/vec/columns/column.h | 2 +-
be/src/vec/columns/column_array.cpp | 2 +-
be/src/vec/columns/column_array.h | 6 +-
be/src/vec/columns/column_complex.h | 5 +-
be/src/vec/columns/column_const.cpp | 2 +-
be/src/vec/columns/column_const.h | 2 +-
be/src/vec/columns/column_decimal.cpp | 2 +-
be/src/vec/columns/column_decimal.h | 2 +-
be/src/vec/columns/column_dictionary.h | 3 +-
be/src/vec/columns/column_dummy.h | 2 +-
be/src/vec/columns/column_fixed_length_object.h | 2 +-
be/src/vec/columns/column_map.cpp | 2 +-
be/src/vec/columns/column_map.h | 5 +-
be/src/vec/columns/column_nothing.h | 2 +-
be/src/vec/columns/column_nullable.cpp | 8 +-
be/src/vec/columns/column_nullable.h | 4 +-
be/src/vec/columns/column_string.cpp | 2 +-
be/src/vec/columns/column_string.h | 2 +-
be/src/vec/columns/column_struct.cpp | 6 +-
be/src/vec/columns/column_struct.h | 8 +-
be/src/vec/columns/column_variant.cpp | 17 +-
be/src/vec/columns/column_variant.h | 3 +-
be/src/vec/columns/column_vector.cpp | 2 +-
be/src/vec/columns/column_vector.h | 2 +-
be/src/vec/columns/predicate_column.h | 3 +-
be/src/vec/common/arithmetic_overflow.h | 42 +-
be/src/vec/common/schema_util.h | 3 +-
be/src/vec/common/sort/heap_sorter.cpp | 2 +-
be/src/vec/common/sort/heap_sorter.h | 1 +
be/src/vec/core/field.h | 3 +-
be/src/vec/core/sort_cursor.h | 65 +-
be/src/vec/data_types/data_type_jsonb.cpp | 21 +
be/src/vec/data_types/data_type_jsonb.h | 22 +-
be/src/vec/data_types/data_type_variant.cpp | 10 +-
.../vec/data_types/serde/data_type_array_serde.cpp | 3 +-
.../vec/data_types/serde/data_type_array_serde.h | 4 +-
.../data_types/serde/data_type_bitmap_serde.cpp | 3 +-
.../vec/data_types/serde/data_type_bitmap_serde.h | 3 +-
.../vec/data_types/serde/data_type_date64_serde.h | 12 +-
.../data_types/serde/data_type_datetimev2_serde.h | 3 -
.../vec/data_types/serde/data_type_datev2_serde.h | 3 -
.../data_types/serde/data_type_decimal_serde.cpp | 57 +-
.../vec/data_types/serde/data_type_decimal_serde.h | 60 -
.../vec/data_types/serde/data_type_hll_serde.cpp | 3 +-
be/src/vec/data_types/serde/data_type_hll_serde.h | 3 +-
be/src/vec/data_types/serde/data_type_ipv4_serde.h | 2 -
.../vec/data_types/serde/data_type_ipv6_serde.cpp | 3 +-
be/src/vec/data_types/serde/data_type_ipv6_serde.h | 3 -
.../vec/data_types/serde/data_type_jsonb_serde.cpp | 24 +-
.../vec/data_types/serde/data_type_jsonb_serde.h | 1 -
.../vec/data_types/serde/data_type_map_serde.cpp | 3 +-
be/src/vec/data_types/serde/data_type_map_serde.h | 2 -
.../vec/data_types/serde/data_type_nothing_serde.h | 2 +-
.../data_types/serde/data_type_nullable_serde.cpp | 1 +
.../data_types/serde/data_type_nullable_serde.h | 2 -
.../data_types/serde/data_type_number_serde.cpp | 126 +-
.../vec/data_types/serde/data_type_number_serde.h | 126 --
.../data_types/serde/data_type_object_serde.cpp | 7 +-
.../vec/data_types/serde/data_type_object_serde.h | 2 -
.../serde/data_type_quantilestate_serde.cpp | 46 +
.../serde/data_type_quantilestate_serde.h | 22 +-
be/src/vec/data_types/serde/data_type_serde.cpp | 4 +-
be/src/vec/data_types/serde/data_type_serde.h | 10 +-
.../data_types/serde/data_type_string_serde.cpp | 365 ++++
.../vec/data_types/serde/data_type_string_serde.h | 279 +--
.../data_types/serde/data_type_struct_serde.cpp | 3 +-
.../vec/data_types/serde/data_type_struct_serde.h | 3 +-
.../exec/format/arrow/arrow_pip_input_stream.cpp | 2 +-
.../vec/exec/format/arrow/arrow_pip_input_stream.h | 3 +-
be/src/vec/exec/format/avro/avro_jni_reader.cpp | 5 +-
be/src/vec/exec/format/avro/avro_jni_reader.h | 4 +-
be/src/vec/exec/format/csv/csv_reader.cpp | 77 +-
be/src/vec/exec/format/csv/csv_reader.h | 7 +-
be/src/vec/exec/format/generic_reader.h | 5 +
be/src/vec/exec/format/json/new_json_reader.cpp | 13 +-
be/src/vec/exec/format/json/new_json_reader.h | 1 +
be/src/vec/exec/format/orc/vorc_reader.cpp | 7 +-
be/src/vec/exec/format/orc/vorc_reader.h | 2 +
be/src/vec/exec/format/parquet/vparquet_reader.cpp | 22 +-
be/src/vec/exec/format/parquet/vparquet_reader.h | 4 +-
be/src/vec/exec/format/table/iceberg_reader.cpp | 6 +-
be/src/vec/exec/format/wal/wal_reader.h | 2 +
be/src/vec/exec/scan/file_scanner.cpp | 14 +-
be/src/vec/exec/scan/file_scanner.h | 1 -
.../exprs/table_function/vexplode_json_array.cpp | 334 +++-
.../vec/exprs/table_function/vexplode_json_array.h | 343 +---
.../exprs/table_function/vexplode_json_object.cpp | 11 +-
be/src/vec/exprs/vmatch_predicate.cpp | 1 +
be/src/vec/exprs/vmatch_predicate.h | 2 +-
.../vec/functions/array/function_array_element.h | 3 +-
.../vec/functions/array/function_array_split.cpp | 5 +-
be/src/vec/functions/array/function_array_zip.cpp | 4 +-
be/src/vec/functions/function_case.h | 1 +
be/src/vec/functions/function_cast.h | 31 +-
.../function_date_or_datetime_computation.cpp | 29 +-
.../function_date_or_datetime_computation.h | 263 ++-
.../function_date_or_datetime_computation_v2.cpp | 72 +-
be/src/vec/functions/function_json.cpp | 3 +-
be/src/vec/functions/function_jsonb.cpp | 71 +-
be/src/vec/functions/function_tokenize.cpp | 97 +-
be/src/vec/functions/function_tokenize.h | 5 +-
be/src/vec/functions/match.cpp | 104 +-
be/src/vec/functions/match.h | 21 +-
be/src/vec/json/json_parser.h | 8 +
be/src/vec/json/path_in_data.h | 19 -
be/src/vec/jsonb/serialize.cpp | 3 +-
be/src/vec/olap/olap_data_convertor.cpp | 17 +-
be/src/vec/runtime/vdatetime_value.cpp | 57 +-
be/src/vec/runtime/vdatetime_value.h | 20 +-
.../sink/writer/iceberg/partition_transformers.h | 9 +-
be/test/exprs/bloom_filter_func_test.cpp | 9 +-
be/test/exprs/hybrid_set_test.cpp | 112 +-
be/test/io/cache/block_file_cache_test.cpp | 77 +
be/test/olap/inverted_index_parser_test.cpp | 320 ++++
.../inverted_index/analyzer/ik_anayzer_test.cpp | 148 +-
.../ananlyzer/custom_analyzer_test.cpp | 357 ++++
.../compaction/index_compaction_test.cpp | 132 ++
.../compaction/util/index_compaction_utils.cpp | 4 +-
.../query/phrase_edge_query_test.cpp | 432 +++++
.../query/phrase_prefix_query_test.cpp | 485 +++++
.../ordered_sloppy_phrase_matcher_test.cpp | 2 +-
.../inverted_index/query/phrase_query_test.cpp | 552 +++++-
.../segment_v2/inverted_index/setting_test.cpp | 184 ++
.../ascii_folding_filter_factory_test.cpp | 215 +++
.../lower_case_filter_factory_test.cpp | 109 ++
.../word_delimiter_filter_factory_test.cpp | 147 ++
.../token_filter/word_delimiter_filter_test.cpp | 331 ++++
.../token_filter/word_delimiter_iterator_test.cpp | 267 +++
.../tokenizer/edge_ngram_tokenizer_test.cpp | 241 +++
.../tokenizer/keyword_analyzer_test.cpp | 147 ++
.../tokenizer/ngram_tokenizer_test.cpp | 205 ++
.../tokenizer/standard_tokenizer_factory_test.cpp | 149 ++
.../util/union_term_iterator_test.cpp | 39 +-
.../inverted_index_compound_reader_test.cpp | 581 +++++-
.../segment_v2/inverted_index_file_reader_test.cpp | 442 +++++
.../segment_v2/inverted_index_file_writer_test.cpp | 571 ++++++
.../inverted_index_fs_directory_test.cpp | 781 ++++++++
.../segment_v2/inverted_index_writer_test.cpp | 561 ++++++
.../operator/streaming_agg_operator_test.cpp | 91 +
.../runtime/index_policy/index_policy_mgr_test.cpp | 179 ++
be/test/util/jsonb_serialize_test.cpp | 167 ++
.../util/test_data/jsonb_serialize_test_data.bin | Bin 0 -> 320 bytes
.../util/test_data/jsonb_serialize_test_data2.bin | Bin 0 -> 160 bytes
be/test/vec/columns/column_object_test.cpp | 19 +-
.../vec/core/column_with_type_and_name_test.cpp | 2 +-
.../vec/data_types/common_data_type_serder_test.h | 6 +-
.../vec/data_types/data_type_agg_state_test.cpp | 1 +
be/test/vec/data_types/data_type_jsonb_test.cpp | 1 +
.../serde/data_type_jsonb_serde_test.cpp | 7 +-
.../serde/data_type_serde_agg_state_test.cpp | 9 +-
.../serde/data_type_serde_bitmap_test.cpp | 4 +-
.../serde/data_type_serde_datetime_v1_test.cpp | 7 +-
.../serde/data_type_serde_datetime_v2_test.cpp | 7 +-
.../serde/data_type_serde_decimal_test.cpp | 7 +-
.../data_type_serde_fixed_length_object_test.cpp | 7 +-
.../data_types/serde/data_type_serde_hll_test.cpp | 4 +-
.../serde/data_type_serde_number_test.cpp | 7 +-
.../serde/data_type_serde_quantile_state_test.cpp | 5 +-
.../serde/data_type_serde_string_test.cpp | 7 +-
.../vec/data_types/serde/data_type_serde_test.cpp | 10 +-
.../dictionary/dictionary_get_nullable_test.cpp | 6 +-
.../vec/exec/format/parquet/parquet_read_lines.cpp | 1 -
.../exec/format/parquet/parquet_reader_test.cpp | 4 -
be/test/vec/function/cast/cast_to_date_test.cpp | 8 +-
.../vec/function/cast/cast_to_datetime_test.cpp | 3 +-
be/test/vec/function/function_match_test.cpp | 10 +-
...lti_match.cpp => function_multi_match_test.cpp} | 0
be/test/vec/function/function_test_util.h | 11 +-
be/test/vec/function/function_time_test.cpp | 12 -
be/test/vec/jsonb/jsonb_document_test.cpp | 205 ++
be/test/vec/olap/jsonb_value_test.cpp | 6 +-
cloud/src/common/config.h | 8 +
cloud/src/common/defer.h | 90 +
cloud/src/common/network_util.cpp | 5 +-
cloud/src/common/util.cpp | 12 +-
cloud/src/common/util.h | 12 +-
cloud/src/meta-service/http_encode_key.cpp | 6 +-
cloud/src/meta-service/meta_service.cpp | 21 +-
cloud/src/meta-service/meta_service.h | 52 +-
cloud/src/meta-service/meta_service_helper.h | 39 +-
cloud/src/meta-service/meta_service_job.cpp | 68 +-
cloud/src/meta-service/meta_service_resource.cpp | 50 +-
cloud/src/meta-service/meta_service_schema.cpp | 10 +-
cloud/src/meta-service/meta_service_txn.cpp | 25 +-
cloud/src/meta-service/txn_kv.cpp | 10 +-
cloud/src/recycler/checker.cpp | 12 +-
cloud/src/recycler/hdfs_accessor.cpp | 5 +-
cloud/src/recycler/meta_checker.cpp | 2 +-
cloud/src/recycler/recycler.cpp | 97 +-
cloud/src/recycler/recycler_service.cpp | 34 +-
cloud/src/recycler/sync_executor.h | 10 +-
cloud/src/recycler/util.h | 11 +-
cloud/src/resource-manager/resource_manager.cpp | 30 +-
cloud/test/encryption_test.cpp | 26 +-
cloud/test/http_encode_key_test.cpp | 6 +-
cloud/test/meta_server_test.cpp | 5 +-
cloud/test/meta_service_http_test.cpp | 16 +-
cloud/test/meta_service_job_test.cpp | 109 +-
cloud/test/meta_service_test.cpp | 95 +-
cloud/test/recycler_test.cpp | 118 +-
cloud/test/schema_kv_test.cpp | 29 +-
cloud/test/txn_kv_test.cpp | 25 +-
docker/runtime/fe/resource/fe_entrypoint.sh | 20 +-
.../json_format_test/simple_object_json.json.gz | Bin 0 -> 211 bytes
.../create_preinstalled_scripts/iceberg/run14.sql | 87 +
.../main/java/org/apache/doris/common/Config.java | 7 +-
.../java/org/apache/doris/common/ConfigBase.java | 16 +
.../org/apache/doris/common/FeMetaVersion.java | 2 +-
.../java/org/apache/doris/common/io/DeepCopy.java | 28 -
.../doris/common/property/PropertiesSet.java | 39 -
.../doris/common/property/PropertySchema.java | 68 -
.../doris/common/property/PropertiesSetTest.java | 21 -
.../doris/common/property/PropertySchemaTest.java | 70 +-
.../antlr4/org/apache/doris/nereids/DorisLexer.g4 | 3 +
.../antlr4/org/apache/doris/nereids/DorisParser.g4 | 14 +-
fe/fe-core/src/main/cup/sql_parser.cup | 409 +---
.../main/java/org/apache/doris/alter/Alter.java | 10 +-
.../java/org/apache/doris/alter/AlterHandler.java | 6 -
.../doris/alter/BatchAlterJobPersistInfo.java | 16 +-
.../org/apache/doris/alter/IndexChangeJob.java | 36 +-
.../doris/alter/MaterializedViewHandler.java | 59 -
.../apache/doris/alter/SchemaChangeHandler.java | 115 --
.../java/org/apache/doris/alter/SystemHandler.java | 53 -
.../analysis/AdminCancelRebalanceDiskStmt.java | 76 -
.../doris/analysis/AdminCheckTabletsStmt.java | 95 -
.../apache/doris/analysis/AdminCleanTrashStmt.java | 77 -
.../doris/analysis/AdminCompactTableStmt.java | 145 --
.../apache/doris/analysis/AdminCopyTabletStmt.java | 124 --
.../doris/analysis/AdminRebalanceDiskStmt.java | 89 -
.../doris/analysis/AdminRepairTableStmt.java | 82 -
.../doris/analysis/AdminSetReplicaStatusStmt.java | 113 --
.../doris/analysis/AdminSetReplicaVersionStmt.java | 151 --
.../doris/analysis/AdminSetTableStatusStmt.java | 91 -
.../org/apache/doris/analysis/AlterSystemStmt.java | 77 -
.../org/apache/doris/analysis/AnalyticExpr.java | 36 +
.../org/apache/doris/analysis/AnalyticWindow.java | 34 +
.../org/apache/doris/analysis/ArithmeticExpr.java | 31 +-
.../org/apache/doris/analysis/ArrayLiteral.java | 29 +-
.../apache/doris/analysis/BetweenPredicate.java | 11 +
.../org/apache/doris/analysis/BinaryPredicate.java | 36 +-
.../doris/analysis/BitmapFilterPredicate.java | 10 +
.../org/apache/doris/analysis/BoolLiteral.java | 21 +-
.../java/org/apache/doris/analysis/BrokerDesc.java | 32 +-
.../doris/analysis/CancelAlterSystemStmt.java | 98 -
.../doris/analysis/CancelAlterTableStmt.java | 116 --
.../apache/doris/analysis/CancelBackupStmt.java | 90 -
.../doris/analysis/CancelCloudWarmUpStmt.java | 89 -
.../java/org/apache/doris/analysis/CaseExpr.java | 25 +
.../java/org/apache/doris/analysis/CastExpr.java | 39 +-
.../apache/doris/analysis/ChannelDescription.java | 20 +-
.../apache/doris/analysis/CleanQueryStatsStmt.java | 149 --
.../org/apache/doris/analysis/ClusterName.java | 6 -
.../org/apache/doris/analysis/ColumnRefExpr.java | 8 +
.../apache/doris/analysis/CompoundPredicate.java | 14 +
...wPolicyStmt.java => CreateIndexPolicyStmt.java} | 76 +-
.../doris/analysis/CreateMaterializedViewStmt.java | 13 +-
.../org/apache/doris/analysis/CreateTableStmt.java | 6 -
.../org/apache/doris/analysis/DataSortInfo.java | 19 +-
.../org/apache/doris/analysis/DateLiteral.java | 36 +-
.../org/apache/doris/analysis/DecimalLiteral.java | 34 +-
.../apache/doris/analysis/DefaultValueExpr.java | 8 +
.../apache/doris/analysis/DefaultValueExprDef.java | 18 +-
...pairTableStmt.java => DropIndexPolicyStmt.java} | 61 +-
.../org/apache/doris/analysis/DropPolicyStmt.java | 113 --
.../org/apache/doris/analysis/EncryptKeyName.java | 19 +-
.../org/apache/doris/analysis/EncryptKeyRef.java | 10 +
.../org/apache/doris/analysis/ExistsPredicate.java | 15 +
.../main/java/org/apache/doris/analysis/Expr.java | 100 +-
.../org/apache/doris/analysis/FloatLiteral.java | 21 +-
.../apache/doris/analysis/FunctionCallExpr.java | 152 +-
.../org/apache/doris/analysis/FunctionName.java | 16 -
.../org/apache/doris/analysis/FunctionParams.java | 40 +-
.../org/apache/doris/analysis/IPv4Literal.java | 8 +
.../org/apache/doris/analysis/IPv6Literal.java | 8 +
.../apache/doris/analysis/ImportColumnDesc.java | 2 +-
.../org/apache/doris/analysis/InPredicate.java | 17 +
.../apache/doris/analysis/InformationFunction.java | 8 +
.../java/org/apache/doris/analysis/IntLiteral.java | 21 +-
.../apache/doris/analysis/InvertedIndexUtil.java | 25 +-
.../org/apache/doris/analysis/IsNullPredicate.java | 9 +
.../org/apache/doris/analysis/JsonLiteral.java | 22 +-
.../java/org/apache/doris/analysis/KeysDesc.java | 48 +-
.../java/org/apache/doris/analysis/KillStmt.java | 84 -
.../java/org/apache/doris/analysis/LabelName.java | 19 +-
.../doris/analysis/LambdaFunctionCallExpr.java | 47 +
.../apache/doris/analysis/LambdaFunctionExpr.java | 22 +
.../org/apache/doris/analysis/LargeIntLiteral.java | 22 +-
.../org/apache/doris/analysis/LikePredicate.java | 9 +
.../org/apache/doris/analysis/LiteralExpr.java | 5 -
.../org/apache/doris/analysis/MVColumnItem.java | 2 +-
.../java/org/apache/doris/analysis/MapLiteral.java | 32 +-
.../org/apache/doris/analysis/MatchPredicate.java | 14 +
.../java/org/apache/doris/analysis/MaxLiteral.java | 18 +-
.../org/apache/doris/analysis/NullLiteral.java | 20 +-
.../org/apache/doris/analysis/OrderByElement.java | 25 +
.../org/apache/doris/analysis/PartitionNames.java | 19 +-
.../org/apache/doris/analysis/PasswordOptions.java | 19 +-
.../doris/analysis/PauseRoutineLoadStmt.java | 71 -
.../org/apache/doris/analysis/PlaceHolderExpr.java | 17 +-
.../org/apache/doris/analysis/ResourcePattern.java | 18 +-
.../doris/analysis/ResumeRoutineLoadStmt.java | 71 -
.../java/org/apache/doris/analysis/SelectStmt.java | 2 +-
.../org/apache/doris/analysis/ShowAuthorStmt.java | 51 -
.../org/apache/doris/analysis/ShowConfigStmt.java | 114 --
.../doris/analysis/ShowCreateRoutineLoadStmt.java | 65 -
...pResourceStmt.java => ShowIndexPolicyStmt.java} | 40 +-
.../org/apache/doris/analysis/ShowIndexStmt.java | 104 -
.../doris/analysis/ShowLoadWarningsStmt.java | 226 ---
.../doris/analysis/ShowQueuedAnalyzeJobsStmt.java | 210 --
.../doris/analysis/ShowReplicaStatusStmt.java | 165 --
.../org/apache/doris/analysis/ShowRollupStmt.java | 96 -
.../apache/doris/analysis/ShowRoutineLoadStmt.java | 156 --
.../doris/analysis/ShowRoutineLoadTaskStmt.java | 151 --
.../apache/doris/analysis/ShowStreamLoadStmt.java | 324 ----
.../apache/doris/analysis/ShowTableStatsStmt.java | 351 ----
.../apache/doris/analysis/ShowTransactionStmt.java | 184 --
.../apache/doris/analysis/ShowTrashDiskStmt.java | 76 -
.../doris/analysis/ShowUserPropertyStmt.java | 177 --
.../apache/doris/analysis/ShowVariablesStmt.java | 138 --
.../doris/analysis/ShowWorkloadGroupsStmt.java | 82 -
.../java/org/apache/doris/analysis/SlotRef.java | 62 +-
.../org/apache/doris/analysis/StringLiteral.java | 22 +-
.../org/apache/doris/analysis/StructLiteral.java | 28 +-
.../java/org/apache/doris/analysis/Subquery.java | 8 +
.../java/org/apache/doris/analysis/TableName.java | 28 +-
.../org/apache/doris/analysis/TablePattern.java | 17 -
.../java/org/apache/doris/analysis/TableRef.java | 37 +-
.../org/apache/doris/analysis/TimeV2Literal.java | 7 +
.../doris/analysis/TimestampArithmeticExpr.java | 41 +
.../doris/analysis/TransactionBeginStmt.java | 48 -
.../doris/analysis/TupleIsNullPredicate.java | 8 +
.../org/apache/doris/analysis/UserIdentity.java | 25 +-
.../org/apache/doris/analysis/VariableExpr.java | 18 +
.../org/apache/doris/analysis/VirtualSlotRef.java | 20 -
.../apache/doris/analysis/WarmUpClusterStmt.java | 164 --
.../doris/analysis/WorkloadGroupPattern.java | 20 +-
.../java/org/apache/doris/backup/AbstractJob.java | 58 +-
.../org/apache/doris/backup/BackupHandler.java | 27 -
.../java/org/apache/doris/backup/BackupJob.java | 85 +-
.../org/apache/doris/backup/BackupJobInfo.java | 33 +-
.../java/org/apache/doris/backup/BackupMeta.java | 27 +-
.../java/org/apache/doris/backup/Repository.java | 19 +-
.../org/apache/doris/backup/RepositoryMgr.java | 20 +-
.../apache/doris/backup/RestoreFileMapping.java | 56 +-
.../java/org/apache/doris/backup/RestoreJob.java | 124 +-
.../java/org/apache/doris/backup/SnapshotInfo.java | 30 -
.../apache/doris/blockrule/SqlBlockRuleMgr.java | 4 +-
.../apache/doris/catalog/AggregateFunction.java | 24 -
.../org/apache/doris/catalog/AliasFunction.java | 17 +-
.../apache/doris/catalog/AuthorizationInfo.java | 15 -
.../doris/catalog/AutoIncrementGenerator.java | 19 +-
.../org/apache/doris/catalog/BinlogConfig.java | 16 +-
.../java/org/apache/doris/catalog/BrokerMgr.java | 19 +-
.../java/org/apache/doris/catalog/BrokerTable.java | 24 -
.../apache/doris/catalog/CatalogRecycleBin.java | 130 +-
.../apache/doris/catalog/ColocateGroupSchema.java | 8 +-
.../apache/doris/catalog/ColocateTableIndex.java | 54 +-
.../main/java/org/apache/doris/catalog/Column.java | 9 -
.../java/org/apache/doris/catalog/ColumnType.java | 40 +-
.../org/apache/doris/catalog/DataProperty.java | 30 +-
.../java/org/apache/doris/catalog/Database.java | 73 +-
.../apache/doris/catalog/DatabaseEncryptKey.java | 18 +-
.../org/apache/doris/catalog/DatabaseProperty.java | 18 +-
.../java/org/apache/doris/catalog/DiskInfo.java | 20 +-
.../org/apache/doris/catalog/DistributionInfo.java | 8 -
.../main/java/org/apache/doris/catalog/Env.java | 136 +-
.../java/org/apache/doris/catalog/EsTable.java | 51 -
.../java/org/apache/doris/catalog/FsBroker.java | 6 -
.../java/org/apache/doris/catalog/Function.java | 98 +-
.../apache/doris/catalog/FunctionSearchDesc.java | 21 +-
.../org/apache/doris/catalog/FunctionUtil.java | 23 -
.../apache/doris/catalog/GlobalFunctionMgr.java | 17 +-
.../apache/doris/catalog/HashDistributionInfo.java | 20 -
.../java/org/apache/doris/catalog/HiveTable.java | 17 -
.../main/java/org/apache/doris/catalog/Index.java | 4 +
.../org/apache/doris/catalog/InternalSchema.java | 142 +-
.../doris/catalog/InternalSchemaInitializer.java | 107 +-
.../java/org/apache/doris/catalog/JdbcTable.java | 38 -
.../apache/doris/catalog/ListPartitionInfo.java | 43 -
.../apache/doris/catalog/ListPartitionItem.java | 13 -
.../main/java/org/apache/doris/catalog/MTMV.java | 52 +-
.../apache/doris/catalog/MaterializedIndex.java | 36 -
.../doris/catalog/MaterializedIndexMeta.java | 19 +-
.../java/org/apache/doris/catalog/MetaObject.java | 7 -
.../org/apache/doris/catalog/MetadataViewer.java | 6 -
.../doris/catalog/MysqlCompatibleDatabase.java | 9 -
.../java/org/apache/doris/catalog/MysqlTable.java | 27 -
.../java/org/apache/doris/catalog/OdbcTable.java | 30 -
.../java/org/apache/doris/catalog/OlapTable.java | 130 +-
.../java/org/apache/doris/catalog/Partition.java | 49 -
.../org/apache/doris/catalog/PartitionInfo.java | 48 -
.../org/apache/doris/catalog/PartitionKey.java | 229 +--
.../doris/catalog/RandomDistributionInfo.java | 15 -
.../apache/doris/catalog/RangePartitionInfo.java | 43 -
.../java/org/apache/doris/catalog/Replica.java | 25 -
.../java/org/apache/doris/catalog/ResourceMgr.java | 27 -
.../org/apache/doris/catalog/ScalarFunction.java | 14 -
.../java/org/apache/doris/catalog/SchemaTable.java | 37 +-
.../apache/doris/catalog/SinglePartitionInfo.java | 18 -
.../main/java/org/apache/doris/catalog/Table.java | 70 +-
.../org/apache/doris/catalog/TableAttributes.java | 14 -
.../org/apache/doris/catalog/TableIndexes.java | 19 +-
.../org/apache/doris/catalog/TableProperty.java | 31 +-
.../main/java/org/apache/doris/catalog/Tablet.java | 36 -
.../org/apache/doris/catalog/TempPartitions.java | 10 -
.../main/java/org/apache/doris/catalog/View.java | 15 -
.../doris/catalog/constraint/Constraint.java | 23 +-
.../java/org/apache/doris/clone/TabletChecker.java | 18 -
.../org/apache/doris/clone/TabletScheduler.java | 10 -
.../apache/doris/cloud/CacheHotspotManager.java | 49 +-
.../doris/cloud/CacheHotspotManagerUtils.java | 8 +-
.../org/apache/doris/cloud/catalog/CloudEnv.java | 6 +-
.../apache/doris/cloud/catalog/CloudPartition.java | 10 -
.../apache/doris/cloud/catalog/CloudReplica.java | 32 -
.../java/org/apache/doris/cloud/load/CopyJob.java | 15 -
.../apache/doris/cloud/rpc/MetaServiceClient.java | 8 +-
.../java/org/apache/doris/common/FeNameFormat.java | 4 +
.../apache/doris/common/SchemaVersionAndHash.java | 21 +-
.../org/apache/doris/common/ThreadPoolManager.java | 10 +-
.../doris/common/proc/RoutineLoadProcNode.java | 4 +-
.../doris/common/proc/RoutineLoadsNameProcDir.java | 4 +-
.../org/apache/doris/common/profile/Counter.java | 14 -
.../doris/common/profile/ProfileManager.java | 68 +-
.../doris/common/profile/RuntimeProfile.java | 5 -
.../doris/common/profile/SummaryProfile.java | 113 ++
.../apache/doris/common/util/PropertyAnalyzer.java | 2 +-
.../java/org/apache/doris/common/util/S3URI.java | 68 +
.../org/apache/doris/common/util/SmallFileMgr.java | 29 +-
.../apache/doris/datasource/CatalogProperty.java | 18 +-
.../apache/doris/datasource/ExternalCatalog.java | 28 +-
.../apache/doris/datasource/ExternalDatabase.java | 17 +-
.../doris/datasource/hive/HMSExternalTable.java | 4 +-
.../datasource/iceberg/IcebergExternalCatalog.java | 24 +-
.../iceberg/IcebergExternalDatabase.java | 12 +-
.../datasource/iceberg/IcebergExternalTable.java | 108 +-
.../datasource/iceberg/IcebergMetadataCache.java | 41 +
.../datasource/iceberg/IcebergMetadataOps.java | 99 +-
.../doris/datasource/iceberg/IcebergUtils.java | 81 +-
.../iceberg/source/IcebergApiSource.java | 11 +
.../apache/doris/datasource/kafka/KafkaUtil.java | 10 +-
.../datasource/operations/ExternalMetadataOps.java | 33 +
.../storage/AbstractS3CompatibleProperties.java | 10 +-
.../datasource/property/storage/S3Properties.java | 11 +-
.../org/apache/doris/dictionary/Dictionary.java | 5 +-
.../org/apache/doris/fs/PersistentFileSystem.java | 31 -
.../java/org/apache/doris/fs/obj/S3ObjStorage.java | 17 +-
.../main/java/org/apache/doris/ha/MasterInfo.java | 14 -
.../doris/httpv2/controller/SessionController.java | 18 +-
.../doris/httpv2/rest/manager/HttpUtils.java | 6 +
.../doris/httpv2/rest/manager/NodeAction.java | 48 +
.../httpv2/rest/manager/QueryProfileAction.java | 133 +-
.../AsciiFoldingTokenFilterValidator.java | 48 +
.../doris/indexpolicy/BasePolicyValidator.java | 52 +
.../DropIndexPolicyLog.java} | 27 +-
.../indexpolicy/EdgeNGramTokenizerValidator.java | 106 +
.../org/apache/doris/indexpolicy/IndexPolicy.java | 120 ++
.../apache/doris/indexpolicy/IndexPolicyMgr.java | 430 +++++
.../IndexPolicyTypeEnum.java} | 31 +-
.../KeywordTokenizerValidator.java} | 31 +-
.../LowerCaseTokenFilterValidator.java} | 31 +-
.../doris/indexpolicy/NGramTokenizerValidator.java | 106 +
.../PolicyPropertyValidator.java} | 8 +-
.../indexpolicy/StandardTokenizerValidator.java | 53 +
.../WordDelimiterTokenFilterValidator.java | 120 ++
.../doris/job/extensions/insert/InsertTask.java | 1 +
.../org/apache/doris/journal/JournalEntity.java | 12 +
.../org/apache/doris/journal/bdbje/Timestamp.java | 15 +-
.../org/apache/doris/load/BrokerFileGroup.java | 136 +-
.../apache/doris/load/BrokerFileGroupAggInfo.java | 35 +-
.../java/org/apache/doris/load/ExportFailMsg.java | 6 -
.../apache/doris/load/ExportJobStateTransfer.java | 15 +-
.../java/org/apache/doris/load/LoadErrorHub.java | 75 +-
.../org/apache/doris/load/StreamLoadRecordMgr.java | 4 +-
.../org/apache/doris/load/loadv2/BulkLoadJob.java | 27 -
.../apache/doris/load/loadv2/IngestionLoadJob.java | 27 -
.../apache/doris/load/loadv2/InsertLoadJob.java | 8 -
.../java/org/apache/doris/load/loadv2/LoadJob.java | 89 +-
.../doris/load/loadv2/LoadJobFinalOperation.java | 29 -
.../load/loadv2/MiniLoadTxnCommitAttachment.java | 14 -
.../doris/load/loadv2/SparkLoadAppHandle.java | 21 +-
.../org/apache/doris/load/loadv2/SparkLoadJob.java | 19 -
.../doris/load/routineload/KafkaProgress.java | 12 -
.../load/routineload/KafkaRoutineLoadJob.java | 27 +-
.../routineload/RLTaskTxnCommitAttachment.java | 14 -
.../doris/load/routineload/RoutineLoadJob.java | 170 +-
.../doris/load/routineload/RoutineLoadManager.java | 79 -
.../load/routineload/RoutineLoadProgress.java | 32 -
.../load/routineload/RoutineLoadStatistic.java | 10 -
.../org/apache/doris/load/sync/SyncFailMsg.java | 20 +-
.../doris/load/sync/canal/CanalDestination.java | 21 +-
.../org/apache/doris/master/ReportHandler.java | 99 +-
.../java/org/apache/doris/mtmv/BaseTableInfo.java | 16 +-
.../org/apache/doris/mtmv/MTMVPartitionInfo.java | 2 +-
.../java/org/apache/doris/mtmv/MTMVPlanUtil.java | 1 +
.../doris/mtmv/MTMVRefreshPartitionSnapshot.java | 56 +-
.../org/apache/doris/mtmv/MTMVRefreshSnapshot.java | 2 +-
.../java/org/apache/doris/mtmv/MTMVRelation.java | 4 +-
.../org/apache/doris/mtmv/MTMVRelationManager.java | 43 +-
.../org/apache/doris/mtmv/MTMVRewriteUtil.java | 5 +-
.../java/org/apache/doris/mtmv/MTMVStatus.java | 6 +
.../java/org/apache/doris/mysql/MysqlServer.java | 1 +
.../org/apache/doris/mysql/privilege/Auth.java | 142 +-
.../doris/mysql/privilege/CatalogPrivEntry.java | 25 -
.../mysql/privilege/CommonUserProperties.java | 20 +-
.../apache/doris/mysql/privilege/DbPrivEntry.java | 17 -
.../doris/mysql/privilege/GlobalPrivEntry.java | 10 -
.../org/apache/doris/mysql/privilege/Password.java | 20 +-
.../doris/mysql/privilege/PasswordPolicy.java | 49 +-
.../apache/doris/mysql/privilege/PrivBitSet.java | 25 +-
.../apache/doris/mysql/privilege/PrivEntry.java | 54 -
.../apache/doris/mysql/privilege/PrivTable.java | 34 -
.../doris/mysql/privilege/ResourcePrivEntry.java | 16 -
.../org/apache/doris/mysql/privilege/Role.java | 54 +-
.../apache/doris/mysql/privilege/RoleManager.java | 20 +-
.../doris/mysql/privilege/TablePrivEntry.java | 17 -
.../org/apache/doris/mysql/privilege/User.java | 17 +-
.../doris/mysql/privilege/UserPrivTable.java | 69 -
.../apache/doris/mysql/privilege/UserProperty.java | 86 +-
.../doris/mysql/privilege/UserPropertyInfo.java | 21 +-
.../doris/mysql/privilege/UserPropertyMgr.java | 20 -
.../apache/doris/mysql/privilege/UserResource.java | 49 -
.../apache/doris/mysql/privilege/WhiteList.java | 51 -
.../mysql/privilege/WorkloadGroupPrivEntry.java | 16 -
.../org/apache/doris/nereids/NereidsPlanner.java | 5 +
.../org/apache/doris/nereids/StatementContext.java | 13 +-
.../doris/nereids/analyzer/UnboundRelation.java | 53 +-
.../apache/doris/nereids/analyzer/UnboundSlot.java | 2 +-
.../doris/nereids/load/NereidsBrokerFileGroup.java | 137 +-
.../doris/nereids/parser/LogicalPlanBuilder.java | 127 +-
.../org/apache/doris/nereids/parser/Origin.java | 9 +
.../apache/doris/nereids/parser/ParserUtils.java | 52 +-
.../properties/ChildOutputPropertyDeriver.java | 5 +-
.../doris/nereids/rules/analysis/BindRelation.java | 49 +-
.../doris/nereids/rules/analysis/BindSink.java | 10 +-
.../nereids/rules/analysis/CollectRelation.java | 14 +-
.../nereids/rules/analysis/ExpressionAnalyzer.java | 5 +
.../InitConsistentMaterializationContextHook.java | 8 +-
.../mv/InitMaterializationContextHook.java | 7 +-
.../exploration/mv/MaterializationContext.java | 29 +-
.../rules/expression/QueryColumnCollector.java | 2 +-
.../nereids/rules/expression/check/CheckCast.java | 2 +-
.../expression/rules/FoldConstantRuleOnBE.java | 2 +-
.../nereids/rules/rewrite/PullUpPredicates.java | 9 +-
.../mv/AbstractSelectMaterializedIndexRule.java | 9 +-
.../mv/SelectMaterializedIndexWithAggregate.java | 2 +-
.../doris/nereids/stats/StatsCalculator.java | 8 +-
.../doris/nereids/trees/AbstractTreeNode.java | 10 +
.../org/apache/doris/nereids/trees/TreeNode.java | 5 +
.../doris/nereids/trees/expressions/Cast.java | 2 +-
.../PropagateNullableOnDateOrTimeLikeV2Args.java | 3 +-
.../expressions/functions/scalar/DateDiff.java | 2 -
.../expressions/functions/scalar/DaysDiff.java | 2 -
.../expressions/functions/scalar/HoursDiff.java | 2 -
.../expressions/functions/scalar/MinutesDiff.java | 2 -
.../expressions/functions/scalar/MonthsDiff.java | 2 -
.../expressions/functions/scalar/SecondsDiff.java | 2 -
.../expressions/functions/scalar/TimeDiff.java | 2 -
.../expressions/functions/scalar/Tokenize.java | 4 +-
.../expressions/functions/scalar/WeeksDiff.java | 2 -
.../expressions/functions/scalar/YearsDiff.java | 2 -
.../trees/expressions/functions/udf/AliasUdf.java | 2 +-
.../nereids/trees/expressions/literal/Literal.java | 7 +-
.../trees/expressions/literal/TimeV2Literal.java | 21 +
.../apache/doris/nereids/trees/plans/PlanType.java | 11 +-
.../doris/nereids/trees/plans/algebra/Repeat.java | 4 +-
.../plans/commands/CancelWarmUpJobCommand.java | 4 +-
.../plans/commands/CleanQueryStatsCommand.java | 12 +-
.../plans/commands/CreateFunctionCommand.java | 2 +-
.../plans/commands/CreateIndexAnalyzerCommand.java | 75 +
.../commands/CreateIndexTokenFilterCommand.java | 75 +
.../commands/CreateIndexTokenizerCommand.java | 75 +
.../commands/CreateMaterializedViewCommand.java | 9 +-
.../trees/plans/commands/DeleteFromCommand.java | 2 +-
.../trees/plans/commands/DescribeCommand.java | 4 +-
.../plans/commands/DropIndexAnalyzerCommand.java} | 54 +-
.../commands/DropIndexTokenFilterCommand.java} | 54 +-
.../plans/commands/DropIndexTokenizerCommand.java} | 54 +-
.../trees/plans/commands/DropRowPolicyCommand.java | 20 +
.../nereids/trees/plans/commands/LoadCommand.java | 2 +-
.../plans/commands/ShowConstraintsCommand.java | 3 +-
.../plans/commands/ShowCreateTableCommand.java | 8 +
.../plans/commands/ShowIndexAnalyzerCommand.java} | 52 +-
.../commands/ShowIndexTokenFilterCommand.java} | 52 +-
.../plans/commands/ShowIndexTokenizerCommand.java} | 52 +-
.../trees/plans/commands/ShowLoadCommand.java | 17 +-
.../plans/commands/ShowProcessListCommand.java | 28 +-
.../plans/commands/ShowRoutineLoadCommand.java | 4 +
.../plans/commands/ShowRoutineLoadTaskCommand.java | 4 +
.../trees/plans/commands/UpdateCommand.java | 2 +-
.../plans/commands/UpdateMvByPartitionCommand.java | 2 +-
.../trees/plans/commands/info/AddColumnsOp.java | 9 +
.../trees/plans/commands/info/BulkStorageDesc.java | 25 +-
.../plans/commands/info/ColumnDefinition.java | 2 +-
.../plans/commands/info/CreateRoutineLoadInfo.java | 9 +
.../commands/info/DictionaryColumnDefinition.java | 19 +-
.../trees/plans/commands/info/TableNameInfo.java | 26 +-
.../commands/insert/InsertIntoTableCommand.java | 5 +-
.../trees/plans/commands/insert/InsertUtils.java | 8 +-
.../commands/load/CreateRoutineLoadCommand.java | 9 +
.../trees/plans/visitor/CommandVisitor.java | 54 +
.../org/apache/doris/nereids/types/DataType.java | 8 -
.../doris/nereids/util/MoreFieldsThread.java | 67 +
.../org/apache/doris/nereids/util/PlanUtils.java | 2 +-
.../apache/doris/nereids/util/RelationUtil.java | 19 +-
.../doris/nereids/util/TypeCoercionUtils.java | 10 +-
.../apache/doris/persist/AnalyzeDeletionLog.java | 8 +-
.../apache/doris/persist/BackendReplicasInfo.java | 18 +-
.../apache/doris/persist/CleanQueryStatsInfo.java | 2 +-
.../apache/doris/persist/ConsistencyCheckInfo.java | 22 -
.../org/apache/doris/persist/CreateTableInfo.java | 16 +-
.../org/apache/doris/persist/DatabaseInfo.java | 20 +-
.../java/org/apache/doris/persist/DropDbInfo.java | 5 -
.../java/org/apache/doris/persist/DropInfo.java | 23 +-
.../java/org/apache/doris/persist/EditLog.java | 30 +-
.../java/org/apache/doris/persist/HbPackage.java | 20 +-
.../apache/doris/persist/ModifyPartitionInfo.java | 34 +-
.../org/apache/doris/persist/OperationType.java | 4 +
.../apache/doris/persist/PartitionPersistInfo.java | 34 +-
.../java/org/apache/doris/persist/PrivInfo.java | 41 +-
.../java/org/apache/doris/persist/RecoverInfo.java | 17 +-
.../apache/doris/persist/ReplicaPersistInfo.java | 36 +-
.../apache/doris/persist/RoutineLoadOperation.java | 16 +-
.../java/org/apache/doris/persist/TableInfo.java | 22 +-
.../apache/doris/persist/TablePropertyInfo.java | 29 +-
.../org/apache/doris/persist/gson/GsonUtils.java | 44 -
.../apache/doris/persist/gson/GsonUtils134.java | 826 --------
.../doris/persist/meta/MetaPersistMethod.java | 6 +
.../doris/persist/meta/PersistMetaModules.java | 2 +-
.../org/apache/doris/planner/IcebergTableSink.java | 3 +
.../org/apache/doris/planner/OlapTableSink.java | 2 +-
.../java/org/apache/doris/plugin/AuditEvent.java | 206 +-
.../org/apache/doris/plugin/audit/AuditLoader.java | 101 +-
.../apache/doris/plugin/audit/AuditLogBuilder.java | 8 +-
.../doris/plugin/audit/AuditStreamLoader.java | 2 +
.../org/apache/doris/policy/DropPolicyLog.java | 18 -
.../java/org/apache/doris/policy/PolicyMgr.java | 34 -
.../java/org/apache/doris/qe/AuditLogHelper.java | 184 +-
.../java/org/apache/doris/qe/ConnectContext.java | 6 +-
.../java/org/apache/doris/qe/ConnectPoolMgr.java | 9 +
.../java/org/apache/doris/qe/ConnectProcessor.java | 8 +-
.../java/org/apache/doris/qe/ConnectScheduler.java | 5 +
.../main/java/org/apache/doris/qe/Coordinator.java | 10 +-
.../org/apache/doris/qe/CoordinatorContext.java | 2 +-
.../main/java/org/apache/doris/qe/DdlExecutor.java | 102 +-
.../java/org/apache/doris/qe/OriginStatement.java | 11 -
.../main/java/org/apache/doris/qe/QueryState.java | 12 +-
.../java/org/apache/doris/qe/SessionVariable.java | 5 -
.../java/org/apache/doris/qe/ShowExecutor.java | 833 +-------
.../java/org/apache/doris/qe/StmtExecutor.java | 137 +-
.../main/java/org/apache/doris/qe/VariableMgr.java | 9 +
.../java/org/apache/doris/resource/TagManager.java | 209 --
.../java/org/apache/doris/resource/TagSet.java | 18 +-
.../apache/doris/service/FrontendServiceImpl.java | 1 -
.../apache/doris/statistics/AnalysisJobInfo.java | 54 -
.../apache/doris/statistics/AnalysisManager.java | 14 -
.../apache/doris/statistics/AnalysisTaskInfo.java | 58 -
.../apache/doris/statistics/OlapAnalysisJob.java | 56 -
.../apache/doris/statistics/StatisticsCache.java | 6 +-
.../doris/statistics/StatsRecursiveDerive.java | 2 +-
.../doris/statistics/util/StatisticsUtil.java | 4 +-
.../org/apache/doris/system/BackendHbResponse.java | 12 -
.../org/apache/doris/system/BrokerHbResponse.java | 12 -
.../java/org/apache/doris/system/Frontend.java | 19 -
.../apache/doris/system/FrontendHbResponse.java | 12 -
.../java/org/apache/doris/system/HeartbeatMgr.java | 3 +
.../org/apache/doris/system/HeartbeatResponse.java | 39 +-
.../java/org/apache/doris/task/AgentBatchTask.java | 10 +
.../org/apache/doris/task/PushIndexPolicyTask.java | 63 +
.../doris/transaction/PartitionCommitInfo.java | 21 +-
.../apache/doris/transaction/TableCommitInfo.java | 41 +-
.../apache/doris/transaction/TabletCommitInfo.java | 8 -
.../apache/doris/transaction/TransactionState.java | 48 +-
.../doris/transaction/TxnCommitAttachment.java | 36 +-
fe/fe-core/src/main/jflex/sql_scanner.flex | 3 +
.../org/apache/doris/alter/BatchRollupJobTest.java | 69 -
.../org/apache/doris/alter/IndexChangeJobTest.java | 20 -
.../analysis/AdminCancelRebalanceDiskStmtTest.java | 78 -
.../doris/analysis/AdminRebalanceDiskStmtTest.java | 77 -
.../apache/doris/analysis/CancelAlterStmtTest.java | 100 -
.../analysis/CreateMaterializedViewStmtTest.java | 2 +-
.../org/apache/doris/analysis/ExprSerDeTest.java | 43 -
.../java/org/apache/doris/analysis/ExprTest.java | 44 +-
.../apache/doris/analysis/InsertArrayStmtTest.java | 44 -
.../apache/doris/analysis/ShowAlterStmtTest.java | 95 -
.../apache/doris/analysis/ShowDbIdStmtTest.java | 54 -
.../apache/doris/analysis/ShowIndexStmtTest.java | 70 -
.../apache/doris/analysis/ShowRollupStmtTest.java | 67 -
.../doris/analysis/ShowUserPropertyStmtTest.java | 81 -
.../doris/analysis/ShowVariablesStmtTest.java | 46 -
.../org/apache/doris/backup/BackupHandlerTest.java | 38 +-
.../org/apache/doris/backup/BackupJobInfoTest.java | 47 -
.../org/apache/doris/catalog/AdminStmtTest.java | 138 --
.../org/apache/doris/catalog/DiskInfoTest.java | 87 -
.../doris/catalog/MaterializedIndexMetaTest.java | 124 --
.../apache/doris/catalog/ModifyBackendTest.java | 199 --
.../org/apache/doris/catalog/ResourceMgrTest.java | 16 -
.../apache/doris/catalog/TablePropertyTest.java | 76 -
.../org/apache/doris/catalog/UserPropertyTest.java | 27 -
.../catalog/constraint/ConstraintPersistTest.java | 13 +-
.../org/apache/doris/clone/DecommissionTest.java | 17 +-
.../doris/clone/TabletRepairAndBalanceTest.java | 100 +-
.../doris/cluster/DecommissionBackendTest.java | 38 +-
.../common/profile/ProfilePersistentTest.java | 93 -
.../org/apache/doris/common/util/S3URITest.java | 45 +
.../doris/datasource/ExternalCatalogTest.java | 68 -
.../property/storage/S3PropertiesTest.java | 51 +
.../org/apache/doris/fs/obj/S3ObjStorageTest.java | 34 +
.../doris/indexpolicy/PolicyValidatorTests.java | 203 ++
.../doris/journal/bdbje/BDBJEJournalTest.java | 24 +-
.../load/routineload/RoutineLoadManagerTest.java | 50 +-
.../java/org/apache/doris/mtmv/AlterMTMVTest.java | 2 +-
.../org/apache/doris/mtmv/MTMVRewriteUtilTest.java | 12 +-
.../doris/nereids/memo/StructInfoMapTest.java | 18 +
.../doris/nereids/mv/IdStatisticsMapTest.java | 6 +
.../doris/nereids/mv/MvTableIdIsLongTest.java | 6 +
.../rules/rewrite/mv/SelectMvIndexTest.java | 14 +-
.../org/apache/doris/nereids/util/PlanChecker.java | 11 +
.../java/org/apache/doris/persist/ExprTest.java | 52 -
.../org/apache/doris/persist/UserPropertyTest.java | 72 -
.../apache/doris/planner/ResourceTagQueryTest.java | 20 +-
.../doris/plugin/audit/AuditLogBuilderTest.java | 24 +-
.../java/org/apache/doris/policy/PolicyTest.java | 15 -
.../org/apache/doris/qe/ConnectContextTest.java | 2 +-
.../org/apache/doris/qe/SessionVariablesTest.java | 78 -
.../java/org/apache/doris/qe/ShowExecutorTest.java | 56 -
.../doris/resource/TagSerializationTest.java | 49 -
.../java/org/apache/doris/resource/TagTest.java | 29 -
.../org/apache/doris/rewrite/FEFunctionsTest.java | 5 +-
.../doris/statistics/AnalysisManagerTest.java | 124 --
.../apache/doris/utframe/TestWithFeService.java | 13 +-
gensrc/proto/data.proto | 1 +
gensrc/script/doris_builtins_functions.py | 2 +-
gensrc/thrift/AgentService.thrift | 39 +-
gensrc/thrift/BackendService.thrift | 35 +-
gensrc/thrift/DataSinks.thrift | 124 +-
gensrc/thrift/Exprs.thrift | 119 +-
gensrc/thrift/FrontendService.thrift | 2 +-
gensrc/thrift/MasterService.thrift | 21 +-
gensrc/thrift/Metrics.thrift | 32 +-
gensrc/thrift/Opcodes.thrift | 156 +-
gensrc/thrift/PaloInternalService.thrift | 18 +-
gensrc/thrift/PlanNodes.thrift | 260 +--
gensrc/thrift/Types.thrift | 431 ++---
regression-test/data/cast_p0/cast_to_datetime.out | Bin 5202 -> 5208 bytes
.../data/datatype_p0/datetimev2/test_timezone.out | Bin 628 -> 434 bytes
.../datatype_p0/datetimev2/test_tz_streamload.out | Bin 627 -> 627 bytes
.../iceberg/test_iceberg_view_query_p0.out | Bin 0 -> 1033 bytes
.../data/external_table_p0/tvf/test_hdfs_tvf.out | Bin 40945 -> 41176 bytes
.../analyzer/test_custom_analyzer.out | Bin 0 -> 1217 bytes
.../analyzer/test_custom_analyzer1.out | Bin 0 -> 528 bytes
.../{ => analyzer}/test_ik_analyzer.out | Bin
.../data/inverted_index_p0/test_tokenize.out | Bin 3555 -> 11439 bytes
.../mv_p0/test_dup_mv_plus/test_dup_mv_plus.out | Bin 436 -> 531 bytes
.../testAggQueryOnAggMV10.out | Bin 264 -> 349 bytes
.../testAggQueryOnAggMV11.out | Bin 229 -> 292 bytes
.../testAggQueryOnAggMV2/testAggQueryOnAggMV2.out | Bin 235 -> 300 bytes
.../testAggQueryOnAggMV3/testAggQueryOnAggMV3.out | Bin 241 -> 327 bytes
.../testAggQuqeryOnAggMV5.out | Bin 217 -> 301 bytes
.../testAggQuqeryOnAggMV7.out | Bin 217 -> 301 bytes
.../testAggregateMVCalcAggFunctionQuery.out | Bin 217 -> 301 bytes
.../testBitmapUnionInQuery.out | Bin 210 -> 261 bytes
.../testCountDistinctToBitmap.out | Bin 281 -> 332 bytes
.../testIncorrectMVRewriteInSubquery.out | Bin 189 -> 240 bytes
.../testIncorrectRewriteCountDistinct.out | Bin 192 -> 243 bytes
.../testJoinOnLeftProjectToJoin.out | Bin 129 -> 130 bytes
.../data/mv_p0/ut/testNDVToHll/testNDVToHll.out | Bin 218 -> 269 bytes
.../testOrderByQueryOnProjectView.out | Bin 225 -> 317 bytes
.../ut/testProjectionMV1/testProjectionMV1.out | Bin 260 -> 335 bytes
.../ut/testProjectionMV2/testProjectionMV2.out | Bin 224 -> 295 bytes
.../ut/testProjectionMV3/testProjectionMV3.out | Bin 227 -> 302 bytes
.../ut/testProjectionMV4/testProjectionMV4.out | Bin 220 -> 287 bytes
.../testSingleMVMultiUsage.out | Bin 217 -> 301 bytes
.../data/mv_p0/ut/testSubQuery/testSubQuery.out | Bin 241 -> 349 bytes
.../ut/testUnionDistinct/testUnionDistinct.out | Bin 225 -> 309 bytes
.../nereids_function_p0/scalar_function/Array.out | Bin 773605 -> 774955
bytes
.../nereids_function_p0/scalar_function/Array1.out | Bin 33282709 -> 33283025
bytes
.../infer_predicate/pull_up_predicate_agg.out | Bin 1565 -> 2218 bytes
.../data/nereids_syntax_p0/grouping_sets.out | Bin 1638 -> 1867 bytes
.../aggregate/agg_with_having/agg_with_having.out} | Bin
regression-test/data/variant_p0/column_name.out | Bin 469 -> 545 bytes
regression-test/pipeline/common/doris-utils.sh | 18 +-
.../plugins/plugin_curl_requester.groovy | 10 +-
.../cold_data_compaction.groovy | 16 +-
.../test_mow_compact_multi_segments.groovy | 1 -
...paction_agg_and_remove_pre_delete_bitmap.groovy | 3 -
.../test_mow_stale_rowset_delete_bitmap.groovy | 1 -
...e_compaction_with_variant_inverted_index.groovy | 12 +-
.../correctness/test_cast_time_to_datetime.groovy | 16 +
.../datatype_p0/datetimev2/test_timezone.groovy | 5 +
.../iceberg/test_iceberg_view_query_p0.groovy | 203 ++
.../test_information_schema_timezone.groovy | 4 +-
.../external_table_p0/tvf/test_hdfs_tvf.groovy | 10 +
.../suites/function_p0/test_array_map.groovy | 4 +-
.../test_group_commit_schema_change.groovy | 4 +-
regression-test/suites/insert_p0/insert.groovy | 5 +
.../analyzer/test_custom_analyzer.groovy | 141 ++
.../analyzer/test_custom_analyzer1.groovy | 72 +
.../{ => analyzer}/test_ik_analyzer.groovy | 10 +-
.../suites/inverted_index_p0/test_tokenize.groovy | 5 +
.../suites/load_p0/copy_into/test_copy_into.groovy | 4 +-
.../routine_load/test_routine_load_error.groovy | 1 +
.../suites/manager/test_manager_interface_5.groovy | 99 +
.../suites/mtmv_p0/test_paimon_mtmv.groovy | 4 +-
.../mtmv_p0/test_paimon_olap_rewrite_mtmv.groovy | 4 +-
.../suites/mtmv_p0/test_paimon_rewrite_mtmv.groovy | 4 +-
.../mv_p0/mv_negative/agg_negative_test.groovy | 175 ++
.../mv_p0/mv_negative/dup_negative_test.groovy | 151 ++
.../mv_p0/mv_negative/mor_negative_test.groovy | 155 ++
.../mv_p0/mv_negative/mow_negative_test.groovy | 156 ++
.../mv_p0/test_dup_mv_plus/test_dup_mv_plus.groovy | 6 +-
.../testAggQueryOnAggMV10.groovy | 6 +-
.../testAggQueryOnAggMV11.groovy | 6 +-
.../testAggQueryOnAggMV2.groovy | 5 +-
.../testAggQueryOnAggMV3.groovy | 6 +-
.../testAggQuqeryOnAggMV5.groovy | 6 +-
.../testAggQuqeryOnAggMV7.groovy | 7 +-
.../testAggTableCountDistinctInBitmapType.groovy | 5 +-
.../testAggregateMVCalcAggFunctionQuery.groovy | 6 +-
.../testBitmapUnionInQuery.groovy | 5 +-
.../testCountDistinctToBitmap.groovy | 5 +-
.../testIncorrectMVRewriteInSubquery.groovy | 5 +-
.../testIncorrectRewriteCountDistinct.groovy | 5 +-
.../testJoinOnLeftProjectToJoin.groovy | 10 +-
.../mv_p0/ut/testNDVToHll/testNDVToHll.groovy | 5 +-
.../testOrderByQueryOnProjectView.groovy | 6 +-
.../ut/testProjectionMV1/testProjectionMV1.groovy | 5 +-
.../ut/testProjectionMV2/testProjectionMV2.groovy | 5 +-
.../ut/testProjectionMV3/testProjectionMV3.groovy | 5 +-
.../ut/testProjectionMV4/testProjectionMV4.groovy | 5 +-
.../testSingleMVMultiUsage.groovy | 6 +-
.../mv_p0/ut/testSubQuery/testSubQuery.groovy | 6 +-
.../ut/testUnionDistinct/testUnionDistinct.groovy | 6 +-
.../nereids_p0/test_repeat_no_stackflow.groovy | 429 +++++
.../infer_predicate/pull_up_predicate_agg.groovy | 6 +
.../mv/dml/insert/dml_insert_and_overwrite.groovy | 9 +-
.../mv/dml/outfile/dml_into_outfile.groovy | 5 +-
.../mv/union_rewrite/usercase_union_rewrite.groovy | 2 +-
.../suites/nereids_syntax_p0/grouping_sets.groovy | 9 +
.../query_not_exists_table_column.groovy | 45 +-
.../agg_with_having/agg_with_having.groovy | 24 +-
.../suites/show_p0/test_show_processlist.groovy | 29 +-
.../suites/variant_p0/column_name.groovy | 15 +-
.../vault_p0/alter/test_alter_s3_vault.groovy | 5 +-
.../test_create_vault_concurrently.groovy | 8 +-
979 files changed, 27906 insertions(+), 22070 deletions(-)
delete mode 100644 be/src/olap/match_predicate.cpp
delete mode 100644 be/src/olap/match_predicate.h
copy
fe/fe-core/src/main/java/org/apache/doris/analysis/TransactionCommitStmt.java
=> be/src/olap/rowset/segment_v2/inverted_index/abstract_analysis_factory.h
(67%)
create mode 100644
be/src/olap/rowset/segment_v2/inverted_index/analysis_factory_mgr.cpp
create mode 100644
be/src/olap/rowset/segment_v2/inverted_index/analysis_factory_mgr.h
create mode 100644
be/src/olap/rowset/segment_v2/inverted_index/analyzer/custom_analyzer.cpp
create mode 100644
be/src/olap/rowset/segment_v2/inverted_index/analyzer/custom_analyzer.h
create mode 100644
be/src/olap/rowset/segment_v2/inverted_index/analyzer/custom_analyzer_config.cpp
create mode 100644
be/src/olap/rowset/segment_v2/inverted_index/analyzer/custom_analyzer_config.h
rename fe/fe-core/src/test/java/org/apache/doris/analysis/KillStmtTest.java =>
be/src/olap/rowset/segment_v2/inverted_index/analyzer/ik/core/SurrogatePairSegmenter.cpp
(55%)
copy fe/fe-core/src/main/java/org/apache/doris/nereids/parser/Origin.java =>
be/src/olap/rowset/segment_v2/inverted_index/analyzer/ik/core/SurrogatePairSegmenter.h
(59%)
create mode 100644
be/src/olap/rowset/segment_v2/inverted_index/query/query_info.h
create mode 100644 be/src/olap/rowset/segment_v2/inverted_index/setting.h
create mode 100644
be/src/olap/rowset/segment_v2/inverted_index/token_filter/ascii_folding_filter.cpp
copy be/src/olap/rowset/segment_v2/inverted_index/{query/disjunction_query.h
=> token_filter/ascii_folding_filter.h} (51%)
copy be/src/{runtime/memory/heap_profiler.h =>
olap/rowset/segment_v2/inverted_index/token_filter/ascii_folding_filter_factory.h}
(55%)
create mode 100644
be/src/olap/rowset/segment_v2/inverted_index/token_filter/lower_case_filter.h
copy fe/fe-core/src/main/java/org/apache/doris/analysis/DefaultValueExpr.java
=>
be/src/olap/rowset/segment_v2/inverted_index/token_filter/lower_case_filter_factory.h
(58%)
copy fe/fe-core/src/main/java/org/apache/doris/analysis/DefaultValueExpr.java
=> be/src/olap/rowset/segment_v2/inverted_index/token_filter/token_filter.h
(58%)
copy fe/fe-core/src/main/java/org/apache/doris/nereids/parser/Origin.java =>
be/src/olap/rowset/segment_v2/inverted_index/token_filter/token_filter_factory.h
(59%)
create mode 100644
be/src/olap/rowset/segment_v2/inverted_index/token_filter/word_delimiter_filter.cpp
create mode 100644
be/src/olap/rowset/segment_v2/inverted_index/token_filter/word_delimiter_filter.h
create mode 100644
be/src/olap/rowset/segment_v2/inverted_index/token_filter/word_delimiter_filter_factory.h
create mode 100644
be/src/olap/rowset/segment_v2/inverted_index/token_filter/word_delimiter_iterator.cpp
create mode 100644
be/src/olap/rowset/segment_v2/inverted_index/token_filter/word_delimiter_iterator.h
create mode 100644 be/src/olap/rowset/segment_v2/inverted_index/token_stream.h
create mode 100644
be/src/olap/rowset/segment_v2/inverted_index/tokenizer/keyword/keyword_tokenizer.h
copy be/src/olap/rowset/segment_v2/inverted_index/{query_v2/term_query.h =>
tokenizer/keyword/keyword_tokenizer_factory.h} (51%)
create mode 100644
be/src/olap/rowset/segment_v2/inverted_index/tokenizer/ngram/char_matcher.h
copy fe/fe-core/src/main/java/org/apache/doris/analysis/DefaultValueExpr.java
=>
be/src/olap/rowset/segment_v2/inverted_index/tokenizer/ngram/edge_ngram_tokenizer.h
(58%)
create mode 100644
be/src/olap/rowset/segment_v2/inverted_index/tokenizer/ngram/edge_ngram_tokenizer_factory.h
create mode 100644
be/src/olap/rowset/segment_v2/inverted_index/tokenizer/ngram/ngram_tokenizer.cpp
create mode 100644
be/src/olap/rowset/segment_v2/inverted_index/tokenizer/ngram/ngram_tokenizer.h
create mode 100644
be/src/olap/rowset/segment_v2/inverted_index/tokenizer/ngram/ngram_tokenizer_factory.cpp
create mode 100644
be/src/olap/rowset/segment_v2/inverted_index/tokenizer/ngram/ngram_tokenizer_factory.h
create mode 100644
be/src/olap/rowset/segment_v2/inverted_index/tokenizer/standard/standard_tokenizer.h
copy be/src/olap/rowset/segment_v2/inverted_index/{query_v2/term_query.h =>
tokenizer/standard/standard_tokenizer_factory.h} (50%)
create mode 100644
be/src/olap/rowset/segment_v2/inverted_index/tokenizer/standard/standard_tokenizer_impl.cpp
create mode 100644
be/src/olap/rowset/segment_v2/inverted_index/tokenizer/standard/standard_tokenizer_impl.h
create mode 100644
be/src/olap/rowset/segment_v2/inverted_index/tokenizer/tokenizer.h
copy
fe/fe-core/src/main/java/org/apache/doris/analysis/TransactionRollbackStmt.java
=> be/src/olap/rowset/segment_v2/inverted_index/tokenizer/tokenizer_factory.h
(61%)
create mode 100644 be/src/runtime/index_policy/index_policy_mgr.cpp
create mode 100644 be/src/runtime/index_policy/index_policy_mgr.h
create mode 100644 be/src/util/jsonb_utils.cpp
create mode 100644
be/src/vec/data_types/serde/data_type_quantilestate_serde.cpp
create mode 100644 be/src/vec/data_types/serde/data_type_string_serde.cpp
create mode 100644 be/test/olap/inverted_index_parser_test.cpp
create mode 100644
be/test/olap/rowset/segment_v2/inverted_index/ananlyzer/custom_analyzer_test.cpp
create mode 100644
be/test/olap/rowset/segment_v2/inverted_index/query/phrase_edge_query_test.cpp
create mode 100644
be/test/olap/rowset/segment_v2/inverted_index/query/phrase_prefix_query_test.cpp
create mode 100644
be/test/olap/rowset/segment_v2/inverted_index/setting_test.cpp
create mode 100644
be/test/olap/rowset/segment_v2/inverted_index/token_filter/ascii_folding_filter_factory_test.cpp
create mode 100644
be/test/olap/rowset/segment_v2/inverted_index/token_filter/lower_case_filter_factory_test.cpp
create mode 100644
be/test/olap/rowset/segment_v2/inverted_index/token_filter/word_delimiter_filter_factory_test.cpp
create mode 100644
be/test/olap/rowset/segment_v2/inverted_index/token_filter/word_delimiter_filter_test.cpp
create mode 100644
be/test/olap/rowset/segment_v2/inverted_index/token_filter/word_delimiter_iterator_test.cpp
create mode 100644
be/test/olap/rowset/segment_v2/inverted_index/tokenizer/edge_ngram_tokenizer_test.cpp
create mode 100644
be/test/olap/rowset/segment_v2/inverted_index/tokenizer/keyword_analyzer_test.cpp
create mode 100644
be/test/olap/rowset/segment_v2/inverted_index/tokenizer/ngram_tokenizer_test.cpp
create mode 100644
be/test/olap/rowset/segment_v2/inverted_index/tokenizer/standard_tokenizer_factory_test.cpp
create mode 100644
be/test/olap/rowset/segment_v2/inverted_index_file_reader_test.cpp
create mode 100644
be/test/olap/rowset/segment_v2/inverted_index_fs_directory_test.cpp
create mode 100644 be/test/runtime/index_policy/index_policy_mgr_test.cpp
create mode 100644 be/test/util/jsonb_serialize_test.cpp
create mode 100644 be/test/util/test_data/jsonb_serialize_test_data.bin
create mode 100644 be/test/util/test_data/jsonb_serialize_test_data2.bin
rename be/test/vec/function/{function_multi_match.cpp =>
function_multi_match_test.cpp} (100%)
create mode 100644 be/test/vec/jsonb/jsonb_document_test.cpp
create mode 100644 cloud/src/common/defer.h
create mode 100644
docker/thirdparties/docker-compose/hive/scripts/preinstalled_data/json_format_test/simple_object_json.json.gz
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/create_preinstalled_scripts/iceberg/run14.sql
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/AdminCancelRebalanceDiskStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/AdminCheckTabletsStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/AdminCleanTrashStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/AdminCompactTableStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/AdminCopyTabletStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/AdminRebalanceDiskStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/AdminRepairTableStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/AdminSetReplicaStatusStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/AdminSetReplicaVersionStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/AdminSetTableStatusStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/AlterSystemStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/CancelAlterSystemStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/CancelAlterTableStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/CancelBackupStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/CancelCloudWarmUpStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/CleanQueryStatsStmt.java
rename fe/fe-core/src/main/java/org/apache/doris/analysis/{ShowPolicyStmt.java
=> CreateIndexPolicyStmt.java} (52%)
rename
fe/fe-core/src/main/java/org/apache/doris/analysis/{AdminCancelRepairTableStmt.java
=> DropIndexPolicyStmt.java} (57%)
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/DropPolicyStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/KillStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/PauseRoutineLoadStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/ResumeRoutineLoadStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/ShowAuthorStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/ShowConfigStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCreateRoutineLoadStmt.java
copy fe/fe-core/src/main/java/org/apache/doris/analysis/{DropResourceStmt.java
=> ShowIndexPolicyStmt.java} (68%)
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/ShowIndexStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/ShowLoadWarningsStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/ShowQueuedAnalyzeJobsStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/ShowReplicaStatusStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/ShowRollupStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/ShowRoutineLoadStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/ShowRoutineLoadTaskStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/ShowStreamLoadStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTableStatsStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTransactionStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTrashDiskStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/ShowUserPropertyStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/ShowVariablesStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/ShowWorkloadGroupsStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/TransactionBeginStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/WarmUpClusterStmt.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/indexpolicy/AsciiFoldingTokenFilterValidator.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/indexpolicy/BasePolicyValidator.java
rename
fe/fe-core/src/main/java/org/apache/doris/{datasource/CatalogMgrProperty.java
=> indexpolicy/DropIndexPolicyLog.java} (71%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/indexpolicy/EdgeNGramTokenizerValidator.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/indexpolicy/IndexPolicy.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/indexpolicy/IndexPolicyMgr.java
rename
fe/fe-core/src/main/java/org/apache/doris/{analysis/TransactionStmt.java =>
indexpolicy/IndexPolicyTypeEnum.java} (59%)
copy fe/fe-core/src/main/java/org/apache/doris/{analysis/DefaultValueExpr.java
=> indexpolicy/KeywordTokenizerValidator.java} (59%)
copy fe/fe-core/src/main/java/org/apache/doris/{analysis/DefaultValueExpr.java
=> indexpolicy/LowerCaseTokenFilterValidator.java} (59%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/indexpolicy/NGramTokenizerValidator.java
rename
fe/fe-core/src/main/java/org/apache/doris/{analysis/TransactionRollbackStmt.java
=> indexpolicy/PolicyPropertyValidator.java} (78%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/indexpolicy/StandardTokenizerValidator.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/indexpolicy/WordDelimiterTokenFilterValidator.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/mysql/privilege/UserPrivTable.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/mysql/privilege/UserResource.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/mysql/privilege/WhiteList.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/CreateIndexAnalyzerCommand.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/CreateIndexTokenFilterCommand.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/CreateIndexTokenizerCommand.java
copy fe/fe-core/src/main/java/org/apache/doris/{analysis/DropResourceStmt.java
=> nereids/trees/plans/commands/DropIndexAnalyzerCommand.java} (57%)
copy fe/fe-core/src/main/java/org/apache/doris/{analysis/DropResourceStmt.java
=> nereids/trees/plans/commands/DropIndexTokenFilterCommand.java} (57%)
rename
fe/fe-core/src/main/java/org/apache/doris/{analysis/DropResourceStmt.java =>
nereids/trees/plans/commands/DropIndexTokenizerCommand.java} (57%)
copy fe/fe-core/src/main/java/org/apache/doris/{analysis/ShowDbIdStmt.java =>
nereids/trees/plans/commands/ShowIndexAnalyzerCommand.java} (57%)
copy fe/fe-core/src/main/java/org/apache/doris/{analysis/ShowDbIdStmt.java =>
nereids/trees/plans/commands/ShowIndexTokenFilterCommand.java} (57%)
rename fe/fe-core/src/main/java/org/apache/doris/{analysis/ShowDbIdStmt.java
=> nereids/trees/plans/commands/ShowIndexTokenizerCommand.java} (57%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/util/MoreFieldsThread.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/persist/gson/GsonUtils134.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/resource/TagManager.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/statistics/AnalysisJobInfo.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/statistics/AnalysisTaskInfo.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/statistics/OlapAnalysisJob.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/task/PushIndexPolicyTask.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/analysis/AdminCancelRebalanceDiskStmtTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/analysis/AdminRebalanceDiskStmtTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/analysis/CancelAlterStmtTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/analysis/ShowAlterStmtTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/analysis/ShowDbIdStmtTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/analysis/ShowIndexStmtTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/analysis/ShowRollupStmtTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/analysis/ShowUserPropertyStmtTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/analysis/ShowVariablesStmtTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/catalog/DiskInfoTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/catalog/MaterializedIndexMetaTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/catalog/ModifyBackendTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/catalog/TablePropertyTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/indexpolicy/PolicyValidatorTests.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/persist/ExprTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/persist/UserPropertyTest.java
create mode 100644
regression-test/data/external_table_p0/iceberg/test_iceberg_view_query_p0.out
create mode 100644
regression-test/data/inverted_index_p0/analyzer/test_custom_analyzer.out
create mode 100644
regression-test/data/inverted_index_p0/analyzer/test_custom_analyzer1.out
rename regression-test/data/inverted_index_p0/{ =>
analyzer}/test_ik_analyzer.out (100%)
copy regression-test/data/{function_p0/test_array_map.out =>
query_p0/aggregate/agg_with_having/agg_with_having.out} (100%)
create mode 100644
regression-test/suites/external_table_p0/iceberg/test_iceberg_view_query_p0.groovy
create mode 100644
regression-test/suites/inverted_index_p0/analyzer/test_custom_analyzer.groovy
create mode 100644
regression-test/suites/inverted_index_p0/analyzer/test_custom_analyzer1.groovy
rename regression-test/suites/inverted_index_p0/{ =>
analyzer}/test_ik_analyzer.groovy (95%)
create mode 100644
regression-test/suites/manager/test_manager_interface_5.groovy
create mode 100644
regression-test/suites/mv_p0/mv_negative/agg_negative_test.groovy
create mode 100644
regression-test/suites/mv_p0/mv_negative/dup_negative_test.groovy
create mode 100644
regression-test/suites/mv_p0/mv_negative/mor_negative_test.groovy
create mode 100644
regression-test/suites/mv_p0/mv_negative/mow_negative_test.groovy
create mode 100644
regression-test/suites/nereids_p0/test_repeat_no_stackflow.groovy
copy fe/fe-core/src/main/java/org/apache/doris/analysis/DefaultValueExpr.java
=>
regression-test/suites/nereids_syntax_p0/query_not_exists_table_column.groovy
(50%)
rename
fe/fe-core/src/main/java/org/apache/doris/analysis/TransactionCommitStmt.java
=>
regression-test/suites/query_p0/aggregate/agg_with_having/agg_with_having.groovy
(62%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
