This is an automated email from the ASF dual-hosted git repository.
eldenmoon pushed a change to branch fix-doris-25672
in repository https://gitbox.apache.org/repos/asf/doris.git
from 92520ac7975 [fix](fe) Reject COUNT DISTINCT on variant arguments
add a2daa074d3f [fix](be) Report string column overflow on checked append
paths (#63183)
add b9f5281b566 [fix](timestamptz) Report TIMESTAMPTZ as string to MySQL
clients (#63292)
add 170084d61e1 [fix](thrift) Reserve frontend service field ids (#63239)
add c5109e709ee [fix](be) Fix json contains duplicate array candidates
(#63301)
add 22c9ed691d5 [fix](fe) Reject lone UTF-16 surrogates in JSONB literals
(RFC 8259 §8.2) (#63255)
add ee0dcfe5a77 [fix](config) Remove fuzzy of string_overflow_size (#63341)
add 69aa8764dfe [fix](fe) Fix alias function with cast outermost expr and
reject illegal expressions (#63254)
add 76bbe581b96 [fix](fe) Add null reject compensation for join rewrite
(#63268)
add 451c70888d8 [fix](storage) Fix typo 'occured' in user-facing error
messages (#62521)
add 84f8107d878 [chore](window function) remove useless cast in
WindowFunctionChecker (#63284)
add ab1a4ddb592 [refine](exec) replace std::shared_mutex/std::shared_lock
with annotated wrappers for thread safety analysis (#63109)
add b6d50d4756c [doc](AGENTS) Update agents instructions for commit
messages and regressions (#63351)
add d77856dc715 [improvement](statistics) Collect hot value during full
statistics analysis (#62435)
add 92c9c21f2cf [fix](mtmv) support qualified materialized view rename
target (#63216)
add ce61c8dfe99 [Chore](be) Avoid BE crash on exception (#63312)
add 21b9fdfbe9f [fix](be) Reject super wildcard path in json keys (#63300)
add 1e1f1a4c451 [Feature] support binlog<row> read and write (row type)
(2/3) (#63110)
add 8a4f118979f [improvement](iceberg) Reconstruct partition spec in SHOW
CREATE TABLE for Iceberg tables (#63240)
add 65136532975 [fix](parquet) Fix wrong encoding for parquet page v2
(#63305)
add ea933186522 [fix](testcase) Fix wrong test case (#63354)
add 95752b78090 [refine](column) enforce nullable nested types for array
(#63088)
add c75eba5488f [fix](fe) Prune empty and cascading CTE plans (#62828)
add cbffd4f290f [test](regression) Move Iceberg REST HDFS case to P2
(#63367)
add 53132a19a96 [fix](be) Fix macOS BE build (#63230)
add f9fb157ad85 [fix](publish) Avoid NPE for force-finished publish task
(#63069)
add 87d949800b0 [fix](fe) Avoid OFFSET path and NULL path for complex
datatype when its children are accessed. (#63229)
add bd21de83599 [fix](exchange) Drain exchange receiver queues outside
lock (#63331)
add 1faf1d9fda6 [improvement](cloud) Propagate compute group id to BE
thrift payloads (#62487)
add cfe94e17d04 [Enhancement](udf) Support volatility property for scalar
UDF (#62698)
add 8f696e0ecaf [fix](be) Preserve collect aggregate limit during merge
(#63361)
add 8d3bd8a037e [fix](be) Rebind storage common expr slots (#63279)
add be49e67d7b0 [improve](streaming-job) async chunk splitting for cdc
source job (#63079)
add 4483daf9f03 [fix](be) Clean up aggregate states and use Doris hash
containers (#63174)
add 2d9ec456a7a [improvement](cloud) Add enable_recycler config to skip
recycler dynamically (#63286)
add 1891f71d5aa [fix](fe) add --drop_backends param to start_fe.sh (#63306)
add 55107434cf4 [enhancement](agent) Add more agent behavior calibration
instructions (#63395)
add f318357c820 [Fix](topn) Reject non-positive topn count argument
(#63350)
add 7ac81600cde [fix](be) Use debug point for string overflow conversion
(#63392)
add 0338e0efee8 [fix](docker) allow overriding fdb image (#63393)
add fc9dde0b263 [fix](case)Fix test_orc_lazy_mat_profile failure caused by
condition cache. (#63382)
add 2a2856189cc [fix](fe) Skip broken external tables in show tables
(#63407)
add 9bf0817dc3b fix: block type reset after dict filter (#63168)
add b96bb6b49be [fix](fe) Preserve narrowing datetimev2 casts in simplify
in predicate (#63343)
add afe30f383fe [fix](view) Prevent invalid alias rewrite in view
definitions (#63353)
add d527c14d90f [refactor](fe) Add typed filesystem properties for S3
(#63252)
add a0685f450d3 [doc](be) Document JSONB path compatibility (#63364)
add 5d82f600b20 [fix](nereids) Fix pre-aggregation context leakage across
join branches (#63357)
add f4ce70ed503 [fix](be) Remove pure attribute from assert_cast (#63417)
add 06f55c0ac14 [Enhancement](CI) Auto refresh AI Review credential
(#63431)
add 820f51b474a [refactor](fe) Refine volatile expression handling (#63403)
add a70c212956c [fix](uniform function) fix constant argument handling
and use ColumnView
(#63076)
add bad5649d6d5 [improvement](be) Optimize nested loop join
materialization (#62956)
add 3d7b76454c6 [fix](be) Remove unsafe JsonbWriter key overload (#63355)
add ec722fd6a12 [fix](be) Avoid signaling unbuilt shared hash table
(#63345)
add d449371b20a [fix](agg)Adjust agg strategy when table satisfy distinct
key distribution (#61248)
add 9b3b9d2c5fc [doc](security) Add threat model for scans (#63447)
add b6d8ef45d7c [chore](be) Document lightweight JSONB validation (#63359)
add 8a8999cf3a5 [refactor](storage) drop StorageField wrapper and clean up
related dead code (#63233)
add c02047ee370 [fix](test) Fix flaky partition_curd_union_rewrite test in
cloud mode (#62766)
add dc5d1398b33 [chore](be) Reject broadcast joins that finalize build
side (#63445)
add b307a23967f [refine](be) remove unsafe PURE annotations (#63440)
add 12f02ebf090 [opt](be) Batch row_id reads in seek_and_read_by_rowid to
reduce column iterator overhead (#63436)
add 4ab7cc02461 [fix](function) support TIMESTAMPDIFF MICROSECOND in
nereids (#63365)
add 974f9bdc89b [opt](sort) avoid copying whole blocks during merge
(#63429)
add 70ca0872d61 [fix](cloud) show proc should display partition cached
version (#60807)
add 58a24298999 [fix](cloud) avoid false tablet diagnosis alarms in cloud
mode (#60805)
add e4238ac87cc [fix](cloud) Fill schema change version holes before
running (#63443)
add f852097a4ff [opt](storage) disable dict encoding in row store columns
(#63438)
add 3da4d2b4669 [fix](test) replace removed JMockit with Mockito in
CloudProcVersionD… (#63473)
add ac34f069c25 [test](be) add JsonbSerializeUtil::block_to_jsonb
golden-file UT covering all row-store-supported types (#63448)
add fb38a5df891 [fix](be) Compare JSON numeric values by value (#63396)
add ad4b8b87bdf [fix](ci) harden GitHub Actions workflows against
injection and module shadowing (#63486)
add 2eff9ea9894 [fix](fe) Allow show tablet without selected database
(#63280)
add c6d04c170ca Merge branch 'master' into fix-doris-25672
No new revisions were added by this update.
Summary of changes:
.claude/skills/be-code-style/SKILL.md | 9 +
.github/workflows/comment-to-trigger-teamcity.yml | 4 +
.github/workflows/license-eyes.yml | 4 +
.github/workflows/opencode-review-runner.yml | 58 +-
AGENTS.md | 14 +-
be/benchmark/benchmark_zone_map_index.hpp | 4 +-
be/src/cloud/cloud_rowset_writer.cpp | 2 +
be/src/cloud/cloud_schema_change_job.cpp | 4 +
be/src/cloud/cloud_tablets_channel.cpp | 4 +
be/src/cloud/pb_convert.cpp | 32 +-
be/src/common/config.cpp | 4 -
be/src/common/config.h | 3 -
be/src/common/multi_version.h | 8 +
be/src/common/thread_safety_annotations.h | 48 +
be/src/core/assert_cast.h | 2 +-
be/src/core/binary_cast.hpp | 2 +-
be/src/core/column/column_nullable.h | 5 +-
be/src/core/column/column_string.cpp | 14 +-
be/src/core/column/column_string.h | 6 +-
be/src/core/data_type/data_type_array.cpp | 17 +-
be/src/core/data_type/data_type_array.h | 11 +-
be/src/core/data_type/data_type_factory.cpp | 5 -
be/src/core/data_type/data_type_factory.hpp | 2 -
be/src/core/data_type/primitive_type.h | 2 +
.../core/data_type_serde/data_type_array_serde.cpp | 4 +-
.../core/data_type_serde/data_type_array_serde.h | 10 +-
.../data_type_serde/data_type_nullable_serde.h | 3 +
.../core/data_type_serde/datelike_serde_common.hpp | 10 +-
be/src/core/string_ref.h | 3 +-
be/src/core/value/map_value.h | 57 --
be/src/core/value/struct_value.h | 61 --
be/src/exec/common/memory.cpp | 2 +-
be/src/exec/exchange/vdata_stream_mgr.cpp | 28 +-
be/src/exec/exchange/vdata_stream_mgr.h | 14 +-
be/src/exec/exchange/vdata_stream_recvr.cpp | 55 +-
be/src/exec/exchange/vdata_stream_recvr.h | 3 +
be/src/exec/operator/hashjoin_build_sink.cpp | 28 +-
.../operator/nested_loop_join_probe_operator.cpp | 642 +++++++++++-
.../operator/nested_loop_join_probe_operator.h | 64 +-
be/src/exec/operator/olap_scan_operator.cpp | 15 +-
be/src/exec/pipeline/pipeline_fragment_context.cpp | 2 +-
be/src/exec/rowid_fetcher.cpp | 136 ++-
be/src/exec/runtime_filter/runtime_filter_mgr.cpp | 20 +-
be/src/exec/runtime_filter/runtime_filter_mgr.h | 9 +-
be/src/exec/scan/olap_scanner.cpp | 15 +-
be/src/exec/scan/olap_scanner.h | 1 +
be/src/exec/scan/parallel_scanner_builder.cpp | 6 +-
be/src/exec/scan/scanner_scheduler.h | 2 +-
.../time_sharing/prioritized_split_runner.cpp | 26 +-
be/src/exec/sink/autoinc_buffer.cpp | 2 +
be/src/exec/sink/autoinc_buffer.h | 8 +
be/src/exec/sort/sort_cursor.h | 5 +
be/src/exec/sort/sorter.cpp | 18 +
be/src/exprs/aggregate/aggregate_function.h | 54 +-
.../exprs/aggregate/aggregate_function_collect.h | 13 +-
.../exprs/aggregate/aggregate_function_distinct.h | 8 +-
be/src/exprs/aggregate/aggregate_function_map.h | 2 +-
be/src/exprs/aggregate/aggregate_function_map_v2.h | 2 +-
be/src/exprs/function/cast/cast_to_array.h | 2 +-
be/src/exprs/function/function_jsonb.cpp | 4 +-
be/src/exprs/function/uniform.cpp | 14 +-
be/src/exprs/virtual_slot_ref.h | 2 +-
be/src/exprs/vslot_ref.h | 2 +-
be/src/format/parquet/vparquet_group_reader.cpp | 4 +-
.../information_schema/schema_rowsets_scanner.cpp | 9 +-
be/src/io/cache/cache_block_meta_store.cpp | 2 -
be/src/io/io_common.h | 4 +-
be/src/load/channel/tablets_channel.cpp | 38 +-
be/src/load/delta_writer/delta_writer.cpp | 14 +-
be/src/load/delta_writer/delta_writer.h | 3 +
be/src/load/delta_writer/delta_writer_context.h | 11 +-
be/src/load/delta_writer/delta_writer_v2.cpp | 2 +
be/src/load/memtable/memtable_flush_executor.cpp | 293 ++++--
be/src/load/memtable/memtable_flush_executor.h | 57 +-
be/src/load/memtable/memtable_writer.cpp | 5 +-
be/src/runtime/collection_value.h | 80 --
be/src/service/point_query_executor.cpp | 5 +-
be/src/storage/binlog.h | 146 +++
be/src/storage/binlog_config.h | 4 +-
be/src/storage/compaction/compaction.cpp | 13 +
be/src/storage/data_dir.cpp | 129 ++-
be/src/storage/field.h | 382 -------
be/src/storage/index/ann/ann_index_writer.cpp | 5 -
be/src/storage/index/ann/ann_index_writer.h | 3 -
be/src/storage/index/index_writer.cpp | 21 +-
be/src/storage/index/index_writer.h | 8 +-
.../index/inverted/inverted_index_reader.cpp | 7 +-
.../index/inverted/inverted_index_writer.cpp | 54 -
.../storage/index/inverted/inverted_index_writer.h | 2 -
be/src/storage/index/zone_map/zone_map_index.cpp | 6 +-
be/src/storage/index/zone_map/zone_map_index.h | 4 +-
be/src/storage/iterator/olap_data_convertor.cpp | 1 -
be/src/storage/iterator/olap_data_convertor.h | 1 -
be/src/storage/iterator/vcollect_iterator.cpp | 4 +
.../storage/iterator/vertical_merge_iterator.cpp | 1 -
be/src/storage/iterator/vgeneric_iterators.cpp | 1 -
be/src/storage/iterators.h | 1 +
be/src/storage/olap_common.h | 22 +-
be/src/storage/partial_update_info.cpp | 49 +-
be/src/storage/partial_update_info.h | 24 +-
be/src/storage/row_cursor.cpp | 53 +-
be/src/storage/row_cursor.h | 9 +-
be/src/storage/rowset/beta_rowset_reader.cpp | 1 +
be/src/storage/rowset/beta_rowset_writer.cpp | 11 +-
be/src/storage/rowset/beta_rowset_writer.h | 11 +
be/src/storage/rowset/beta_rowset_writer_v2.h | 4 +
be/src/storage/rowset/group_rowset_writer.cpp | 43 +-
be/src/storage/rowset/group_rowset_writer.h | 13 +
be/src/storage/rowset/rowset.h | 4 +-
be/src/storage/rowset/rowset_factory.cpp | 4 +-
be/src/storage/rowset/rowset_meta.h | 21 +-
be/src/storage/rowset/rowset_meta_manager.cpp | 157 ++-
be/src/storage/rowset/rowset_meta_manager.h | 40 +-
be/src/storage/rowset/rowset_writer.h | 9 +
be/src/storage/rowset/rowset_writer_context.h | 48 +-
be/src/storage/rowset/segment_creator.cpp | 18 +-
be/src/storage/rowset/segment_creator.h | 3 +
.../storage/rowset/vertical_beta_rowset_writer.cpp | 1 +
be/src/storage/rowset_builder.cpp | 115 ++-
be/src/storage/rowset_builder.h | 28 +-
be/src/storage/rowset_version_mgr.cpp | 25 +-
be/src/storage/schema.cpp | 34 +-
be/src/storage/schema.h | 28 +-
be/src/storage/schema_change/schema_change.cpp | 9 -
be/src/storage/schema_change/schema_change.h | 1 -
be/src/storage/segment/column_writer.cpp | 170 ++--
be/src/storage/segment/column_writer.h | 36 +-
.../storage/segment/historical_row_retriever.cpp | 288 ++++++
be/src/storage/segment/historical_row_retriever.h | 134 +++
.../storage/segment/row_binlog_segment_writer.cpp | 522 ++++++++++
be/src/storage/segment/row_binlog_segment_writer.h | 111 ++
be/src/storage/segment/segment.cpp | 19 +-
be/src/storage/segment/segment.h | 10 +-
be/src/storage/segment/segment_iterator.cpp | 311 +++++-
be/src/storage/segment/segment_iterator.h | 8 +-
be/src/storage/segment/segment_writer.cpp | 126 +--
be/src/storage/segment/segment_writer.h | 14 +-
.../variant/binary_column_extract_iterator.h | 1 -
.../segment/variant/hierarchical_data_iterator.h | 1 -
.../segment/variant/sparse_column_merge_iterator.h | 1 -
.../segment/variant/variant_column_writer_impl.cpp | 31 +-
.../segment/variant/variant_column_writer_impl.h | 4 +-
.../variant_streaming_compaction_writer.cpp | 3 +-
be/src/storage/segment/vertical_segment_writer.cpp | 22 +-
be/src/storage/storage_engine.cpp | 54 +-
be/src/storage/tablet/base_tablet.cpp | 157 ++-
be/src/storage/tablet/base_tablet.h | 9 +-
be/src/storage/tablet/tablet.cpp | 143 ++-
be/src/storage/tablet/tablet.h | 14 +-
be/src/storage/tablet/tablet_manager.cpp | 12 +
be/src/storage/tablet/tablet_meta_manager.cpp | 46 +-
be/src/storage/tablet/tablet_meta_manager.h | 6 +
be/src/storage/tablet/tablet_reader.cpp | 6 +-
be/src/storage/tablet/tablet_schema.h | 9 +
be/src/storage/tablet_info.cpp | 49 +
be/src/storage/tablet_info.h | 3 +
.../storage/task/engine_publish_version_task.cpp | 46 +-
be/src/storage/task/engine_publish_version_task.h | 4 +-
be/src/storage/task/index_builder.cpp | 46 +-
be/src/storage/task/index_builder.h | 12 +-
be/src/storage/txn/txn_manager.cpp | 108 +-
be/src/storage/txn/txn_manager.h | 17 +-
be/src/storage/types.h | 60 +-
be/src/util/jsonb_document.cpp | 7 +-
be/src/util/jsonb_document.h | 310 ++++--
be/src/util/jsonb_writer.h | 2 -
be/src/util/string_parser.hpp | 3 +-
be/src/util/thrift_util.cpp | 13 +
be/src/util/thrift_util.h | 5 +-
be/test/cloud/cloud_schema_change_job_test.cpp | 109 ++
be/test/cloud/cloud_tablet_test.cpp | 50 +
be/test/core/block/block_test.cpp | 6 +-
be/test/core/column/column_string_test.cpp | 22 +-
.../data_type_serde_get_name_test.cpp | 4 +-
.../data_type_serde_string_test.cpp | 8 +-
be/test/core/jsonb/convert_field_to_type_test.cpp | 4 +-
be/test/core/jsonb/jsonb_document_test.cpp | 109 +-
be/test/core/jsonb/serialize_test.cpp | 1066 +++++++++++++++++++-
.../data/vec/native/all_types_single_row.native | Bin 1124 -> 1140 bytes
be/test/exec/common/schema_util_test.cpp | 4 +-
.../time_sharing_task_executor_test.cpp | 43 +
be/test/exec/operator/hashjoin_build_sink_test.cpp | 54 +
be/test/exec/operator/sort_operator_test.cpp | 19 +-
.../exec/operator/table_function_operator_test.cpp | 55 +-
be/test/exec/pipeline/vdata_stream_recvr_test.cpp | 111 +-
be/test/exec/scan/vgeneric_iterators_test.cpp | 1 -
be/test/exec/sort/heap_sorter_test.cpp | 16 +-
be/test/exec/sort/merge_sorter_state.cpp | 67 ++
be/test/exprs/aggregate/agg_array_agg_test.cpp | 70 --
be/test/exprs/aggregate/agg_collect_test.cpp | 72 +-
be/test/exprs/aggregate/agg_replace_test.cpp | 6 +-
.../aggregate_function_exception_test.cpp | 162 +++
.../function/cast/function_variant_cast_test.cpp | 1 -
be/test/exprs/function/function_jsonb_test.cpp | 74 +-
be/test/exprs/hybrid_set_test.cpp | 17 +-
be/test/exprs/minmax_predicate_test.cpp | 19 +-
be/test/format/orc/orc_reader_fill_data_test.cpp | 48 +-
be/test/format/parquet/parquet_thrift_test.cpp | 31 +
.../load/memtable/memtable_flush_executor_test.cpp | 335 +++++-
be/test/olap/rowset/group_rowset_builder_test.cpp | 112 +-
be/test/olap/rowset/group_rowset_writer_test.cpp | 225 +++++
.../compaction/ordered_data_compaction_test.cpp | 1 -
.../compaction/vertical_compaction_test.cpp | 1 -
be/test/storage/index/ann/ann_index_smoke_test.cpp | 6 -
.../storage/index/ann/ann_index_writer_test.cpp | 24 +-
.../compaction/util/index_compaction_utils.cpp | 1 +
.../inverted/query/phrase_edge_query_test.cpp | 11 +-
.../inverted/query/phrase_prefix_query_test.cpp | 11 +-
.../index/inverted/query/phrase_query_test.cpp | 11 +-
be/test/storage/metadata_adder_test.cpp | 8 +-
.../storage/rowset/rowset_meta_manager_test.cpp | 139 +++
.../storage/segment/column_meta_accessor_test.cpp | 71 ++
.../storage/segment/column_reader_writer_test.cpp | 227 -----
.../storage/segment/inverted_index_array_test.cpp | 46 +-
.../segment/inverted_index_file_writer_test.cpp | 1 +
.../storage/segment/inverted_index_reader_test.cpp | 56 +-
.../storage/segment/inverted_index_writer_test.cpp | 174 +---
.../storage/segment/segment_corruption_test.cpp | 1 -
be/test/storage/segment/zone_map_index_test.cpp | 52 +-
be/test/storage/storage_types_test.cpp | 87 +-
be/test/storage/txn/txn_manager_test.cpp | 119 ++-
be/test/testutil/creators.h | 148 ++-
be/test/util/jsonb_contains_test.cpp | 64 ++
be/test/util/jsonb_serialize_test.cpp | 8 +-
.../test_data/block_to_jsonb_all_types_golden.bin | Bin 0 -> 1586 bytes
bin/start_fe.sh | 14 +-
cloud/src/common/config.h | 2 +
cloud/src/recycler/recycler.cpp | 45 +-
cloud/test/recycler_test.cpp | 81 ++
docker/runtime/doris-compose/command.py | 10 +-
docker/runtime/doris-compose/resource/init_fe.sh | 2 +-
.../postgresql/postgresql-14.yaml.tpl | 4 +-
.../org/apache/doris/analysis/JsonLiteral.java | 39 +-
.../main/java/org/apache/doris/catalog/Column.java | 1 +
.../java/org/apache/doris/catalog/Function.java | 11 +
.../apache/doris/catalog/FunctionVolatility.java} | 30 +-
.../main/java/org/apache/doris/common/Config.java | 3 +
.../job/cdc/request/FetchTableSplitsRequest.java | 12 +
.../antlr4/org/apache/doris/nereids/DorisParser.g4 | 5 +-
.../src/main/java/org/apache/doris/DorisFE.java | 5 +
.../apache/doris/alter/SchemaChangeHandler.java | 6 +
.../doris/catalog/AutoIncrementGenerator.java | 4 +
.../doris/catalog/BuiltinTableValuedFunctions.java | 2 +
.../main/java/org/apache/doris/catalog/Env.java | 34 +
.../org/apache/doris/catalog/FunctionGenTable.java | 8 +
.../doris/catalog/FunctionToSqlConverter.java | 67 +-
.../java/org/apache/doris/catalog/OlapTable.java | 28 +-
.../org/apache/doris/catalog/OlapTableWrapper.java | 2 +
.../doris/catalog/RowBinlogTableWrapper.java | 18 +-
.../java/org/apache/doris/catalog/SchemaTable.java | 2 +-
.../java/org/apache/doris/common/FeConstants.java | 1 +
.../apache/doris/common/proc/IndicesProcDir.java | 4 +-
.../common/proc/ProcReplicaVersionDisplay.java | 44 +
.../apache/doris/common/proc/ReplicasProcNode.java | 17 +-
.../apache/doris/common/proc/TabletsProcDir.java | 14 +-
.../apache/doris/datasource/ExternalDatabase.java | 11 +-
.../apache/doris/datasource/InternalCatalog.java | 2 +-
.../datasource/iceberg/IcebergExternalTable.java | 50 +
.../insert/streaming/StreamingInsertJob.java | 39 +-
.../streaming/StreamingJobSchedulerTask.java | 7 +
.../doris/job/offset/SourceOffsetProvider.java | 24 +-
.../job/offset/jdbc/JdbcSourceOffsetProvider.java | 503 +++++++--
.../offset/jdbc/JdbcTvfSourceOffsetProvider.java | 60 +-
.../apache/doris/job/util/StreamingJobUtils.java | 72 +-
.../java/org/apache/doris/load/DeleteHandler.java | 7 +
.../org/apache/doris/mysql/MysqlSerializer.java | 7 +-
.../org/apache/doris/nereids/StatementContext.java | 11 +
.../glue/translator/PhysicalPlanTranslator.java | 35 +-
.../doris/nereids/jobs/executor/Optimizer.java | 78 +-
.../doris/nereids/jobs/executor/Rewriter.java | 8 +-
.../doris/nereids/parser/LogicalPlanBuilder.java | 7 +-
.../post/PushDownFilterThroughProject.java | 2 +-
.../org/apache/doris/nereids/rules/RuleType.java | 2 +-
.../nereids/rules/analysis/BindExpression.java | 23 +-
.../rules/analysis/DatetimeFunctionBinder.java | 5 +-
.../rules/analysis/WindowFunctionChecker.java | 28 +-
.../mv/AbstractMaterializedViewRule.java | 171 +++-
.../expression/rules/FoldConstantRuleOnBE.java | 4 +-
.../rules/InPredicateExtractNonConstant.java | 2 +-
.../expression/rules/PushIntoCaseWhenBranch.java | 4 +-
.../expression/rules/SimplifyInPredicate.java | 11 +-
.../LogicalOlapScanToPhysicalOlapScan.java | 12 +-
.../rewrite/AccessPathExpressionCollector.java | 19 +
...n.java => AddProjectForVolatileExpression.java} | 58 +-
.../doris/nereids/rules/rewrite/CTEInliner.java | 86 +-
.../CheckAndStandardizeWindowFunctionAndFrame.java | 5 +-
.../nereids/rules/rewrite/ClearContextStatus.java | 5 +-
.../rules/rewrite/CollectFilterAboveConsumer.java | 2 +-
.../rules/rewrite/DistinctAggregateRewriter.java | 115 +++
.../rules/rewrite/JoinExtractOrFromCaseWhen.java | 2 +-
.../rewrite/MergeOneRowRelationIntoUnion.java | 6 +-
.../nereids/rules/rewrite/NestedColumnPruning.java | 299 +++++-
.../rewrite/PushDownFilterThroughAggregation.java | 2 +-
.../rewrite/PushDownFilterThroughGenerate.java | 2 +-
.../rules/rewrite/PushDownFilterThroughJoin.java | 4 +-
.../rewrite/PushDownFilterThroughProject.java | 2 +-
.../PushDownVirtualColumnsIntoOlapScan.java | 2 +-
.../rules/rewrite/PushFilterInsideJoin.java | 2 +-
.../rules/rewrite/PushProjectIntoUnion.java | 2 +-
.../doris/nereids/rules/rewrite/ReorderJoin.java | 4 +-
.../nereids/rules/rewrite/SetPreAggStatus.java | 1 +
.../rewrite/eageraggregation/EagerAggRewriter.java | 2 +-
.../trees/expressions/ArrayItemReference.java | 3 +-
.../nereids/trees/expressions/Expression.java | 5 -
.../trees/expressions/VolatileExpression.java | 25 +-
.../trees/expressions/VolatileIdentity.java | 90 ++
.../functions/AggCombinerFunctionBuilder.java | 3 +-
.../functions/ComputeSignatureHelper.java | 2 +-
.../expressions/functions/ExpressionTrait.java | 15 +-
.../trees/expressions/functions/agg/TopN.java | 14 +
.../trees/expressions/functions/agg/TopNArray.java | 14 +
.../expressions/functions/agg/TopNWeighted.java | 14 +
.../functions/combinator/ForEachCombinator.java | 2 +-
.../expressions/functions/scalar/ArrayMap.java | 2 +-
.../expressions/functions/scalar/ArraySort.java | 4 +-
.../trees/expressions/functions/scalar/Random.java | 27 +-
.../expressions/functions/scalar/RandomBytes.java | 11 +-
.../functions/scalar/UniqueFunction.java | 56 +-
.../functions/scalar/UniqueFunctionParams.java | 17 +-
.../trees/expressions/functions/scalar/Uuid.java | 11 +-
.../expressions/functions/scalar/UuidNumeric.java | 11 +-
.../trees/expressions/functions/table/Binlog.java | 57 ++
.../trees/expressions/functions/udf/AliasUdf.java | 17 +-
.../trees/expressions/functions/udf/JavaUdf.java | 65 +-
.../expressions/functions/udf/JavaUdfBuilder.java | 2 +-
.../trees/expressions/functions/udf/PythonUdf.java | 65 +-
.../functions/udf/PythonUdfBuilder.java | 4 +-
.../trees/expressions/literal/Interval.java | 1 +
.../trees/expressions/literal/JsonLiteral.java | 39 +-
.../visitor/TableValuedFunctionVisitor.java | 5 +
.../plans/commands/CreateFunctionCommand.java | 42 +-
.../trees/plans/commands/ShowFunctionsCommand.java | 11 +-
.../trees/plans/commands/ShowTabletIdCommand.java | 7 -
.../plans/commands/info/AlterMTMVRenameInfo.java | 15 +-
.../trees/plans/logical/LogicalAggregate.java | 4 +-
.../trees/plans/logical/LogicalLoadProject.java | 2 +-
.../trees/plans/logical/LogicalProject.java | 2 +-
.../trees/plans/logical/LogicalSubQueryAlias.java | 7 +-
.../physical/PhysicalBucketedHashAggregate.java | 4 +-
.../plans/physical/PhysicalHashAggregate.java | 4 +-
.../org/apache/doris/nereids/types/ArrayType.java | 28 +-
.../org/apache/doris/nereids/types/DataType.java | 4 +-
.../apache/doris/nereids/util/ExpressionUtils.java | 17 +-
.../org/apache/doris/nereids/util/PlanUtils.java | 2 +-
.../doris/nereids/util/TypeCoercionUtils.java | 3 +-
.../java/org/apache/doris/nereids/util/Utils.java | 16 +
.../apache/doris/planner/NestedLoopJoinNode.java | 51 +
.../org/apache/doris/planner/OlapScanNode.java | 33 +-
.../org/apache/doris/planner/OlapTableSink.java | 17 +
.../java/org/apache/doris/qe/SessionVariable.java | 2 +-
.../java/org/apache/doris/qe/StmtExecutor.java | 1 -
.../apache/doris/statistics/BaseAnalysisTask.java | 25 +-
.../doris/statistics/ExternalAnalysisTask.java | 6 +-
.../apache/doris/statistics/OlapAnalysisTask.java | 6 +-
.../java/org/apache/doris/system/Diagnoser.java | 22 +-
.../doris/tablefunction/TableBinlogFunction.java | 211 ++++
.../doris/tablefunction/TableValuedFunctionIf.java | 2 +
.../apache/doris/task/AgentTaskCleanupDaemon.java | 2 +-
.../org/apache/doris/task/PublishVersionTask.java | 7 +-
.../doris/transaction/DatabaseTransactionMgr.java | 6 +-
.../doris/alter/SchemaChangeHandlerTest.java | 12 +
.../apache/doris/catalog/CreateFunctionTest.java | 23 +
.../org/apache/doris/catalog/CreateTableTest.java | 23 +-
.../org/apache/doris/catalog/CreateViewTest.java | 24 +
.../doris/catalog/FunctionToSqlConverterTest.java | 136 ++-
.../java/org/apache/doris/catalog/TypeTest.java | 6 +-
.../doris/clone/TabletReplicaTooSlowTest.java | 97 ++
.../common/proc/CloudProcVersionDisplayTest.java | 200 ++++
.../iceberg/IcebergExternalTableTest.java | 160 ++-
.../JdbcSourceOffsetProviderAsyncSplitTest.java | 486 +++++++++
.../doris/job/offset/jdbc/SplitProgressTest.java | 60 ++
.../java/org/apache/doris/mtmv/AlterMTMVTest.java | 29 +-
.../doris/mysql/MysqlSerializerVarbinaryTest.java | 30 +
.../rules/analysis/DatetimeFunctionBinderTest.java | 10 +
.../exploration/mv/NullRejectInferenceTest.java | 120 ++-
.../rules/expression/SimplifyInPredicateTest.java | 62 +-
...va => AddProjectForVolatileExpressionTest.java} | 43 +-
.../doris/nereids/rules/rewrite/CTEInlineTest.java | 38 +
.../rewrite/CollectFilterAboveConsumerTest.java | 2 +-
.../rewrite/DistinctAggregateRewriterTest.java | 224 +++-
.../rules/rewrite/PruneNestedColumnTest.java | 114 ++-
.../nereids/trees/expressions/LiteralTest.java | 12 +-
.../doris/nereids/trees/expressions/UdfTest.java | 31 +
.../functions/scalar/UniqueFunctionTest.java | 2 +-
.../functions/udf/UdfVolatilityTest.java | 91 ++
.../trees/expressions/literal/JsonLiteralTest.java | 124 +++
.../plans/commands/ShowFunctionsCommandTest.java | 50 +
.../plans/commands/ShowTabletIdCommandTest.java | 4 +-
.../doris/statistics/HMSAnalysisTaskTest.java | 72 +-
.../doris/statistics/OlapAnalysisTaskTest.java | 122 ++-
.../apache/doris/task/PublishVersionTaskTest.java | 109 ++
.../CheckReplicaContinuousVersionSuccTest.java | 177 ++++
.../filesystem/properties/BackendStorageKind.java} | 44 +-
.../properties/BackendStorageProperties.java | 43 +
.../properties/FileSystemProperties.java | 92 ++
.../properties/HadoopStorageProperties.java} | 36 +-
.../S3CompatibleFileSystemProperties.java | 80 ++
.../doris/filesystem/properties/StorageKind.java} | 39 +-
.../doris/filesystem/cos/CosObjStorageTest.java | 9 +-
.../doris/filesystem/obs/ObsObjStorageTest.java | 2 +
.../doris/filesystem/oss/OssObjStorageTest.java | 1 +
fe/fe-filesystem/fe-filesystem-s3/pom.xml | 17 +
.../s3/S3CredentialsProviderFactory.java | 201 ++++
.../filesystem/s3/S3CredentialsProviderType.java | 70 ++
.../apache/doris/filesystem/s3/S3FileSystem.java | 17 +
.../filesystem/s3/S3FileSystemProperties.java | 398 ++++++++
.../doris/filesystem/s3/S3FileSystemProvider.java | 69 +-
.../apache/doris/filesystem/s3/S3ObjStorage.java | 195 +---
.../s3/S3CredentialsProviderFactoryTest.java | 103 ++
.../filesystem/s3/S3FileSystemPropertiesTest.java | 245 +++++
.../filesystem/s3/S3FileSystemProviderTest.java | 73 ++
.../doris/filesystem/s3/S3ObjStorageMockTest.java | 82 +-
.../doris/filesystem/s3/S3ObjStorageTest.java | 156 +--
.../doris/filesystem/s3/S3OutputStreamTest.java | 4 +-
.../doris/filesystem/spi/FileSystemProvider.java | 23 +
.../java/org/apache/doris/catalog/ArrayType.java | 57 +-
.../org/apache/doris/catalog/PrimitiveType.java | 5 +-
.../source/reader/JdbcIncrementalSourceReader.java | 216 ++--
.../source/reader/mysql/MySqlSourceReader.java | 212 ++--
gensrc/proto/descriptors.proto | 2 +
gensrc/proto/olap_file.proto | 17 +-
gensrc/thrift/BackendService.thrift | 1 +
gensrc/thrift/Descriptors.thrift | 2 +
gensrc/thrift/FrontendService.thrift | 23 +
gensrc/thrift/HeartbeatService.thrift | 1 +
gensrc/thrift/PlanNodes.thrift | 7 +
gensrc/thrift/Types.thrift | 1 +
.../timestamptz/test_cast_timestamptz.out | 4 +-
.../timestamptz/test_timestamptz_cast.out | 12 +-
.../sql-functions/doc_date_functions_test.out | 48 +-
.../sql/presto/scalar/TestJsonFunctions.out | 16 +-
.../paimon/test_paimon_catalog_timestamp_tz.out | 12 +-
...doris_25531_string_overflow_fault_injection.out | 7 +
.../agg_skew_rewrite/agg_skew_rewrite.out | 6 +-
.../nereids_rules_p0/agg_strategy/agg_strategy.out | 22 +-
.../bind_relation/bind_view_alias_star_agg.out | 3 +
.../column_pruning/null_column_pruning.out | 6 +
.../string_length_column_pruning.out | 9 +
.../distinct_split/disitinct_split.out | 57 +-
.../unique_function/agg_with_unique_function.out | 8 +-
...tampdiff.out => test_simplify_in_predicate.out} | 16 +-
.../data/nereids_syntax_p0/test_timestampdiff.out | 6 +
.../query_p0/repeat/test_repeat_output_slot.out | 28 +-
.../test_json_contains_numeric_equality.out | 3 +
.../query_p0/system/test_query_sys_rowsets.out | 3 +-
.../system/test_query_sys_scan_rowsets.out | 3 +-
.../data/query_p0/test_parquet_dict.out | 4 +
.../data/row_binlog_p0/test_row_binlog_basic.out | 53 +
.../test_row_binlog_multi_segment.out | 36 +
.../test_row_binlog_publish_conflict.out | 40 +
.../test_row_binlog_schema_change.out | 20 +
.../data/shape_check/clickbench/query10.out | 11 +-
.../data/shape_check/clickbench/query11.out | 7 +-
.../data/shape_check/clickbench/query12.out | 7 +-
.../data/shape_check/clickbench/query14.out | 7 +-
.../data/shape_check/clickbench/query23.out | 7 +-
.../data/shape_check/clickbench/query9.out | 5 +-
.../pipeline/nonConcurrent/conf/fe.conf | 2 +
.../test_timestamptz_jdbc_binary_protocol.groovy | 85 ++
.../hive/test_orc_lazy_mat_profile.groovy | 1 +
.../tvf/test_hdfs_parquet_group0.groovy | 4 +-
.../iceberg_rest_on_hdfs.groovy | 4 +-
...is_25531_string_overflow_fault_injection.groovy | 62 ++
.../test_publish_no_npe_when_be_down.groovy | 142 +++
.../suites/javaudf_p0/test_javaudf_float.groovy | 3 +-
.../test_streaming_mysql_job_async_split.groovy | 160 +++
...t_streaming_mysql_job_async_split_uneven.groovy | 195 ++++
...ing_postgres_job_async_split_multi_table.groovy | 178 ++++
...ng_postgres_job_async_split_pause_resume.groovy | 172 ++++
...treaming_postgres_job_async_split_uneven.groovy | 198 ++++
...stgres_job_async_split_uneven_restart_fe.groovy | 207 ++++
...streaming_postgres_job_binlog_restart_fe.groovy | 191 ++++
...st_streaming_postgres_job_special_offset.groovy | 15 +-
...ming_job_cdc_stream_postgres_async_split.groovy | 193 ++++
...c_stream_postgres_async_split_restart_fe.groovy | 218 ++++
.../jsonb_p0/test_jsonb_keys_invalid_path.groovy | 30 +-
.../suites/mtmv_p0/test_expand_star_mtmv.groovy | 3 +-
.../suites/mv_p0/ssb/q_4_1_r1/q_4_1_r1.groovy | 14 +-
.../agg_function/topn/topn.groovy | 32 +
.../nereids_function_p0/scalar_function/U.groovy | 2 +
.../bind_relation/bind_view_alias_star_agg.groovy | 46 +
.../column_pruning/null_column_pruning.groovy | 67 +-
.../string_length_column_pruning.groovy | 72 +-
.../distinct_split/disitinct_split.groovy | 1 +
.../mv/dimension/dimension_self_conn.groovy | 5 +-
.../inner_join_null_reject_compensation.groovy | 217 ++++
.../partition_curd_union_rewrite.groovy | 30 +-
.../predicate_infer/infer_predicate.groovy | 36 +
.../nereids_rules_p0/set_preagg/set_preagg.groovy | 25 +-
.../test_simplify_in_predicate.groovy | 28 +
.../nereids_syntax_p0/test_timestampdiff.groovy | 28 +
.../pythonudf_p0/test_pythonudf_aggregate.groovy | 6 +-
.../pythonudf_p0/test_pythonudf_float.groovy | 3 +-
.../pythonudf_p0/test_pythonudf_volatility.groovy | 204 ++++
.../query_p0/cte/test_cbo_cte_inline_prune.groovy | 113 +++
.../test_nestedloop_lazy_materialization.groovy | 256 +++++
.../test_json_contains_numeric_equality.groovy | 32 +-
.../suites/query_p0/test_parquet_dict.groovy | 32 +-
.../row_binlog_p0/test_row_binlog_basic.groovy | 264 +++++
.../test_row_binlog_multi_segment.groovy | 239 +++++
.../test_row_binlog_publish_conflict.groovy | 303 ++++++
.../test_row_binlog_schema_change.groovy | 110 ++
.../suites/show_p0/test_show_tablet.groovy | 8 +-
.../statistics/test_full_analyze_hot_value.groovy | 166 +++
.../suites/statistics/test_hot_value.groovy | 20 +-
regression-test/suites/tso_p0/test_tso_api.groovy | 169 ++--
.../tso_p0/test_tso_rowset_commit_tso.groovy | 70 +-
threat-model.md | 806 +++++++++++++++
508 files changed, 21183 insertions(+), 4307 deletions(-)
delete mode 100644 be/src/core/value/map_value.h
delete mode 100644 be/src/core/value/struct_value.h
delete mode 100644 be/src/runtime/collection_value.h
delete mode 100644 be/src/storage/field.h
create mode 100644 be/src/storage/segment/historical_row_retriever.cpp
create mode 100644 be/src/storage/segment/historical_row_retriever.h
create mode 100644 be/src/storage/segment/row_binlog_segment_writer.cpp
create mode 100644 be/src/storage/segment/row_binlog_segment_writer.h
create mode 100644
be/test/exprs/aggregate/aggregate_function_exception_test.cpp
create mode 100644 be/test/olap/rowset/group_rowset_writer_test.cpp
create mode 100644 be/test/util/jsonb_contains_test.cpp
create mode 100644 be/test/util/test_data/block_to_jsonb_all_types_golden.bin
copy fe/{fe-core/src/main/java/org/apache/doris/catalog/FunctionGenTable.java
=> fe-catalog/src/main/java/org/apache/doris/catalog/FunctionVolatility.java}
(54%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/common/proc/ProcReplicaVersionDisplay.java
rename
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/{AddProjectForUniqueFunction.java
=> AddProjectForVolatileExpression.java} (84%)
copy be/src/runtime/collection_value.cpp =>
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/VolatileExpression.java
(61%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/VolatileIdentity.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/table/Binlog.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/tablefunction/TableBinlogFunction.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/common/proc/CloudProcVersionDisplayTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/job/offset/jdbc/JdbcSourceOffsetProviderAsyncSplitTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/job/offset/jdbc/SplitProgressTest.java
rename
fe/fe-core/src/test/java/org/apache/doris/nereids/rules/rewrite/{AddProjectForUniqueFunctionTest.java
=> AddProjectForVolatileExpressionTest.java} (78%)
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/expressions/functions/udf/UdfVolatilityTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/expressions/literal/JsonLiteralTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/task/PublishVersionTaskTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/transaction/CheckReplicaContinuousVersionSuccTest.java
copy
fe/{fe-core/src/main/java/org/apache/doris/catalog/RowBinlogTableWrapper.java
=>
fe-filesystem/fe-filesystem-api/src/main/java/org/apache/doris/filesystem/properties/BackendStorageKind.java}
(50%)
create mode 100644
fe/fe-filesystem/fe-filesystem-api/src/main/java/org/apache/doris/filesystem/properties/BackendStorageProperties.java
create mode 100644
fe/fe-filesystem/fe-filesystem-api/src/main/java/org/apache/doris/filesystem/properties/FileSystemProperties.java
copy
fe/{fe-common/src/main/java/org/apache/doris/job/cdc/request/FetchTableSplitsRequest.java
=>
fe-filesystem/fe-filesystem-api/src/main/java/org/apache/doris/filesystem/properties/HadoopStorageProperties.java}
(51%)
create mode 100644
fe/fe-filesystem/fe-filesystem-api/src/main/java/org/apache/doris/filesystem/properties/S3CompatibleFileSystemProperties.java
copy fe/{fe-core/src/main/java/org/apache/doris/catalog/FunctionGenTable.java
=>
fe-filesystem/fe-filesystem-api/src/main/java/org/apache/doris/filesystem/properties/StorageKind.java}
(60%)
create mode 100644
fe/fe-filesystem/fe-filesystem-s3/src/main/java/org/apache/doris/filesystem/s3/S3CredentialsProviderFactory.java
create mode 100644
fe/fe-filesystem/fe-filesystem-s3/src/main/java/org/apache/doris/filesystem/s3/S3CredentialsProviderType.java
create mode 100644
fe/fe-filesystem/fe-filesystem-s3/src/main/java/org/apache/doris/filesystem/s3/S3FileSystemProperties.java
create mode 100644
fe/fe-filesystem/fe-filesystem-s3/src/test/java/org/apache/doris/filesystem/s3/S3CredentialsProviderFactoryTest.java
create mode 100644
fe/fe-filesystem/fe-filesystem-s3/src/test/java/org/apache/doris/filesystem/s3/S3FileSystemPropertiesTest.java
create mode 100644
regression-test/data/fault_injection_p0/test_doris_25531_string_overflow_fault_injection.out
create mode 100644
regression-test/data/nereids_rules_p0/bind_relation/bind_view_alias_star_agg.out
copy regression-test/data/nereids_syntax_p0/{test_timestampdiff.out =>
test_simplify_in_predicate.out} (51%)
create mode 100644
regression-test/data/query_p0/sql_functions/json_functions/test_json_contains_numeric_equality.out
create mode 100644 regression-test/data/query_p0/test_parquet_dict.out
create mode 100644 regression-test/data/row_binlog_p0/test_row_binlog_basic.out
create mode 100644
regression-test/data/row_binlog_p0/test_row_binlog_multi_segment.out
create mode 100644
regression-test/data/row_binlog_p0/test_row_binlog_publish_conflict.out
create mode 100644
regression-test/data/row_binlog_p0/test_row_binlog_schema_change.out
create mode 100644
regression-test/suites/datatype_p0/timestamptz/test_timestamptz_jdbc_binary_protocol.groovy
rename regression-test/suites/{external_table_p0/refactor_storage_param =>
external_table_p2/refactor_catalog_param}/iceberg_rest_on_hdfs.groovy (99%)
create mode 100644
regression-test/suites/fault_injection_p0/test_doris_25531_string_overflow_fault_injection.groovy
create mode 100644
regression-test/suites/fault_injection_p0/test_publish_no_npe_when_be_down.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/test_streaming_mysql_job_async_split.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/test_streaming_mysql_job_async_split_uneven.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/test_streaming_postgres_job_async_split_multi_table.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/test_streaming_postgres_job_async_split_pause_resume.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/test_streaming_postgres_job_async_split_uneven.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/test_streaming_postgres_job_async_split_uneven_restart_fe.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/test_streaming_postgres_job_binlog_restart_fe.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/tvf/test_streaming_job_cdc_stream_postgres_async_split.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/tvf/test_streaming_job_cdc_stream_postgres_async_split_restart_fe.groovy
copy fe/fe-core/src/main/java/org/apache/doris/catalog/FunctionGenTable.java
=> regression-test/suites/jsonb_p0/test_jsonb_keys_invalid_path.groovy (59%)
create mode 100644
regression-test/suites/nereids_rules_p0/bind_relation/bind_view_alias_star_agg.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/mv/join_infer_derive/inner_join_null_reject_compensation.groovy
create mode 100644
regression-test/suites/pythonudf_p0/test_pythonudf_volatility.groovy
create mode 100644
regression-test/suites/query_p0/cte/test_cbo_cte_inline_prune.groovy
create mode 100644
regression-test/suites/query_p0/join/test_nestedloop_lazy_materialization.groovy
rename be/src/runtime/collection_value.cpp =>
regression-test/suites/query_p0/sql_functions/json_functions/test_json_contains_numeric_equality.groovy
(61%)
copy fe/fe-core/src/main/java/org/apache/doris/catalog/FunctionGenTable.java
=> regression-test/suites/query_p0/test_parquet_dict.groovy (60%)
create mode 100644
regression-test/suites/row_binlog_p0/test_row_binlog_basic.groovy
create mode 100644
regression-test/suites/row_binlog_p0/test_row_binlog_multi_segment.groovy
create mode 100644
regression-test/suites/row_binlog_p0/test_row_binlog_publish_conflict.groovy
create mode 100644
regression-test/suites/row_binlog_p0/test_row_binlog_schema_change.groovy
create mode 100644
regression-test/suites/statistics/test_full_analyze_hot_value.groovy
create mode 100644 threat-model.md
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
