This is an automated email from the ASF dual-hosted git repository.
lijibing pushed a change to branch high-priority-column
in repository https://gitbox.apache.org/repos/asf/doris.git
discard d877ab18590 Fix bug (#32454)
omit 2f8eb492d76 Support auto analyze mv (#32433)
omit e8b16d671c0 Unit test (#32398)
omit 6ad12223884 refactor2 (#32278)
omit 7bcec7100f9 Refactor. (#32273)
omit f74a4d07d83 support window (#32094)
omit c28bdc7fd75 Check column health value earlier, show job priority.
(#32064)
omit 8631bcafdc3 Support show auto analyze pending jobs. (#31926)
omit fe58392bd47 Support follower sync query columns to master. (#31859)
omit 6fc7aa15ad5 Support column level health value. (#31794)
omit a4cba9f4b7e High priority queue and map. (#31509)
omit 1bc42cd821a Collect high priority columns. (#31235)
add 1a7bb08e22d [Fix](regression test) Fix <=> rf cause regresion test
failed (#32377)
add 65e1087bab2 [enhancement](test)unique model by modify a value type
from SMALLINT to other type (#32348)
add 249e5959baa [pipelineX](cancel) Remove lock for mapping query ctx to
fragment (#32346)
add 0f38260673e [fix](compile) fix compile err in macOS (#32400)
add 40624cd3f08 [Chore](tools) update ssb tools (#32308)
add 449d9bc2d4f [fix](feut) comment out doc gen execution (#32413)
add 049596d49bb [pipelineX](streaming agg) Fix wrong columns produced by
streaming agg (#32411)
add 2d186565679 [chore](ci) fix script (#32420)
add af4b4227cdf [fix](planner)decimalv3 literal's precision and scale is
not correctly set (#32288)
add 3d4af5c12f2 [Fix](Variant) fix variant with not null (#32248)
add 001bca173b0 [fix](time_series) default value modify for compaction
(#32410)
add 58278663cca [fix](cloud) fix create table fail without be (#32372)
add cc4893fc160 (cloud) Fix missing disk and cpu report in cloud mode
(#32424)
add 1fffd330792 [FIX](array_agg) fix array agg with other agg function
(#32387)
add 4e7eee8e670 [fix](compile) Fix links failure when use gcc to compile
(#32447)
add cee8473efbd [Fix](Regression) DCHECK failed in runtime filter wrapper
(#32446)
add a444cef5723 [opt](hive) skip hidden file and dir (#32412)
add b01f95abcc8 [Performance](join) speed up the colocate and bucket
shuffle join by change rf size (#32421)
add 0dbe63aa476 do not auto resume if job cannot resume definitely (#32419)
add 142ed954098 fix routine load regression test fail (#32406)
add ef03984169c [opt](like) opt LIKE and REGEXP clause with concat(col,
pattern_str) (#32333)
add a2df10e7867 [Fix](smooth-upgrade) Fix incompatibility when upgrade
from 2.0 to 2.1 (#32444)
add b1898e08a26 [fix](regression) prepare_insert failed when connect to
observer fe (#32223)
add b989ea1e839 [improve](group commit) Group commit support chunked
stream load in flink (#32135)
add 8293368a83b [fix](group commit) Fix p2 regression-test (#32270)
add 3507274d0d6 [refactor](executor)Delete cpu_resource_limit (#32388)
add 62f5ed2394a [Fix](Job)When jobname is the do keyword, parsing errors
will occur when executing SQL. (#32379)
add d991bcf60ae [fix](ParquetReader) Fix Parquet Reader to read `int96`
parquet type problem (#32394)
add 8c117550287 [fix](nereids)support topn-filter for non pipeline engine
#32397
add 4ea31a3dfea [pipelineX](api) Add api for long-running tasks (#32459)
add 8bd805e50db [fix](decimal) fix Arithmetic Overflow error of converting
string to decimal (#32246)
add d468c68d487 [fix](group commit) Fix group commit connect to observer
fe (#32222)
add 40f48a33ff4 [fix](filecache) fix insufficient inode checking (#32494)
add e54210be284 [improvement](hint) update clone hint (#32466)
add ddd3d384e68 [fix](group commit) Fix invalid function problem on p2
regression-test (#32481)
add 4599c4e474c [fix](group commit) Fix compatibility issues on
serializing and deserializing wal file (#32299)
add e096ff89bf4 [fix](broker load) improve the checking of overlapping
partitions of same table (#32254)
add 4f87091d681 [fix](schema-change) fix the bug of handling empty blocks
in schema change (#32460)
add deb95f4e0b0 [fix](cloud-partialupdate)Fix wrong rowset state in
partial update (#32257)
add 783c6171dc5 [improvement](agg) streaming agg should not take too much
memory when spilling enabled (#32426)
add 5571b1f93fb [improvement](spill) optimize the spilling logic of hash
join operator (#32202)
add 1835a8c9bb8 [fix](snapshot-loader) Fix be crash caused by deref end()
iterator (#32489)
add 712f9051cf0 [feature](hive)Get updated information from coordinate and
commit (#32441)
add 6a0c5a1ae93 [fix][regression]update ccr test project (#32445)
add 62ded7882fa [Fix](inverted index) fix inappropriate use of macro in
inverted index fs directory error process (#32472)
add 1d97305f491 [Fix](Variant) Initialize original_tablet_schema in
_expand_variant_to_subcolumns to address potential nullptr issue (#32184)
add 586a504f5ce [Enhencement](Nereids) add eliminate distinct constant
rule (#32307)
add 09c0328870d [case](mtmv)MTMV external catalog case (#32390)
add 406cbcdacce [test](neredis) Add tpch test for query rewrite by
materialized view (#30870)
add a0d255d951e [fix](stats) sort partitions when do sample analyze
(#32185)
add 47387a2a2eb [chor](log) Change log4j rollover strategy to 'max'
(#32116)
add 37d4ec42696 [Chore](build) fix compile failed on
SegmentFlusher::_expand_variant_to_subcolumns (#32505)
add 81c8b7fec93 [fix](nereids)NullSafeEqualToEqual rule only change to
equal if both children are not nullable (#32374)
add 340b41c1b08 [Feature](partition) Support insert overwrite auto detect
partition (#32156)
add da09c3fdbd4 [opt](routine-load) self-adaption backoff timeout (#32227)
add e7d2b382339 [opt](routine-load) optimize allocate task to be algorithm
for load balance (#32021)
add 913ff364b9e [regression-test](case) forbid
test_stream_stub_fault_injection (#32540)
add 002adfbc091 [code](Refactor) Del unless filter id in runtime filter
func (#32502)
add d4cde6f773e [fix](merge-cloud) fix load return invalid tablet state
when MoW table under alter (#32500)
add 6011870e08f [feature](function) Support for aggregate function foreach
combiner for some error function (#31913)
add d1e7edabd8d [fix](Nereids) decimalv2 and int/date bit arithmetic need
cast to bigint (#32311)
add 335a3fe9cfb [opt](variable) user variable support expression rather
than literal (#32492)
add 36c8b59607a [feature](cpu cores) get the cores when running within a
cgroup. (#32370)
add 7f2fda8ad94 [expr](fix) Not to throw exception when close failed
(#32287)
add d0c55802d2d [pipelineX](fix) Fix running tasks API core dump (#32503)
add 4732997c6db [fix](random-bucket) tabletindex when there is no cached
value in memory (#32336)
add 021f80ce73d [improvement](group_comit) Add bvar to monitor the total
wal count on disk (#31646)
add c391474b94d [fix](cloud) Fix dcheck failure in
CloudTablet::create_transient_rowset_writer (#32542)
add 9f2e16c70e9 [Feature] Support Array Type compare function for nereids
planner (#31701)
add b8485fab010 [Bug] Stop incorrectly of reportwork cause heap use after
free (#32205)
add 77e55bc7496 [feature][insert]Adapt the create table statement to the
nereids sql (#32458)
add f8aa1bef470 [improve](function) add error msg if exceeded maximum
default value in repeat function (#32219)
add a0cef461d3e [feature](merge-cloud) Support specify meta service
endpoints separated by comma (#32230)
add 794becba9f0 [fix](merge-cloud) Fix CloudPartition.getVisibleVersion
return value (#32479)
add 5a93fa9ee86 [Enhancement] when partition column is datetime, date can
work in create table command (#32335)
add 97a7b8382d7 (cloud-merge) Fix filecache coredump because the
fileWriterMapKey is not unique (#32559)
add 3b6464fe23e [fix](merge-cloud) Add retry when create tablet meet kv
conflict in cloud mode (#32267)
add 26cda65ddb3 [fix](jdbc catalog) Fixed the problem that the
metadata_refresh_interval_sec properties cannot be set (#32516)
add 3eb2eba42ab [enhance](S3) Print the oss request id for each error s3
request (#32499)
add 16149ae4e91 [case](Cloud) Add ssb case for hdfs vault (#32567)
add 89048051c0d [enhance](S3) Print the oss request id for each error s3
request (#32491)
add f70dfc64316 [fix](cloud) fix dead cloud cluster status empty (#32471)
add 52a8e6681a2 [pipelineX](debug) Add debug logs for long-running load
task (#32534)
add ac2bd437174 [fix](partition) Fix be tablet partition id eq 0 By report
tablet (#32179)
add f4145576f28 [Fix](Variant) fix variant serialize root node (#31769)
add 58037aa4eda [enhancement](test) unique model by modify a key type from
SMALLINT to other type (#32033)
add 4fe846bc2ac [refactor](jdbc catalog) refactor jdbc catalog get
databases logic (#32579)
add 1e35ebb7581 [enhancement](test) unique model by modify a value type
from INT or BIGINT to other type (#32553)
add 3e947dd1a88 [fix](test)change stream load of auto partition (#32544)
add dc714edc072 [enhancement](mow) Add bvar for bloom filter and segment
(#32355)
add fd5e41057df [Fix](auto-inc) Fix auto inc unique table case (#32393)
add f837109a2e5 [fix](spill) should wait for merging done before read agg
result (#32537)
add 5fcc563c41d [Fix](executor) Fix insert select not close coordinator
#32571
add 35870e97f05 [pipelineX](fix) Fix illegal memory access (#32602)
add cc21052b9ec [opt](information_schema) Add DEFAULT_ENCRYPTION column to
schemata table (#32501)
add ad496ea7dd1 Improve analyze stats case, avoid cluster delay caused
failure. (#32507)
add f409a45d0ba [fix](mtmv)resolve the issue of table version updates in
concurrent situations (#32487)
add ad815f08e0d [fix](auth)node priv can login web ui (#32521)
add 09e584521c3 [Fix](Outfile) Fix the column type mapping in the
orc/parquet file format (#32281)
add 4de86fe460c [FIX](compile)fix for gcc compile (#32508)
add f21a847bbe1 Add
DISABLE_BUILD_UI/DISABLE_BUILD_SPARK_DPP/DISABLE_BUILD_HIVE_UDF in build.sh
(#32595)
add 42dca5e5189 [enhance](mtmv)refresh mtmv must add auto (#32522)
add 0f693a1515d [opt](jdbc catalog) set jdbc test_connection default true
(#32546)
add 3483f525444 [opt](paimon) add split num and partition num (#32597)
add 40a4e6078d5 [test](Nereids) refine group by eliminate regression test
(#32543)
add 55519965281 [fix](inverted index) skip read index column data only for
DUP and MOW table (#32594)
add b32f9642765 [feature](merge-cloud) Optimize TabletStatMgr
initialization (#32585)
add 6d7122a1f21 [Fix](cloud) fix cloud inverted index case and writer
searcher cache (#32564)
add 1273e9577ff [opt](invert index) use lowercase by default (#32405)
add d4d619f45f7 [fix](merge-cloud) Set visible version for OlapScanNode at
the plan phase (#32473)
add bcef00df389 [fix](partial update) fix data correctness risk when load
delete sign data into a table with sequence col (#32574)
add 168f4f2e113 [Improvement](brpc) log error message when
AutoReleaseClosure meet brpc error or response… (#32628)
add 3a90e26300d [bugfix](deadlock) pipelinex map lock should only scope in
map not about pipelinectx's cancel method (#32622)
add 120da7d6f1e [fix](kerberos)fix hive keberos principal usage (#32609)
add 48895b0891b [enhancement](test) exclude somecases not support in cloud
mode (#32108)
add 801f0ef3992 [fix](backup) clear snapshot info for cancelled backup job
to reduce log size (#32604)
add 425cb6b66c3 [enhance](fs) Eliminate the reference of
FileReader/FileWriter to FS (#31716)
add b3e397fef22 [fix](memory) Fix thread context not initialized in MacOS
(#32570)
add 4127f452c49 [fix](join) core caused by null-safe-equal join (#32623)
add 22c59ef359f [feature](cloud) Add one http action for Meta Service to
drop storage vault (#32603)
add 526971f0780 [fix](merge-cloud) fix full_compaction case adapts to
cloud mode (#32298)
add 8e93989d460 [feature](doris compose) set up local test multi clusters
(#32626)
add 6b8e329a8bd [chore](hint) update group commit plan fail hint (#32584)
add 9911303ab67 [refactor](nereids)unify outputTupleDesc and projection be
part (#32439)
add 7e42feef926 [fix](join) the result of left semi join with empty right
side should be false, not null (#32477)
add 42c48e17fcc [chore](ci) gcore when timeout in cloud_p* (#32631)
add fae5f3e6cd0 [fix](Nereids): just pull up alias project above join
through topn (#32305)
add 432a104b3cd [pipelineX](refactor) Wait for 2-phase execution before
opening (#32613)
add a1fa7f5fafd [fix](nereids)str_to_date function's signature for folding
constant is wrong (#32474)
add 9f8cd396ae6 [chore](Nereids) remove ensure project on top join (#32562)
add 512396e1181 [feat](Nereids): add is null predicate for the first
partition when updating mv by partition (#32463)
add 4d7be8627c0 [feat](Nereids): rewrite sum literal to sum and count
(#32244)
add e141128e141 [fix](restore) fix restore odbc resource bug (#31989)
add e4e8fe80a24 [fix](Nereids) filter-limit-project translate to wrong
plan (#32496)
add d584532afda [opt](parquet) Support hive struct schema change (#32438)
add b0b1f2285de [fix](insert)fix hive table sink write path (#32587)
add 1fc91a36cf0 [fix](jdbc catalog) Fix query errors without jdbc pool
default value on only BE upgrade (#32618)
add 2bfe3aa0099 [feature](Nereids) support data masking policy (#32526)
add 04812b0538c [fix](backup) clear snapshotInfos and backupMeta when
cancel (#32646)
new 6ee8cbf9ff0 Collect high priority columns. (#31235)
new 6796bab835c High priority queue and map. (#31509)
new 36df41f6446 Support column level health value. (#31794)
new d86c393510a Support follower sync query columns to master. (#31859)
new 6a78fc05fa3 Support show auto analyze pending jobs. (#31926)
new 85fa24abd7e Check column health value earlier, show job priority.
(#32064)
new a7c2aa20877 support window (#32094)
new 714453b7a06 Refactor. (#32273)
new fb7d2988796 refactor2 (#32278)
new 5255c8f7343 Unit test (#32398)
new b136f85264d Support auto analyze mv (#32433)
new 856753e8968 Fix bug (#32454)
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (d877ab18590)
\
N -- N -- N refs/heads/high-priority-column (856753e8968)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
The 12 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
be/src/agent/agent_server.cpp | 10 +
be/src/agent/agent_server.h | 2 +
be/src/agent/task_worker_pool.cpp | 204 +-
be/src/agent/task_worker_pool.h | 2 +
be/src/cloud/cloud_backend_service.cpp | 4 +-
be/src/cloud/cloud_backend_service.h | 3 +-
be/src/cloud/cloud_meta_mgr.cpp | 94 +-
be/src/cloud/cloud_meta_mgr.h | 7 +-
be/src/cloud/cloud_rowset_builder.cpp | 7 +-
be/src/cloud/cloud_schema_change_job.cpp | 1 -
be/src/cloud/cloud_storage_engine.cpp | 86 +-
be/src/cloud/cloud_tablet.cpp | 8 +
be/src/cloud/config.h | 17 +
be/src/exec/exec_node.cpp | 26 +-
be/src/exec/exec_node.h | 4 +
.../schema_scanner/schema_schemata_scanner.cpp | 11 +
be/src/exec/tablet_info.cpp | 104 +-
be/src/exec/tablet_info.h | 25 +-
be/src/exprs/bloom_filter_func.h | 30 +-
be/src/exprs/runtime_filter.cpp | 29 +-
be/src/exprs/runtime_filter.h | 2 +
be/src/http/action/compaction_action.cpp | 36 +-
be/src/http/action/http_stream.cpp | 32 +-
be/src/http/action/pipeline_task_action.cpp | 18 +
be/src/http/action/pipeline_task_action.h | 9 +
be/src/http/action/stream_load.cpp | 31 +-
be/src/io/cache/block_file_cache.cpp | 15 +-
be/src/io/cache/block_file_cache.h | 6 +-
be/src/io/cache/block_file_cache_factory.cpp | 4 +
be/src/io/cache/cached_remote_file_reader.h | 2 -
be/src/io/cache/file_block.cpp | 8 +-
be/src/io/cache/fs_file_cache_storage.cpp | 8 +-
be/src/io/cache/fs_file_cache_storage.h | 16 +-
be/src/io/file_factory.cpp | 197 +-
be/src/io/file_factory.h | 65 +-
be/src/io/fs/benchmark/hdfs_benchmark.hpp | 28 +-
be/src/io/fs/benchmark/s3_benchmark.hpp | 17 +-
be/src/io/fs/broker_file_reader.cpp | 85 +-
be/src/io/fs/broker_file_reader.h | 9 +-
be/src/io/fs/broker_file_system.cpp | 112 +-
be/src/io/fs/broker_file_system.h | 18 +-
be/src/io/fs/broker_file_writer.cpp | 75 +-
be/src/io/fs/broker_file_writer.h | 27 +-
be/src/io/fs/buffered_reader.cpp | 68 +-
be/src/io/fs/buffered_reader.h | 13 +-
be/src/io/fs/err_utils.cpp | 13 +-
be/src/io/fs/file_handle_cache.cpp | 4 +-
be/src/io/fs/file_handle_cache.h | 4 -
be/src/io/fs/file_reader.cpp | 19 +-
be/src/io/fs/file_reader.h | 8 +-
be/src/io/fs/file_system.h | 51 +-
be/src/io/fs/file_writer.h | 42 +-
be/src/io/fs/hdfs_file_reader.cpp | 61 +-
be/src/io/fs/hdfs_file_reader.h | 21 +-
be/src/io/fs/hdfs_file_system.cpp | 248 +-
be/src/io/fs/hdfs_file_system.h | 88 +-
be/src/io/fs/hdfs_file_writer.cpp | 101 +-
be/src/io/fs/hdfs_file_writer.h | 38 +-
be/src/io/fs/local_file_reader.cpp | 11 +-
be/src/io/fs/local_file_reader.h | 14 +-
be/src/io/fs/local_file_system.cpp | 46 +-
be/src/io/fs/local_file_system.h | 11 +-
be/src/io/fs/local_file_writer.cpp | 22 +-
be/src/io/fs/local_file_writer.h | 13 +-
be/src/io/fs/remote_file_system.cpp | 24 +-
be/src/io/fs/remote_file_system.h | 25 +-
be/src/io/fs/s3_file_reader.cpp | 35 +-
be/src/io/fs/s3_file_reader.h | 18 +-
be/src/io/fs/s3_file_system.cpp | 284 +-
be/src/io/fs/s3_file_system.h | 71 +-
be/src/io/fs/s3_file_writer.cpp | 144 +-
be/src/io/fs/s3_file_writer.h | 15 +-
be/src/io/fs/stream_load_pipe.h | 2 -
be/src/io/fs/stream_sink_file_writer.cpp | 7 +-
be/src/io/fs/stream_sink_file_writer.h | 21 +-
be/src/io/hdfs_util.cpp | 143 +
be/src/io/hdfs_util.h | 129 +
be/src/olap/base_tablet.cpp | 46 +-
be/src/olap/base_tablet.h | 2 +
be/src/olap/cold_data_compaction.cpp | 19 +-
be/src/olap/compaction.cpp | 40 +-
be/src/olap/delta_writer_v2.cpp | 1 -
be/src/olap/inverted_index_parser.cpp | 9 -
be/src/olap/inverted_index_parser.h | 23 +-
be/src/olap/iterators.h | 1 +
be/src/olap/olap_server.cpp | 19 +-
be/src/olap/primary_key_index.cpp | 7 +
be/src/olap/primary_key_index.h | 10 +
be/src/olap/push_handler.cpp | 1 -
be/src/olap/rowset/beta_rowset_reader.cpp | 2 +
be/src/olap/rowset/beta_rowset_writer.cpp | 8 +-
be/src/olap/rowset/rowset.h | 4 -
be/src/olap/rowset/rowset_meta.cpp | 5 +
be/src/olap/rowset/segment_creator.cpp | 13 +-
be/src/olap/rowset/segment_v2/bloom_filter.h | 39 +-
.../segment_v2/bloom_filter_index_writer.cpp | 5 +
.../rowset/segment_v2/bloom_filter_index_writer.h | 9 +-
be/src/olap/rowset/segment_v2/column_reader.cpp | 9 +-
be/src/olap/rowset/segment_v2/column_reader.h | 1 +
.../rowset/segment_v2/inverted_index_file_reader.h | 4 +-
.../segment_v2/inverted_index_file_writer.cpp | 2 +
.../segment_v2/inverted_index_fs_directory.cpp | 56 +-
.../rowset/segment_v2/inverted_index_writer.cpp | 27 +-
be/src/olap/rowset/segment_v2/page_io.cpp | 6 +-
be/src/olap/rowset/segment_v2/segment.cpp | 10 +-
be/src/olap/rowset/segment_v2/segment.h | 1 +
be/src/olap/rowset/segment_v2/segment_iterator.cpp | 9 +-
be/src/olap/rowset/segment_v2/segment_writer.cpp | 20 +-
be/src/olap/rowset/segment_v2/segment_writer.h | 6 +-
.../rowset/segment_v2/vertical_segment_writer.cpp | 23 +-
.../rowset/segment_v2/vertical_segment_writer.h | 4 +-
be/src/olap/rowset/vertical_beta_rowset_writer.cpp | 3 +-
be/src/olap/rowset_builder.cpp | 2 +-
be/src/olap/schema_change.cpp | 15 +-
be/src/olap/storage_policy.cpp | 29 +-
be/src/olap/storage_policy.h | 8 +-
be/src/olap/tablet.cpp | 15 -
be/src/olap/tablet.h | 2 -
be/src/olap/tablet_manager.cpp | 20 +
be/src/olap/tablet_manager.h | 3 +
be/src/olap/tablet_meta.cpp | 4 +-
be/src/olap/tablet_schema.cpp | 8 +
be/src/olap/wal/wal_manager.cpp | 14 +-
be/src/olap/wal/wal_manager.h | 7 +-
be/src/olap/wal/wal_reader.cpp | 4 +-
be/src/olap/wal/wal_reader.h | 3 +-
be/src/olap/wal/wal_table.cpp | 5 +-
be/src/olap/wal/wal_writer.cpp | 4 +-
be/src/olap/wal/wal_writer.h | 2 +-
be/src/pipeline/exec/hashjoin_build_sink.cpp | 28 +-
be/src/pipeline/exec/hashjoin_build_sink.h | 3 +
be/src/pipeline/exec/hashjoin_probe_operator.cpp | 24 +
be/src/pipeline/exec/hashjoin_probe_operator.h | 4 +
be/src/pipeline/exec/join_probe_operator.cpp | 31 +-
be/src/pipeline/exec/join_probe_operator.h | 12 +-
.../exec/nested_loop_join_probe_operator.cpp | 7 +-
.../exec/nested_loop_join_probe_operator.h | 2 +-
.../partitioned_aggregation_source_operator.cpp | 6 +
.../exec/partitioned_hash_join_probe_operator.cpp | 86 +-
.../exec/partitioned_hash_join_probe_operator.h | 8 +
.../exec/partitioned_hash_join_sink_operator.cpp | 33 +-
.../exec/partitioned_hash_join_sink_operator.h | 6 +
.../exec/streaming_aggregation_operator.cpp | 139 +-
.../pipeline/exec/streaming_aggregation_operator.h | 5 +-
be/src/pipeline/exec/union_source_operator.cpp | 2 +-
be/src/pipeline/pipeline_fragment_context.cpp | 3 +-
be/src/pipeline/pipeline_fragment_context.h | 5 +-
be/src/pipeline/pipeline_x/dependency.h | 1 +
be/src/pipeline/pipeline_x/operator.cpp | 34 +-
be/src/pipeline/pipeline_x/operator.h | 4 +
.../pipeline_x/pipeline_x_fragment_context.cpp | 6 +-
.../pipeline_x/pipeline_x_fragment_context.h | 2 +-
be/src/pipeline/pipeline_x/pipeline_x_task.cpp | 27 +-
be/src/runtime/exec_env_init.cpp | 1 +
be/src/runtime/fragment_mgr.cpp | 161 +-
be/src/runtime/fragment_mgr.h | 15 +-
be/src/runtime/group_commit_mgr.cpp | 20 +-
be/src/runtime/load_stream_writer.cpp | 4 +-
be/src/runtime/query_context.cpp | 61 +-
be/src/runtime/query_context.h | 14 +-
be/src/runtime/runtime_filter_mgr.cpp | 1 +
be/src/runtime/snapshot_loader.cpp | 19 +-
be/src/service/backend_service.cpp | 4 +-
be/src/service/backend_service.h | 5 +-
be/src/service/doris_main.cpp | 60 +-
be/src/service/http_service.cpp | 7 +-
be/src/service/internal_service.cpp | 3 +
be/src/util/arrow/block_convertor.cpp | 27 +-
be/src/util/arrow/block_convertor.h | 5 +-
be/src/util/arrow/row_batch.cpp | 14 +-
be/src/util/cpu_info.cpp | 83 +-
be/src/util/hdfs_util.cpp | 58 -
be/src/util/hdfs_util.h | 52 -
be/src/util/ref_count_closure.h | 18 +
be/src/util/s3_util.cpp | 99 +-
be/src/util/s3_util.h | 65 +-
.../aggregate_function_collect.h | 110 +-
.../aggregate_functions/aggregate_function_map.h | 43 +-
.../aggregate_function_simple_factory.h | 26 +-
be/src/vec/columns/column_object.cpp | 109 +-
be/src/vec/columns/column_object.h | 11 +-
be/src/vec/common/allocator.cpp | 9 +-
.../common/hash_table/hash_map_context_creator.h | 15 +-
be/src/vec/common/hash_table/join_hash_table.h | 15 +-
be/src/vec/common/schema_util.cpp | 19 +-
be/src/vec/common/schema_util.h | 2 +-
be/src/vec/core/block.h | 6 +
be/src/vec/core/block_spill_reader.cpp | 6 +-
be/src/vec/core/block_spill_writer.cpp | 4 +-
be/src/vec/data_types/data_type_decimal.cpp | 2 +-
be/src/vec/data_types/data_type_object.cpp | 4 +-
be/src/vec/data_types/data_type_struct.h | 1 +
.../vec/data_types/serde/data_type_array_serde.cpp | 29 +-
.../vec/data_types/serde/data_type_array_serde.h | 12 +-
.../vec/data_types/serde/data_type_bitmap_serde.h | 4 +-
.../data_types/serde/data_type_date64_serde.cpp | 2 +-
.../vec/data_types/serde/data_type_date64_serde.h | 4 +-
.../serde/data_type_datetimev2_serde.cpp | 26 +-
.../data_types/serde/data_type_datetimev2_serde.h | 4 +-
.../data_types/serde/data_type_datev2_serde.cpp | 56 +-
.../vec/data_types/serde/data_type_datev2_serde.h | 4 +-
.../data_types/serde/data_type_decimal_serde.cpp | 2 +-
.../vec/data_types/serde/data_type_decimal_serde.h | 4 +-
.../vec/data_types/serde/data_type_hll_serde.cpp | 4 +-
be/src/vec/data_types/serde/data_type_hll_serde.h | 4 +-
.../vec/data_types/serde/data_type_jsonb_serde.cpp | 20 +-
.../vec/data_types/serde/data_type_jsonb_serde.h | 12 +-
.../vec/data_types/serde/data_type_map_serde.cpp | 12 +-
be/src/vec/data_types/serde/data_type_map_serde.h | 4 +-
.../data_types/serde/data_type_nullable_serde.cpp | 22 +-
.../data_types/serde/data_type_nullable_serde.h | 12 +-
.../data_types/serde/data_type_number_serde.cpp | 2 +-
.../vec/data_types/serde/data_type_number_serde.h | 25 +-
.../vec/data_types/serde/data_type_object_serde.h | 4 +-
.../serde/data_type_quantilestate_serde.h | 4 +-
be/src/vec/data_types/serde/data_type_serde.cpp | 13 +-
be/src/vec/data_types/serde/data_type_serde.h | 12 +-
.../vec/data_types/serde/data_type_string_serde.h | 16 +-
.../data_types/serde/data_type_struct_serde.cpp | 4 +-
.../vec/data_types/serde/data_type_struct_serde.h | 4 +-
be/src/vec/exec/format/csv/csv_reader.cpp | 19 +-
be/src/vec/exec/format/csv/csv_reader.h | 2 -
be/src/vec/exec/format/json/new_json_reader.cpp | 7 +-
be/src/vec/exec/format/json/new_json_reader.h | 1 -
be/src/vec/exec/format/orc/vorc_reader.cpp | 12 +-
.../exec/format/parquet/parquet_column_convert.h | 13 +-
be/src/vec/exec/format/parquet/parquet_common.cpp | 6 +-
be/src/vec/exec/format/parquet/parquet_common.h | 12 +-
.../exec/format/parquet/vparquet_column_reader.cpp | 59 +-
.../exec/format/parquet/vparquet_column_reader.h | 29 +-
be/src/vec/exec/format/parquet/vparquet_reader.cpp | 6 +-
be/src/vec/exec/format/parquet/vparquet_reader.h | 1 -
be/src/vec/exec/format/wal/wal_reader.cpp | 11 +-
be/src/vec/exec/format/wal/wal_reader.h | 1 +
be/src/vec/exec/join/vhash_join_node.cpp | 57 +-
be/src/vec/exec/join/vhash_join_node.h | 4 +-
be/src/vec/exec/join/vjoin_node_base.cpp | 31 +-
be/src/vec/exec/join/vjoin_node_base.h | 12 +-
be/src/vec/exec/join/vnested_loop_join_node.cpp | 4 +
be/src/vec/exec/join/vnested_loop_join_node.h | 2 +-
be/src/vec/exec/vunion_node.cpp | 2 +-
be/src/vec/exprs/vectorized_agg_fn.cpp | 13 +-
be/src/vec/exprs/vexpr.cpp | 6 +-
be/src/vec/exprs/vexpr_context.cpp | 6 +-
be/src/vec/exprs/vruntimefilter_wrapper.cpp | 7 +-
be/src/vec/functions/function_string.h | 41 +-
be/src/vec/functions/like.cpp | 371 +-
be/src/vec/functions/like.h | 92 +-
be/src/vec/runtime/vparquet_transformer.cpp | 10 +-
be/src/vec/sink/varrow_flight_result_writer.cpp | 3 +-
be/src/vec/sink/varrow_flight_result_writer.h | 3 +
be/src/vec/sink/vmemory_scratch_sink.cpp | 3 +-
be/src/vec/sink/vmemory_scratch_sink.h | 4 +-
be/src/vec/sink/vrow_distribution.cpp | 120 +-
be/src/vec/sink/vrow_distribution.h | 26 +-
be/src/vec/sink/vtablet_finder.cpp | 8 -
be/src/vec/sink/vtablet_finder.h | 3 +-
be/src/vec/sink/writer/async_result_writer.cpp | 17 +-
be/src/vec/sink/writer/async_result_writer.h | 1 +
be/src/vec/sink/writer/vfile_result_writer.cpp | 40 +-
be/src/vec/sink/writer/vhive_partition_writer.cpp | 37 +-
be/src/vec/sink/writer/vhive_partition_writer.h | 14 +-
be/src/vec/sink/writer/vtablet_writer.cpp | 3 +-
be/src/vec/sink/writer/vtablet_writer_v2.cpp | 29 +-
be/src/vec/sink/writer/vwal_writer.cpp | 2 +-
be/src/vec/sink/writer/vwal_writer.h | 2 -
be/src/vec/spill/spill_reader.cpp | 11 +-
be/src/vec/spill/spill_writer.cpp | 5 +-
be/test/exec/test_data/wal_scanner/wal | Bin 180 -> 0 bytes
be/test/exec/test_data/wal_scanner/wal_version0 | Bin 0 -> 220 bytes
be/test/exec/test_data/wal_scanner/wal_version1 | Bin 0 -> 272 bytes
be/test/io/cache/block_file_cache_test.cpp | 5 +-
be/test/io/fs/buffered_reader_test.cpp | 4 -
be/test/io/fs/s3_file_writer_test.cpp | 53 +-
be/test/olap/delete_bitmap_calculator_test.cpp | 2 +-
be/test/olap/rowset/beta_rowset_test.cpp | 32 +-
be/test/olap/tablet_cooldown_test.cpp | 21 +-
.../serde/data_type_serde_arrow_test.cpp | 12 +-
be/test/vec/exec/parquet/parquet_reader_test.cpp | 2 +-
be/test/vec/exec/parquet/parquet_thrift_test.cpp | 6 +-
be/test/vec/exec/vwal_scanner_test.cpp | 43 +-
be/test/vec/function/function_string_test.cpp | 21 +-
build.sh | 23 +-
cloud/src/meta-service/meta_service.cpp | 2 +-
cloud/src/meta-service/meta_service_http.cpp | 3 +
cloud/src/meta-service/meta_service_resource.cpp | 6 +-
cloud/src/meta-service/meta_service_schema.cpp | 4 +-
docker/runtime/doris-compose/Readme.md | 8 +
docker/runtime/doris-compose/cluster.py | 40 +-
docker/runtime/doris-compose/command.py | 103 +-
docker/runtime/doris-compose/resource/init_be.sh | 4 +-
.../parquet_all_types/.test_hidden_dir/wrong_file | 1 +
.../test_hidden_file/.hidden_file | 1 +
.../sql-functions/combinators/foreach.md | 84 +
.../Manipulation/INSERT-OVERWRITE.md | 70 +-
.../sql-functions/combinators/foreach.md | 82 +
.../Manipulation/INSERT-OVERWRITE.md | 69 +-
.../apache/doris/jdbc/JdbcDataSourceConfig.java | 10 +-
.../main/java/org/apache/doris/common/Config.java | 9 +
fe/fe-core/pom.xml | 4 +-
.../antlr4/org/apache/doris/nereids/DorisParser.g4 | 8 +-
fe/fe-core/src/main/cup/sql_parser.cup | 4 +
.../org/apache/doris/analysis/AnalyzeTblStmt.java | 8 +-
.../org/apache/doris/analysis/ArrayLiteral.java | 9 +-
.../org/apache/doris/analysis/CreateJobStmt.java | 26 +-
.../org/apache/doris/analysis/DecimalLiteral.java | 3 +
.../doris/analysis/InsertOverwriteTableStmt.java | 7 +
.../apache/doris/analysis/NativeInsertStmt.java | 6 +
.../org/apache/doris/analysis/OutFileClause.java | 88 +-
.../org/apache/doris/analysis/PartitionNames.java | 24 +-
.../apache/doris/analysis/SetUserDefinedVar.java | 36 +-
.../java/org/apache/doris/backup/BackupJob.java | 9 +-
.../org/apache/doris/backup/BackupJobInfo.java | 7 +-
.../java/org/apache/doris/backup/RestoreJob.java | 10 +-
.../apache/doris/catalog/CloudTabletStatMgr.java | 13 +-
.../main/java/org/apache/doris/catalog/Env.java | 14 +-
.../java/org/apache/doris/catalog/EnvFactory.java | 5 +
.../org/apache/doris/catalog/JdbcResource.java | 2 +-
.../java/org/apache/doris/catalog/OlapTable.java | 8 +
.../java/org/apache/doris/catalog/Partition.java | 1 +
.../org/apache/doris/catalog/PartitionKey.java | 22 +-
.../java/org/apache/doris/catalog/SchemaTable.java | 3 +-
.../apache/doris/catalog/TabletInvertedIndex.java | 9 +
.../org/apache/doris/clone/TabletScheduler.java | 4 +-
.../doris/cloud/catalog/CloudEnvFactory.java | 6 +
.../apache/doris/cloud/catalog/CloudPartition.java | 16 +-
.../apache/doris/cloud/catalog/CloudReplica.java | 2 +-
.../cloud/datasource/CloudInternalCatalog.java | 21 +-
.../cloud/planner/CloudGroupCommitPlanner.java | 6 +-
.../apache/doris/cloud/qe/CloudCoordinator.java | 69 -
.../doris/cloud/system/CloudSystemInfoService.java | 3 +-
.../org/apache/doris/common/InternalErrorCode.java | 1 +
.../java/org/apache/doris/common/Log4jConfig.java | 6 +-
.../org/apache/doris/common/util/LocationPath.java | 7 +
.../doris/datasource/hive/HMSExternalCatalog.java | 4 +-
.../doris/datasource/hive/HiveMetaStoreCache.java | 24 +-
.../datasource/hive/HiveMetaStoreClientHelper.java | 27 +-
.../doris/datasource/hive/HiveMetadataOps.java | 97 +-
.../doris/datasource/hive/HiveTableMetadata.java | 59 +-
.../hive/PostgreSQLJdbcHMSCachedClient.java | 5 -
.../datasource/hive/ThriftHMSCachedClient.java | 40 +-
.../doris/datasource/jdbc/JdbcExternalCatalog.java | 17 +-
.../jdbc/client/JdbcClickHouseClient.java | 5 -
.../doris/datasource/jdbc/client/JdbcClient.java | 35 +-
.../datasource/jdbc/client/JdbcDB2Client.java | 28 +-
.../datasource/jdbc/client/JdbcMySQLClient.java | 31 +-
.../jdbc/client/JdbcOceanBaseClient.java | 5 -
.../datasource/jdbc/client/JdbcOracleClient.java | 31 -
.../jdbc/client/JdbcPostgreSQLClient.java | 6 -
.../jdbc/client/JdbcSQLServerClient.java | 5 -
.../datasource/jdbc/client/JdbcSapHanaClient.java | 5 -
.../datasource/jdbc/client/JdbcTrinoClient.java | 13 -
.../datasource/paimon/source/PaimonScanNode.java | 26 +-
.../doris/httpv2/controller/BaseController.java | 4 +-
.../insertoverwrite/InsertOverwriteManager.java | 87 +
.../doris/insertoverwrite/InsertOverwriteUtil.java | 47 +-
.../apache/doris/load/BrokerFileGroupAggInfo.java | 14 +
.../doris/load/routineload/RoutineLoadJob.java | 13 +
.../doris/load/routineload/RoutineLoadManager.java | 4 +-
.../load/routineload/RoutineLoadTaskInfo.java | 30 +
.../load/routineload/RoutineLoadTaskScheduler.java | 3 +-
.../doris/load/routineload/ScheduleRule.java | 2 +-
.../main/java/org/apache/doris/mtmv/MTMVCache.java | 34 +-
.../main/java/org/apache/doris/mtmv/MTMVUtil.java | 15 +-
.../doris/mysql/privilege/PrivPredicate.java | 4 +
.../org/apache/doris/nereids/NereidsPlanner.java | 6 +-
.../doris/nereids/analyzer/UnboundTableSink.java | 34 +-
.../nereids/analyzer/UnboundTableSinkCreator.java | 37 +
.../glue/translator/PhysicalPlanTranslator.java | 9 +-
.../doris/nereids/jobs/executor/Analyzer.java | 2 +
.../doris/nereids/jobs/executor/Rewriter.java | 8 +-
.../doris/nereids/parser/LogicalPlanBuilder.java | 22 +-
.../org/apache/doris/nereids/rules/RuleType.java | 3 +-
.../doris/nereids/rules/analysis/CheckPolicy.java | 24 +-
.../rules/analysis/EliminateDistinctConstant.java | 48 +
.../mv/AbstractMaterializedViewAggregateRule.java | 1 +
.../expression/rules/NullSafeEqualToEqual.java | 2 +-
.../rules/rewrite/EnsureProjectOnTopJoin.java | 60 -
.../rules/rewrite/PullUpProjectUnderLimit.java | 6 +-
.../rules/rewrite/PullUpProjectUnderTopN.java | 38 +-
.../nereids/rules/rewrite/SumLiteralRewrite.java | 185 +
.../trees/expressions/ComparisonPredicate.java | 2 +-
.../functions/combinator/ForEachCombinator.java | 2 +-
.../executable/DateTimeExtractAndTransform.java | 11 +-
.../scalar/PushDownToProjectionFunction.java | 3 +-
.../functions/table/TableValuedFunction.java | 4 +-
.../apache/doris/nereids/trees/plans/JoinType.java | 4 +
.../plans/commands/UpdateMvByPartitionCommand.java | 103 +-
.../commands/insert/AbstractInsertExecutor.java | 1 +
.../commands/insert/HiveInsertCommandContext.java | 2 +-
.../plans/commands/insert/HiveInsertExecutor.java | 10 +
.../commands/insert/InsertIntoTableCommand.java | 1 +
.../insert/InsertOverwriteTableCommand.java | 136 +-
.../commands/insert/OlapInsertCommandContext.java | 22 +-
.../plans/commands/insert/OlapInsertExecutor.java | 7 +-
.../trees/plans/logical/LogicalCheckPolicy.java | 67 +-
.../trees/plans/physical/PhysicalTableSink.java | 3 +
.../nereids/trees/plans/visitor/SinkVisitor.java | 8 +-
.../doris/nereids/util/TypeCoercionUtils.java | 15 +-
.../org/apache/doris/planner/HiveTableSink.java | 3 +-
.../org/apache/doris/planner/OlapTableSink.java | 15 +-
.../org/apache/doris/planner/OriginalPlanner.java | 3 +
.../java/org/apache/doris/planner/Planner.java | 1 -
.../java/org/apache/doris/planner/ScanNode.java | 69 +
.../doris/planner/TabletLoadIndexRecorderMgr.java | 5 +-
.../java/org/apache/doris/qe/ConnectContext.java | 2 +
.../main/java/org/apache/doris/qe/Coordinator.java | 50 +-
.../java/org/apache/doris/qe/MasterOpExecutor.java | 6 +-
.../java/org/apache/doris/qe/SessionVariable.java | 10 +-
.../java/org/apache/doris/qe/StmtExecutor.java | 83 +-
.../apache/doris/service/FrontendServiceImpl.java | 166 +
.../apache/doris/statistics/AnalysisManager.java | 2 +-
.../apache/doris/statistics/OlapAnalysisTask.java | 5 +-
.../ExternalFileTableValuedFunction.java | 2 +-
.../doris/transaction/DatabaseTransactionMgr.java | 21 +-
.../apache/doris/transaction/TableCommitInfo.java | 4 +-
.../apache/doris/analysis/CreateJobStmtTest.java | 26 +
.../apache/doris/datasource/PathVisibleTest.java | 47 +
.../doris/datasource/hive/HiveMetadataOpsTest.java | 162 +
.../doris/datasource/hive/HmsCommitTest.java | 5 +-
.../nereids/postprocess/TopNRuntimeFilterTest.java | 6 +-
.../nereids/privileges/TestCheckPrivileges.java | 200 +-
.../nereids/rules/analysis/BindRelationTest.java | 2 -
.../expression/rules/NullSafeEqualToEqualTest.java | 26 +-
.../nereids/rules/rewrite/InferPredicatesTest.java | 44 -
.../rules/rewrite/PullUpProjectUnderLimitTest.java | 7 +-
.../rules/rewrite/PullUpProjectUnderTopNTest.java | 8 +-
.../rules/rewrite/PushDownTopNThroughJoinTest.java | 8 +-
.../nereids/rules/rewrite/ReorderJoinTest.java | 6 -
.../rules/rewrite/SumLiteralRewriteTest.java | 54 +
.../apache/doris/nereids/sqltest/InferTest.java | 4 -
.../commands/UpdateMvByPartitionCommandTest.java | 62 +-
.../ExtractCommonFactorsRuleFunctionTest.java | 4 +-
gensrc/thrift/Descriptors.thrift | 3 +
gensrc/thrift/FrontendService.thrift | 19 +
gensrc/thrift/PaloInternalService.thrift | 2 +
gensrc/thrift/PlanNodes.thrift | 4 +
regression-test/conf/regression-conf.groovy | 5 -
.../test_like_predicate_with_concat.out | 101 +
.../test_null_aware_left_anti_join.out | 5 +
.../unique/test_unique_table_auto_inc.out | 54 +-
.../datatype_p0/decimalv3/test_decimalv3_where.out | 6 +
.../data/datatype_p0/decimalv3/test_load.out | 28 +
.../data/export_p0/export/test_show_export.out | 300 +-
.../test_outfile_expr_generate_col_name.out | 4 +-
.../parquet/test_outfile_parquet_array_type.out | 8 +-
.../parquet/test_outfile_parquet_complex_type.out | 20 +-
.../parquet/test_outfile_parquet_map_type.out | 28 +-
.../data/export_p0/test_export_data_types.out | 24 +-
regression-test/data/export_p0/test_export_orc.out | 200 +-
.../data/export_p0/test_export_parquet.out | 200 +-
.../export/hive_read/orc/test_hive_read_orc.out | 2 +-
.../hive_read/parquet/test_hive_read_parquet.out | 16 +-
.../parquet/test_hive_read_parquet_comlex_type.out | 40 +-
.../jdbc/test_clickhouse_jdbc_catalog.out | Bin 5426 -> 5487 bytes
.../jdbc/test_mariadb_jdbc_catalog.out | 5 +
.../jdbc/test_mysql_jdbc_driver5_catalog.out | 12 +-
.../jdbc/test_oracle_jdbc_catalog.out | 8 +
.../jdbc/test_pg_jdbc_catalog.out | 8 +-
.../jdbc/test_sqlserver_jdbc_catalog.out | 15 +
.../test_index_lowercase_fault_injection.out} | 8 +-
.../data/function_p0/test_agg_foreach.out | 23 +-
.../{ => hdfs_vault}/ssb_sf1_p2/sql/flat_q1.1.out | 0
.../{ => hdfs_vault}/ssb_sf1_p2/sql/flat_q1.2.out | 0
.../{ => hdfs_vault}/ssb_sf1_p2/sql/flat_q1.3.out | 0
.../{ => hdfs_vault}/ssb_sf1_p2/sql/flat_q2.1.out | 0
.../{ => hdfs_vault}/ssb_sf1_p2/sql/flat_q2.2.out | 0
.../{ => hdfs_vault}/ssb_sf1_p2/sql/flat_q2.3.out | 0
.../{ => hdfs_vault}/ssb_sf1_p2/sql/flat_q3.1.out | 0
.../{ => hdfs_vault}/ssb_sf1_p2/sql/flat_q3.2.out | 0
.../{ => hdfs_vault}/ssb_sf1_p2/sql/flat_q3.3.out | 0
.../{ => hdfs_vault}/ssb_sf1_p2/sql/flat_q3.4.out | 0
.../{ => hdfs_vault}/ssb_sf1_p2/sql/flat_q4.1.out | 0
.../{ => hdfs_vault}/ssb_sf1_p2/sql/flat_q4.2.out | 0
.../{ => hdfs_vault}/ssb_sf1_p2/sql/flat_q4.3.out | 0
.../ssb_sf1_p2}/sql/q1.1.out | 0
.../ssb_sf1_p2}/sql/q1.2.out | 0
.../ssb_sf1_p2}/sql/q1.3.out | 0
.../ssb_sf1_p2/sql/q2.1.out} | 6 +-
.../ssb_sf1_p2/sql/q2.2.out} | 6 +-
.../ssb_sf1_p2/sql/q2.3.out} | 6 +-
.../ssb_sf1_p2/sql/q3.1.out} | 6 +-
.../ssb_sf1_p2/sql/q3.2.out} | 6 +-
.../ssb_sf1_p2/sql/q3.3.out} | 6 +-
.../ssb_sf1_p2}/sql/q3.4.out | 0
.../ssb_sf1_p2/sql/q4.1.out} | 6 +-
.../ssb_sf1_p2}/sql/q4.2.out | 0
.../ssb_sf1_p2}/sql/q4.3.out | 0
.../insert_overwrite_auto_detect.out | 83 +
...p_commit_http_stream_lineitem_schema_change.out | 5 +-
...p_commit_insert_into_lineitem_scheme_change.out | 2 +-
...p_commit_stream_load_lineitem_schema_change.out | 2 +-
.../test_index_skip_read_data.out | 83 +
.../data/inverted_index_p0/test_lowercase.out | 6 +
.../broker_load/test_multi_table_load.out} | 8 +-
regression-test/data/mtmv_p0/test_es_mtmv.out | 13 +
.../load.out => mtmv_p0/test_iceberg_mtmv.out} | 10 +-
.../load.out => mtmv_p0/test_mysql_mtmv.out} | 14 +-
regression-test/data/mtmv_p0/test_paimon_mtmv.out | 9 +
regression-test/data/nereids_arith_p0/decimal.out | 2400 ++--
regression-test/data/nereids_arith_p0/integer.out | 776 +-
.../data/nereids_clickbench_shape_p0/query30.out | 11 +-
.../data/nereids_clickbench_shape_p0/query35.out | 8 +-
.../data/nereids_clickbench_shape_p0/query36.out | 8 +-
.../data/nereids_clickbench_shape_p0/query40.out | 8 +-
.../data/nereids_p0/hint/fix_leading.out | 23 +-
.../limit/filterLimitProject.out} | 11 +-
regression-test/data/nereids_p0/test_user_var.out | 13 +-
.../eliminate_distinct_constant.out | 40 +
.../eliminate_gby_key/eliminate_gby_key.out | 164 -
.../eliminate_outer_join/eliminate_outer_join.out | 180 +-
.../push_down_alias_through_join.out | 72 +-
.../data/nereids_rules_p0/mv/tpch/mv_tpch_test.out | 11451 +++++++++++++++++++
.../data/nereids_rules_p0/sumRewrite.out | 142 +
regression-test/data/nereids_shape_check/load.out | 36 +-
.../data/nereids_syntax_p0/array_compare.out | 68 +
.../shape/query10.out | 8 +-
.../shape/query17.out | 8 +-
.../shape/query27.out | 61 +-
.../shape/query28.out | 101 +-
.../shape/query35.out | 8 +-
.../shape/query39.out | 19 +-
.../shape/query54.out | 8 +-
.../shape/query58.out | 139 +-
.../shape/query59.out | 59 +-
.../shape/query61.out | 6 +-
.../shape/query69.out | 8 +-
.../shape/query83.out | 129 +-
.../shape/query88.out | 145 +-
.../noStatsRfPrune/query10.out | 8 +-
.../noStatsRfPrune/query17.out | 8 +-
.../noStatsRfPrune/query27.out | 59 +-
.../noStatsRfPrune/query28.out | 101 +-
.../noStatsRfPrune/query35.out | 8 +-
.../noStatsRfPrune/query39.out | 19 +-
.../noStatsRfPrune/query54.out | 8 +-
.../noStatsRfPrune/query58.out | 179 +-
.../noStatsRfPrune/query59.out | 57 +-
.../noStatsRfPrune/query61.out | 6 +-
.../noStatsRfPrune/query69.out | 8 +-
.../noStatsRfPrune/query83.out | 165 +-
.../noStatsRfPrune/query88.out | 145 +-
.../no_stats_shape/query10.out | 8 +-
.../no_stats_shape/query17.out | 8 +-
.../no_stats_shape/query27.out | 59 +-
.../no_stats_shape/query28.out | 101 +-
.../no_stats_shape/query35.out | 8 +-
.../no_stats_shape/query39.out | 19 +-
.../no_stats_shape/query54.out | 8 +-
.../no_stats_shape/query58.out | 179 +-
.../no_stats_shape/query59.out | 57 +-
.../no_stats_shape/query61.out | 6 +-
.../no_stats_shape/query69.out | 8 +-
.../no_stats_shape/query83.out | 165 +-
.../no_stats_shape/query88.out | 145 +-
.../rf_prune/query10.out | 8 +-
.../rf_prune/query17.out | 8 +-
.../rf_prune/query27.out | 63 +-
.../rf_prune/query28.out | 101 +-
.../rf_prune/query35.out | 8 +-
.../rf_prune/query39.out | 19 +-
.../rf_prune/query54.out | 8 +-
.../rf_prune/query58.out | 139 +-
.../rf_prune/query59.out | 59 +-
.../rf_prune/query61.out | 6 +-
.../rf_prune/query69.out | 8 +-
.../rf_prune/query83.out | 129 +-
.../rf_prune/query88.out | 145 +-
.../nereids_tpcds_shape_sf100_p0/shape/query10.out | 8 +-
.../nereids_tpcds_shape_sf100_p0/shape/query17.out | 8 +-
.../nereids_tpcds_shape_sf100_p0/shape/query27.out | 63 +-
.../nereids_tpcds_shape_sf100_p0/shape/query28.out | 101 +-
.../nereids_tpcds_shape_sf100_p0/shape/query35.out | 8 +-
.../nereids_tpcds_shape_sf100_p0/shape/query39.out | 19 +-
.../nereids_tpcds_shape_sf100_p0/shape/query54.out | 8 +-
.../nereids_tpcds_shape_sf100_p0/shape/query58.out | 139 +-
.../nereids_tpcds_shape_sf100_p0/shape/query59.out | 59 +-
.../nereids_tpcds_shape_sf100_p0/shape/query61.out | 6 +-
.../nereids_tpcds_shape_sf100_p0/shape/query69.out | 8 +-
.../nereids_tpcds_shape_sf100_p0/shape/query83.out | 129 +-
.../nereids_tpcds_shape_sf100_p0/shape/query88.out | 145 +-
.../data/nereids_tpch_p0/tpch/topn-filter.out | 4 +
.../data/query_p0/aggregate/array_agg.out | 84 +-
.../join/test_half_join_nullable_build_side.out | 8 +
regression-test/data/query_p0/join/test_join.out | 3 +
.../test_unique_model_schema_key_change.out | 40 +
.../test_unique_model_schema_value_change.out | 190 +
.../test_partial_update_seq_col_delete.out | Bin 1064 -> 1526 bytes
.../test_partial_update_seq_type_delete.out | Bin 3017 -> 2967 bytes
.../data/variant_github_events_p0/load.out | 6 +
regression-test/data/variant_p0/load.out | 75 +-
.../org/apache/doris/regression/Config.groovy | 14 +
.../org/apache/doris/regression/suite/Suite.groovy | 14 +-
.../doris/regression/suite/SuiteContext.groovy | 17 +-
.../doris/regression/suite/SyncerContext.groovy | 6 +-
.../cloud_p0/conf/regression-conf-custom.groovy | 4 +-
.../pipeline/cloud_p0/conf/session_variables.sql | 4 -
regression-test/pipeline/cloud_p0/run.sh | 8 +-
regression-test/pipeline/common/doris-utils.sh | 15 +-
.../pipeline/p0/conf/regression-conf.groovy | 7 +-
.../pipeline/p1/conf/regression-conf.groovy | 5 +
.../performance/clickbench/check-query-result.sh | 2 +-
regression-test/pipeline/performance/run-load.sh | 6 +-
.../test_full_compaction_by_table_id.groovy | 6 +-
.../test_like_predicate_with_concat.groovy | 112 +
.../test_null_aware_left_anti_join.groovy | 11 +
.../unique/test_unique_table_auto_inc.groovy | 6 +-
.../decimalv3/test_decimalv3_where.groovy | 19 +
.../suites/datatype_p0/decimalv3/test_load.groovy | 55 +
.../datatype_p0/string/test_string_basic.groovy | 5 +-
.../parquet/test_outfile_parquet_map_type.groovy | 55 +-
.../suites/export_p0/test_export_data_types.groovy | 348 +-
.../suites/export_p0/test_export_orc.groovy | 149 +-
.../export/hive_read/orc/test_hive_read_orc.groovy | 12 +-
.../parquet/test_hive_read_parquet.groovy | 12 +-
.../test_hive_read_parquet_comlex_type.groovy | 2 +-
.../jdbc/test_clickhouse_jdbc_catalog.groovy | 142 +-
.../jdbc/test_mariadb_jdbc_catalog.groovy | 1 +
.../jdbc/test_mysql_jdbc_catalog.groovy | 241 +-
.../jdbc/test_mysql_jdbc_driver5_catalog.groovy | 3 +-
.../jdbc/test_oracle_jdbc_catalog.groovy | 1 +
.../jdbc/test_pg_jdbc_catalog.groovy | 1 +
.../jdbc/test_sqlserver_jdbc_catalog.groovy | 84 +-
.../test_index_lowercase_fault_injection.groovy | 76 +
.../suites/function_p0/test_agg_foreach.groovy | 43 +-
.../hdfs_vault/ssb_sf1_p2/ddl/customer_create.sql | 16 +
.../ssb_sf1_p2}/ddl/customer_delete.sql | 0
.../hdfs_vault/ssb_sf1_p2/ddl/date_create.sql | 25 +
.../ssb_sf1_p2}/ddl/date_delete.sql | 0
.../hdfs_vault/ssb_sf1_p2/ddl/lineorder_create.sql | 25 +
.../ssb_sf1_p2}/ddl/lineorder_delete.sql | 0
.../ssb_sf1_p2/ddl/lineorder_flat_create.sql | 36 +-
.../ssb_sf1_p2}/ddl/lineorder_flat_delete.sql | 0
.../hdfs_vault/ssb_sf1_p2/ddl/part_create.sql | 17 +
.../ssb_sf1_p2}/ddl/part_delete.sql | 0
.../hdfs_vault/ssb_sf1_p2/ddl/supplier_create.sql | 15 +
.../ssb_sf1_p2}/ddl/supplier_delete.sql | 0
.../suites/hdfs_vault/ssb_sf1_p2/load.groovy | 133 +
.../ssb_sf1_p2}/sql/flat_q1.1.sql | 0
.../ssb_sf1_p2}/sql/flat_q1.2.sql | 0
.../ssb_sf1_p2}/sql/flat_q1.3.sql | 0
.../ssb_sf1_p2}/sql/flat_q2.1.sql | 0
.../ssb_sf1_p2}/sql/flat_q2.2.sql | 0
.../ssb_sf1_p2}/sql/flat_q2.3.sql | 0
.../ssb_sf1_p2}/sql/flat_q3.1.sql | 0
.../ssb_sf1_p2}/sql/flat_q3.2.sql | 0
.../ssb_sf1_p2}/sql/flat_q3.3.sql | 0
.../ssb_sf1_p2}/sql/flat_q3.4.sql | 0
.../ssb_sf1_p2}/sql/flat_q4.1.sql | 0
.../ssb_sf1_p2}/sql/flat_q4.2.sql | 0
.../ssb_sf1_p2}/sql/flat_q4.3.sql | 0
.../ssb_sf1_p2}/sql/q1.1.sql | 0
.../ssb_sf1_p2}/sql/q1.2.sql | 0
.../ssb_sf1_p2}/sql/q1.3.sql | 0
.../ssb_sf1_p2}/sql/q2.1.sql | 0
.../ssb_sf1_p2}/sql/q2.2.sql | 0
.../ssb_sf1_p2}/sql/q2.3.sql | 0
.../ssb_sf1_p2}/sql/q3.1.sql | 0
.../ssb_sf1_p2}/sql/q3.2.sql | 0
.../ssb_sf1_p2}/sql/q3.3.sql | 0
.../ssb_sf1_p2}/sql/q3.4.sql | 0
.../ssb_sf1_p2}/sql/q4.1.sql | 0
.../ssb_sf1_p2}/sql/q4.2.sql | 0
.../ssb_sf1_p2}/sql/q4.3.sql | 0
.../insert_overwrite_auto_detect.groovy | 108 +
.../suites/insert_p0/prepare_insert.groovy | 41 +-
...ommit_http_stream_lineitem_schema_change.groovy | 1 +
...mit_insert_into_lineitem_multiple_client.groovy | 25 +-
...mmit_insert_into_lineitem_multiple_table.groovy | 26 +-
...group_commit_insert_into_lineitem_normal.groovy | 29 +-
...ommit_insert_into_lineitem_scheme_change.groovy | 36 +-
...ommit_stream_load_lineitem_schema_change.groovy | 1 +
.../index_change/test_index_change_1.groovy | 2 +-
.../index_change/test_index_change_2.groovy | 3 +-
.../index_change/test_index_change_3.groovy | 8 +-
.../index_change/test_index_change_4.groovy | 3 +-
.../test_index_change_with_compaction.groovy | 5 +-
.../index_change/test_pk_uk_index_change.groovy | 2 +-
.../inverted_index_p0/test_add_drop_index.groovy | 2 +-
.../inverted_index_p0/test_array_index.groovy | 16 +
.../inverted_index_p0/test_build_index.groovy | 78 +-
.../inverted_index_p0/test_create_index_1.groovy | 4 +-
.../inverted_index_p0/test_create_index_2.groovy | 6 +-
.../inverted_index_p0/test_create_index_3.groovy | 21 +-
.../test_index_skip_read_data.groovy | 131 +
.../suites/inverted_index_p0/test_show_data.groovy | 11 +-
.../suites/job_p0/test_base_insert_job.groovy | 29 +
.../broker_load/test_multi_table_load.groovy | 166 +
.../test_insert_random_distribution_table.groovy | 314 +-
.../routine_load/test_routine_load_error.groovy | 2 +-
.../stream_load/test_load_to_single_tablet.groovy | 190 +-
.../suites/mtmv_p0/test_agg_table_mtmv.groovy | 2 +-
.../suites/mtmv_p0/test_base_mtmv.groovy | 6 +-
.../suites/mtmv_p0/test_build_mtmv.groovy | 2 +-
regression-test/suites/mtmv_p0/test_es_mtmv.groovy | 63 +
.../suites/mtmv_p0/test_hive_mtmv.groovy | 2 +-
.../suites/mtmv_p0/test_hive_olap_mtmv.groovy | 2 +-
.../suites/mtmv_p0/test_iceberg_mtmv.groovy | 69 +
.../mtmv_p0/test_limit_partition_mtmv.groovy | 10 +-
.../suites/mtmv_p0/test_mor_table_mtmv.groovy | 2 +-
.../suites/mtmv_p0/test_mow_table_mtmv.groovy | 2 +-
.../suites/mtmv_p0/test_mysql_mtmv.groovy | 71 +
.../suites/mtmv_p0/test_paimon_mtmv.groovy | 62 +
.../mtmv_p0/test_partition_refresh_mtmv.groovy | 18 +-
.../suites/mtmv_p0/test_task_mtmv.groovy | 2 +-
.../suites/mtmv_p0/test_workload_group_mtmv.groovy | 2 +-
.../mv_p0/test_create_mv/test_create_mv.groovy | 83 +
.../suites/nereids_arith_p0/load.groovy | 6 +-
.../nereids_p0/limit/filterLimitProject.groovy | 58 +
.../suites/nereids_p0/test_user_var.groovy | 12 +-
.../eliminate_distinct_constant.groovy | 70 +
.../eliminate_gby_key/eliminate_gby_key.groovy | 108 +-
.../cross_join_list_str_increment_create.groovy | 2 +-
.../cross_join_range_date_increment_create.groovy | 2 +-
...cross_join_range_number_increment_create.groovy | 2 +-
.../full_join_list_str_increment_create.groovy | 2 +-
.../full_join_range_date_increment_create.groovy | 2 +-
.../full_join_range_number_increment_create.groovy | 2 +-
.../inner_join_list_str_increment_create.groovy | 2 +-
.../inner_join_range_date_increment_create.groovy | 2 +-
...inner_join_range_number_increment_create.groovy | 2 +-
...left_anti_join_list_str_increment_create.groovy | 2 +-
...ft_anti_join_range_date_increment_create.groovy | 2 +-
..._anti_join_range_number_increment_create.groovy | 2 +-
.../left_join_list_str_increment_create.groovy | 2 +-
.../left_join_range_date_increment_create.groovy | 2 +-
.../left_join_range_number_increment_create.groovy | 2 +-
...left_semi_join_list_str_increment_create.groovy | 2 +-
...ft_semi_join_range_date_increment_create.groovy | 2 +-
..._semi_join_range_number_increment_create.groovy | 2 +-
...ight_anti_join_list_str_increment_create.groovy | 2 +-
...ht_anti_join_range_date_increment_create.groovy | 2 +-
..._anti_join_range_number_increment_create.groovy | 2 +-
.../right_join_list_str_increment_create.groovy | 2 +-
.../right_join_range_date_increment_create.groovy | 2 +-
...right_join_range_number_increment_create.groovy | 2 +-
...ight_semi_join_list_str_increment_create.groovy | 2 +-
...ht_semi_join_range_date_increment_create.groovy | 2 +-
..._semi_join_range_number_increment_create.groovy | 2 +-
.../self_conn_list_str_increment_create.groovy | 2 +-
.../self_conn_range_date_increment_create.groovy | 2 +-
.../self_conn_range_number_increment_create.groovy | 2 +-
.../mv/join/inner/inner_join.groovy | 17 +-
.../mv/tpch}/ddl/create_table.sql | 0
.../mv/tpch}/ddl/customer.sql | 0
.../mv/tpch}/ddl/customer_delete.sql | 0
.../mv/tpch}/ddl/lineitem.sql | 0
.../mv/tpch}/ddl/lineitem_delete.sql | 0
.../mv/tpch}/ddl/nation.sql | 0
.../mv/tpch}/ddl/nation_delete.sql | 0
.../mv/tpch}/ddl/orders.sql | 0
.../mv/tpch}/ddl/orders_delete.sql | 0
.../mv/tpch}/ddl/part.sql | 0
.../mv/tpch}/ddl/part_delete.sql | 0
.../mv/tpch}/ddl/partsupp.sql | 0
.../mv/tpch}/ddl/partsupp_delete.sql | 0
.../mv/tpch}/ddl/region.sql | 0
.../mv/tpch}/ddl/region_delete.sql | 0
.../mv/tpch}/ddl/revenue1.sql | 0
.../mv/tpch}/ddl/revenue1_delete.sql | 0
.../mv/tpch}/ddl/supplier.sql | 0
.../mv/tpch}/ddl/supplier_delete.sql | 0
.../nereids_rules_p0/mv/tpch/mv_tpch_test.groovy | 1514 +++
.../test_date_function_prune.groovy | 5 +
.../suites/nereids_rules_p0/sumRewrite.groovy | 118 +
.../suites/nereids_syntax_p0/array_compare.groovy | 83 +
.../suites/nereids_tpch_p0/tpch/topn-filter.groovy | 3 +
.../test_multi_column_partition.groovy | 29 +-
.../multi_partition/test_multi_partition.groovy | 43 +-
.../multi_partition/test_range_partition.groovy | 28 +
.../test_partition_table_err_msg.groovy | 5 +-
.../diff_data/stress_test_diff_date_list.groovy | 87 +-
.../auto_partition/diff_data/thread_load_1.sh | 17 -
.../auto_partition/diff_data/thread_load_2.sh | 17 -
.../stress_test_high_concurrency_load.groovy | 95 +-
.../same_data/stress_test_same_date_range.groovy | 85 +-
.../auto_partition/same_data/thread_load_1.sh | 17 -
.../auto_partition/same_data/thread_load_2.sh | 17 -
.../stress_test_two_stream_load.groovy | 104 +-
.../two_stream_load/thread_load_1.sh | 17 -
.../two_stream_load/thread_load_2.sh | 17 -
.../plugin_p0/test_plugin_curl_requester.groovy | 7 +-
.../suites/query_p0/aggregate/array_agg.groovy | 84 +-
.../join/test_half_join_nullable_build_side.groovy | 11 +-
.../suites/query_p0/join/test_join.groovy | 41 +
.../test_array_functions_with_where.groovy | 6 -
.../test_string_function_regexp.groovy | 3 +-
.../test_unique_model_schema_key_change.groovy | 655 +-
.../test_unique_model_schema_value_change.groovy | 492 +
.../suites/statistics/analyze_stats.groovy | 55 +-
.../suites/statistics/test_analyze_mtmv.groovy | 2 +-
.../test_partial_update_seq_col_delete.groovy | 8 +
.../max_msg_size_of_result_receiver.groovy | 14 +-
.../suites/variant_github_events_p0/load.groovy | 3 +-
regression-test/suites/variant_p0/load.groovy | 30 +-
.../variant_p0/test_compaction_extract_root.groovy | 22 +-
tools/ssb-tools/README.md | 2 +-
tools/ssb-tools/bin/create-ssb-tables.sh | 41 +-
tools/ssb-tools/bin/load-ssb-data.sh | 7 +
tools/ssb-tools/bin/run-ssb-flat-queries.sh | 97 +-
tools/ssb-tools/bin/run-ssb-queries.sh | 112 +-
...at-table.sql => create-ssb-flat-tables-sf1.sql} | 12 +-
...-table.sql => create-ssb-flat-tables-sf100.sql} | 12 +-
...table.sql => create-ssb-flat-tables-sf1000.sql} | 16 +-
...te-ssb-tables.sql => create-ssb-tables-sf1.sql} | 36 +-
...-ssb-tables.sql => create-ssb-tables-sf100.sql} | 36 +-
...ssb-tables.sql => create-ssb-tables-sf1000.sql} | 40 +-
tools/tpcds-tools/bin/run-tpcds-queries.sh | 1 +
tools/tpch-tools/bin/run-tpch-queries.sh | 1 +
809 files changed, 29684 insertions(+), 10047 deletions(-)
create mode 100644 be/src/io/hdfs_util.cpp
create mode 100644 be/src/io/hdfs_util.h
delete mode 100644 be/src/util/hdfs_util.cpp
delete mode 100644 be/src/util/hdfs_util.h
delete mode 100644 be/test/exec/test_data/wal_scanner/wal
create mode 100644 be/test/exec/test_data/wal_scanner/wal_version0
create mode 100644 be/test/exec/test_data/wal_scanner/wal_version1
create mode 100644
docker/thirdparties/docker-compose/hive/scripts/preinstalled_data/parquet_table/parquet_all_types/.test_hidden_dir/wrong_file
create mode 100644
docker/thirdparties/docker-compose/hive/scripts/preinstalled_data/parquet_table/parquet_all_types/test_hidden_file/.hidden_file
create mode 100644 docs/en/docs/sql-manual/sql-functions/combinators/foreach.md
create mode 100644
docs/zh-CN/docs/sql-manual/sql-functions/combinators/foreach.md
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/analysis/EliminateDistinctConstant.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/EnsureProjectOnTopJoin.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/SumLiteralRewrite.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/PathVisibleTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/hive/HiveMetadataOpsTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/rules/rewrite/SumLiteralRewriteTest.java
create mode 100644
regression-test/data/correctness_p0/test_like_predicate_with_concat.out
copy
regression-test/data/{insert_p2/test_group_commit_http_stream_lineitem_schema_change.out
=> fault_injection_p0/test_index_lowercase_fault_injection.out} (81%)
copy regression-test/data/{ => hdfs_vault}/ssb_sf1_p2/sql/flat_q1.1.out (100%)
copy regression-test/data/{ => hdfs_vault}/ssb_sf1_p2/sql/flat_q1.2.out (100%)
copy regression-test/data/{ => hdfs_vault}/ssb_sf1_p2/sql/flat_q1.3.out (100%)
copy regression-test/data/{ => hdfs_vault}/ssb_sf1_p2/sql/flat_q2.1.out (100%)
copy regression-test/data/{ => hdfs_vault}/ssb_sf1_p2/sql/flat_q2.2.out (100%)
copy regression-test/data/{ => hdfs_vault}/ssb_sf1_p2/sql/flat_q2.3.out (100%)
copy regression-test/data/{ => hdfs_vault}/ssb_sf1_p2/sql/flat_q3.1.out (100%)
copy regression-test/data/{ => hdfs_vault}/ssb_sf1_p2/sql/flat_q3.2.out (100%)
copy regression-test/data/{ => hdfs_vault}/ssb_sf1_p2/sql/flat_q3.3.out (100%)
copy regression-test/data/{ => hdfs_vault}/ssb_sf1_p2/sql/flat_q3.4.out (100%)
copy regression-test/data/{ => hdfs_vault}/ssb_sf1_p2/sql/flat_q4.1.out (100%)
copy regression-test/data/{ => hdfs_vault}/ssb_sf1_p2/sql/flat_q4.2.out (100%)
copy regression-test/data/{ => hdfs_vault}/ssb_sf1_p2/sql/flat_q4.3.out (100%)
copy regression-test/data/{inverted_index_p0/ssb_unique_sql_zstd =>
hdfs_vault/ssb_sf1_p2}/sql/q1.1.out (100%)
copy regression-test/data/{inverted_index_p0/ssb_unique_sql_zstd =>
hdfs_vault/ssb_sf1_p2}/sql/q1.2.out (100%)
copy regression-test/data/{inverted_index_p0/ssb_unique_sql_zstd =>
hdfs_vault/ssb_sf1_p2}/sql/q1.3.out (100%)
copy regression-test/data/{variant_github_events_p0/load.out =>
hdfs_vault/ssb_sf1_p2/sql/q2.1.out} (79%)
copy regression-test/data/{variant_github_events_p0/load.out =>
hdfs_vault/ssb_sf1_p2/sql/q2.2.out} (79%)
copy regression-test/data/{variant_github_events_p0/load.out =>
hdfs_vault/ssb_sf1_p2/sql/q2.3.out} (79%)
copy regression-test/data/{variant_github_events_p0/load.out =>
hdfs_vault/ssb_sf1_p2/sql/q3.1.out} (79%)
copy regression-test/data/{variant_github_events_p0/load.out =>
hdfs_vault/ssb_sf1_p2/sql/q3.2.out} (79%)
copy regression-test/data/{variant_github_events_p0/load.out =>
hdfs_vault/ssb_sf1_p2/sql/q3.3.out} (79%)
copy regression-test/data/{inverted_index_p0/ssb_unique_sql_zstd =>
hdfs_vault/ssb_sf1_p2}/sql/q3.4.out (100%)
copy regression-test/data/{variant_github_events_p0/load.out =>
hdfs_vault/ssb_sf1_p2/sql/q4.1.out} (79%)
copy regression-test/data/{inverted_index_p0/ssb_unique_sql_zstd =>
hdfs_vault/ssb_sf1_p2}/sql/q4.2.out (100%)
copy regression-test/data/{inverted_index_p0/ssb_unique_sql_zstd =>
hdfs_vault/ssb_sf1_p2}/sql/q4.3.out (100%)
create mode 100644
regression-test/data/insert_overwrite_p0/insert_overwrite_auto_detect.out
create mode 100644
regression-test/data/inverted_index_p0/test_index_skip_read_data.out
copy regression-test/data/{variant_github_events_p0/load.out =>
load_p0/broker_load/test_multi_table_load.out} (86%)
create mode 100644 regression-test/data/mtmv_p0/test_es_mtmv.out
copy regression-test/data/{variant_github_events_p0/load.out =>
mtmv_p0/test_iceberg_mtmv.out} (71%)
copy regression-test/data/{variant_github_events_p0/load.out =>
mtmv_p0/test_mysql_mtmv.out} (57%)
create mode 100644 regression-test/data/mtmv_p0/test_paimon_mtmv.out
copy regression-test/data/{variant_github_events_p0/load.out =>
nereids_p0/limit/filterLimitProject.out} (74%)
create mode 100644
regression-test/data/nereids_rules_p0/eliminate_distinct_constant/eliminate_distinct_constant.out
delete mode 100644
regression-test/data/nereids_rules_p0/eliminate_gby_key/eliminate_gby_key.out
create mode 100644
regression-test/data/nereids_rules_p0/mv/tpch/mv_tpch_test.out
create mode 100644 regression-test/data/nereids_rules_p0/sumRewrite.out
create mode 100644 regression-test/data/nereids_syntax_p0/array_compare.out
create mode 100644
regression-test/suites/correctness_p0/test_like_predicate_with_concat.groovy
create mode 100644
regression-test/suites/fault_injection_p0/test_index_lowercase_fault_injection.groovy
create mode 100644
regression-test/suites/hdfs_vault/ssb_sf1_p2/ddl/customer_create.sql
copy regression-test/suites/{inverted_index_p0/ssb_unique_sql_zstd =>
hdfs_vault/ssb_sf1_p2}/ddl/customer_delete.sql (100%)
create mode 100644
regression-test/suites/hdfs_vault/ssb_sf1_p2/ddl/date_create.sql
copy regression-test/suites/{inverted_index_p0/ssb_unique_sql_zstd =>
hdfs_vault/ssb_sf1_p2}/ddl/date_delete.sql (100%)
create mode 100644
regression-test/suites/hdfs_vault/ssb_sf1_p2/ddl/lineorder_create.sql
copy regression-test/suites/{inverted_index_p0/ssb_unique_sql_zstd =>
hdfs_vault/ssb_sf1_p2}/ddl/lineorder_delete.sql (100%)
copy tools/ssb-tools/ddl/create-ssb-flat-table.sql =>
regression-test/suites/hdfs_vault/ssb_sf1_p2/ddl/lineorder_flat_create.sql (55%)
copy regression-test/suites/{nereids_rules_p0/mv/ssb =>
hdfs_vault/ssb_sf1_p2}/ddl/lineorder_flat_delete.sql (100%)
create mode 100644
regression-test/suites/hdfs_vault/ssb_sf1_p2/ddl/part_create.sql
copy regression-test/suites/{inverted_index_p0/ssb_unique_sql_zstd =>
hdfs_vault/ssb_sf1_p2}/ddl/part_delete.sql (100%)
create mode 100644
regression-test/suites/hdfs_vault/ssb_sf1_p2/ddl/supplier_create.sql
copy regression-test/suites/{inverted_index_p0/ssb_unique_sql_zstd =>
hdfs_vault/ssb_sf1_p2}/ddl/supplier_delete.sql (100%)
create mode 100644 regression-test/suites/hdfs_vault/ssb_sf1_p2/load.groovy
copy regression-test/suites/{ssb_sf0.1_p1 =>
hdfs_vault/ssb_sf1_p2}/sql/flat_q1.1.sql (100%)
copy regression-test/suites/{ssb_sf0.1_p1 =>
hdfs_vault/ssb_sf1_p2}/sql/flat_q1.2.sql (100%)
copy regression-test/suites/{ssb_sf0.1_p1 =>
hdfs_vault/ssb_sf1_p2}/sql/flat_q1.3.sql (100%)
copy regression-test/suites/{ssb_sf0.1_p1 =>
hdfs_vault/ssb_sf1_p2}/sql/flat_q2.1.sql (100%)
copy regression-test/suites/{ssb_sf0.1_p1 =>
hdfs_vault/ssb_sf1_p2}/sql/flat_q2.2.sql (100%)
copy regression-test/suites/{ssb_sf0.1_p1 =>
hdfs_vault/ssb_sf1_p2}/sql/flat_q2.3.sql (100%)
copy regression-test/suites/{ssb_sf0.1_p1 =>
hdfs_vault/ssb_sf1_p2}/sql/flat_q3.1.sql (100%)
copy regression-test/suites/{ssb_sf0.1_p1 =>
hdfs_vault/ssb_sf1_p2}/sql/flat_q3.2.sql (100%)
copy regression-test/suites/{ssb_sf0.1_p1 =>
hdfs_vault/ssb_sf1_p2}/sql/flat_q3.3.sql (100%)
copy regression-test/suites/{ssb_sf0.1_p1 =>
hdfs_vault/ssb_sf1_p2}/sql/flat_q3.4.sql (100%)
copy regression-test/suites/{ssb_sf0.1_p1 =>
hdfs_vault/ssb_sf1_p2}/sql/flat_q4.1.sql (100%)
copy regression-test/suites/{ssb_sf0.1_p1 =>
hdfs_vault/ssb_sf1_p2}/sql/flat_q4.2.sql (100%)
copy regression-test/suites/{ssb_sf0.1_p1 =>
hdfs_vault/ssb_sf1_p2}/sql/flat_q4.3.sql (100%)
copy regression-test/suites/{inverted_index_p0/ssb_unique_sql_zstd =>
hdfs_vault/ssb_sf1_p2}/sql/q1.1.sql (100%)
copy regression-test/suites/{inverted_index_p0/ssb_unique_sql_zstd =>
hdfs_vault/ssb_sf1_p2}/sql/q1.2.sql (100%)
copy regression-test/suites/{inverted_index_p0/ssb_unique_sql_zstd =>
hdfs_vault/ssb_sf1_p2}/sql/q1.3.sql (100%)
copy regression-test/suites/{inverted_index_p0/ssb_unique_sql_zstd =>
hdfs_vault/ssb_sf1_p2}/sql/q2.1.sql (100%)
copy regression-test/suites/{inverted_index_p0/ssb_unique_sql_zstd =>
hdfs_vault/ssb_sf1_p2}/sql/q2.2.sql (100%)
copy regression-test/suites/{inverted_index_p0/ssb_unique_sql_zstd =>
hdfs_vault/ssb_sf1_p2}/sql/q2.3.sql (100%)
copy regression-test/suites/{inverted_index_p0/ssb_unique_sql_zstd =>
hdfs_vault/ssb_sf1_p2}/sql/q3.1.sql (100%)
copy regression-test/suites/{inverted_index_p0/ssb_unique_sql_zstd =>
hdfs_vault/ssb_sf1_p2}/sql/q3.2.sql (100%)
copy regression-test/suites/{inverted_index_p0/ssb_unique_sql_zstd =>
hdfs_vault/ssb_sf1_p2}/sql/q3.3.sql (100%)
copy regression-test/suites/{inverted_index_p0/ssb_unique_sql_zstd =>
hdfs_vault/ssb_sf1_p2}/sql/q3.4.sql (100%)
copy regression-test/suites/{inverted_index_p0/ssb_unique_sql_zstd =>
hdfs_vault/ssb_sf1_p2}/sql/q4.1.sql (100%)
copy regression-test/suites/{inverted_index_p0/ssb_unique_sql_zstd =>
hdfs_vault/ssb_sf1_p2}/sql/q4.2.sql (100%)
copy regression-test/suites/{inverted_index_p0/ssb_unique_sql_zstd =>
hdfs_vault/ssb_sf1_p2}/sql/q4.3.sql (100%)
create mode 100644
regression-test/suites/insert_overwrite_p0/insert_overwrite_auto_detect.groovy
create mode 100644
regression-test/suites/inverted_index_p0/test_index_skip_read_data.groovy
create mode 100644
regression-test/suites/load_p0/broker_load/test_multi_table_load.groovy
create mode 100644 regression-test/suites/mtmv_p0/test_es_mtmv.groovy
create mode 100644 regression-test/suites/mtmv_p0/test_iceberg_mtmv.groovy
create mode 100644 regression-test/suites/mtmv_p0/test_mysql_mtmv.groovy
create mode 100644 regression-test/suites/mtmv_p0/test_paimon_mtmv.groovy
create mode 100644
regression-test/suites/mv_p0/test_create_mv/test_create_mv.groovy
create mode 100644
regression-test/suites/nereids_p0/limit/filterLimitProject.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/eliminate_distinct_constant/eliminate_distinct_constant.groovy
copy regression-test/suites/{tpch_sf0.1_p1 =>
nereids_rules_p0/mv/tpch}/ddl/create_table.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
nereids_rules_p0/mv/tpch}/ddl/customer.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
nereids_rules_p0/mv/tpch}/ddl/customer_delete.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
nereids_rules_p0/mv/tpch}/ddl/lineitem.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
nereids_rules_p0/mv/tpch}/ddl/lineitem_delete.sql (100%)
copy regression-test/suites/{nereids_tpch_p0 =>
nereids_rules_p0/mv/tpch}/ddl/nation.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
nereids_rules_p0/mv/tpch}/ddl/nation_delete.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
nereids_rules_p0/mv/tpch}/ddl/orders.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
nereids_rules_p0/mv/tpch}/ddl/orders_delete.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
nereids_rules_p0/mv/tpch}/ddl/part.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
nereids_rules_p0/mv/tpch}/ddl/part_delete.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
nereids_rules_p0/mv/tpch}/ddl/partsupp.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
nereids_rules_p0/mv/tpch}/ddl/partsupp_delete.sql (100%)
copy regression-test/suites/{nereids_tpch_p0 =>
nereids_rules_p0/mv/tpch}/ddl/region.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
nereids_rules_p0/mv/tpch}/ddl/region_delete.sql (100%)
copy regression-test/suites/{nereids_tpch_p0 =>
nereids_rules_p0/mv/tpch}/ddl/revenue1.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
nereids_rules_p0/mv/tpch}/ddl/revenue1_delete.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
nereids_rules_p0/mv/tpch}/ddl/supplier.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
nereids_rules_p0/mv/tpch}/ddl/supplier_delete.sql (100%)
create mode 100644
regression-test/suites/nereids_rules_p0/mv/tpch/mv_tpch_test.groovy
create mode 100644 regression-test/suites/nereids_rules_p0/sumRewrite.groovy
create mode 100644
regression-test/suites/nereids_syntax_p0/array_compare.groovy
delete mode 100644
regression-test/suites/partition_p2/auto_partition/diff_data/thread_load_1.sh
delete mode 100644
regression-test/suites/partition_p2/auto_partition/diff_data/thread_load_2.sh
delete mode 100644
regression-test/suites/partition_p2/auto_partition/same_data/thread_load_1.sh
delete mode 100644
regression-test/suites/partition_p2/auto_partition/same_data/thread_load_2.sh
delete mode 100644
regression-test/suites/partition_p2/auto_partition/two_stream_load/thread_load_1.sh
delete mode 100644
regression-test/suites/partition_p2/auto_partition/two_stream_load/thread_load_2.sh
copy tools/ssb-tools/ddl/{create-ssb-flat-table.sql =>
create-ssb-flat-tables-sf1.sql} (93%)
copy tools/ssb-tools/ddl/{create-ssb-flat-table.sql =>
create-ssb-flat-tables-sf100.sql} (93%)
rename tools/ssb-tools/ddl/{create-ssb-flat-table.sql =>
create-ssb-flat-tables-sf1000.sql} (90%)
copy tools/ssb-tools/ddl/{create-ssb-tables.sql => create-ssb-tables-sf1.sql}
(87%)
copy tools/ssb-tools/ddl/{create-ssb-tables.sql =>
create-ssb-tables-sf100.sql} (87%)
rename tools/ssb-tools/ddl/{create-ssb-tables.sql =>
create-ssb-tables-sf1000.sql} (85%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
