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
omit 858f4bf078a Support high priority column stats auto collection. * fix
visible column (#33023) * Collect high priority columns. (#31235) * High
priority queue and map. (#31509) * Support column level health value. (#31794)
* Support follower sync query columns to master. (#31859) * Support show auto
analyze pending jobs. (#31926) * Check column health value earlier, show job
priority. (#32064) * support window (#32094) * Refactor. (#32273) * refactor2
(#32278) * Unit test (#32398) [...]
add 60bae68729a (cloud-merge) Support more multi case strategies about
cache (#32804)
add b7381c13017 [test](hll) fix unstable case without order by clause
(#33947)
add 3f2904b35b9 [fix](case) test_alter_colocate_table.groovy (#33981)
add ebb6831f505 [test](p0 case) Increase the batch size in test leading
cases (#33994)
add ed4e4bf05cd [FIX]fix cidr func with const param (#33968)
add 21a8c626b13 [fix](jni-connector) avoid core dump if init connector
failed (#34007)
add 4559ddebe29 [bug](random distribution) fix data loss and incorrect in
random distribution table #33962
add 29a7d066899 [fix](stream agg) fix coredump when close if open failed
(#33978)
add feaf51c0a55 [Fix](hdfs-writer) Fix hdfs file writer core with `check
failed: _ref_cnt == 0` in dtor of `HdfsFileWriter`. (#33959)
add 10a937aa875 [test](hive)add subnet for hive docker compose (#34000)
add 421923c8f58 [fix](exception) Fix Block noexcept method not throw
exception (#34002)
add 3862d5feb26 [fix](gc) remove useless code due to #25921 (#33999)
add b4405f6f10a [bug](fold) fix fold date/datetime error as null (#33845)
add 465090c1471 [fix](merge-cloud) Fix incorrect num_expired in
`recycle_rowsets()` (#34022)
add a78a237997d [fix](merge-cloud) Remove expired loadJob when
replayEndLoadJob (#34020)
add 8d019eea459 [behavior change](fe) Change `ShowProcessStmt` output
column format (#33975)
add 6bcd1dfdb8a [fix](regression test) fix
test_decommission_with_replica_num_fail due to set
force_olap_table_replication_num (#33941)
add 63f7704140a [fix](group commit) Fix the timeout to wait wal finished
when schema change (#34021)
add 5c9f68fdc89 [test](regression) add non light schema change cases when
enable memtable on sink node (#31851)
add c530759a618 [test](hive) run suite cases both in hive2 and hive3
(#33874)
add 828c0f2c14a [bug](test) fix test case failed with fuuzy fold constatnt
to false (#34052)
add 89be8b001fd [fix](merge-cloud) fix incorrect path of temporary files
created by vertical compaction (#34044)
add df07e1a4079 [fix](routine-load) fix routine load lag is negative
(#33846)
add bf2cb5c604d [feature](Nereids): Add DAG to store function dependencies
(#33882)
add baaa53d8551 [Feature](top-n) support topn filter on vscan node (#33496)
add 9e219f3aa05 [chore](session_variable) Add 'data_queue_max_blocks' to
prevent the DataQueue from occupying too much memory. (#34017)
add 1330dfca07b [fix](bdb) Write OP_TIMESTAMP operation until it successed
(#33967)
add 5faa6662f42 [docker](k8s)k8s docker script support create account and
remove some useless code (#33889)
add c2c250c0bb1 [improve](table function) opt
explode/explode_map/explode_json table function (#33904)
add 92e2f1c74fc [queryretry](errormsg) should not send retry request to BE
again if the query is timeout (#33984)
add 0132ef8d2d3 [fix][compile] Resolve time_point type mismatch on MacOS
and Linux (#34054)
add 80e1f1b1963 [fix](mtmv) Mv check name (#34016)
add fb24b1f9cf1 [Feat](nereids) nereids add alter view (#33970)
add fc9423ffee3 [Feat](nereids) add expression rewrite rule
LikeToEqualRewrite (#33803)
add 2e8a2a69411 [Feat](nereids) add transform rule
SimplifyWindowExpression (#33647)
add dd1895ff81b [opt](nereids)project sub expression in other condition
for nested loop join (#32697)
add 4420027aef1 [improvement](spill) improve config of spill thread pool
(#33992)
add 889d44b0f68 [feature](profile) sort pipelineX task by total time #34053
add e86c599a819 [improvement](mtmv) Optimize the nested materialized view
rewrite performance (#34050)
add c7a113306df [fix](fd) release fd for shutdown tablets (#34003)
add 81c6231099b [refactor](errormessage) step1: unify the status usage in
FE (#34062)
add ce4ca1e8f25 [bugfix](core) close method should check if the pointer is
nullptr (#34067)
add c782a1a6079 [feature](cloud) Support decomission in cloud (#33201)
add 889e1381739 [fix](Cloud) Use user specify storage vault first (#34059)
add 59024bacc6b [fix](session-var) force_sample_analyze forwarding to
master (#34048)
add 1e53a0b9d41 [fix](auto bucket) Fix auto bucket regression case
occasional fail (#34069)
add 440a926c014 [fix](parse) set origin stmt for select stmt generated
from show stmt (#34015)
add b63820fe48f [fix](auth)can not grant priv to __internal_schema (#34009)
add 059ead60a9f [pipeline](fix) Prevent re-cancel pipeline tasks (#34073)
add 19fed2678fc [fix](mtmv) Fix exception when create materialized view
with cte (#33988)
add 204d45d9cea [fix](decommission) fix cann't decommission mtmv (#33823)
add cfa0f2d69c3 [fix](cloud-merge) init _index_offset in case undefined
behaviour and fix index queue error (#34080)
add 550ed2b6e75 [Fix](executor)Fix when Fe send empty wg list to be may
cause query failed. (#34074)
add 79890c1f641 [feature](cloud) introduce copy into (#32759)
new 4c8a145e5a1 Support high priority column stats auto collection. * fix
visible column (#33023) * Collect high priority columns. (#31235) * High
priority queue and map. (#31509) * Support column level health value. (#31794)
* Support follower sync query columns to master. (#31859) * Support show auto
analyze pending jobs. (#31926) * Check column health value earlier, show job
priority. (#32064) * support window (#32094) * Refactor. (#32273) * refactor2
(#32278) * Unit test (#32398) [...]
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 (858f4bf078a)
\
N -- N -- N refs/heads/high-priority-column (4c8a145e5a1)
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 1 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/topic_subscriber.cpp | 6 +-
be/src/agent/workload_group_listener.cpp | 27 +-
be/src/cloud/cloud_backend_service.cpp | 145 +
be/src/cloud/cloud_backend_service.h | 20 +
be/src/cloud/cloud_base_compaction.cpp | 4 +-
be/src/cloud/cloud_cumulative_compaction.cpp | 8 +-
be/src/cloud/cloud_full_compaction.cpp | 4 +-
be/src/cloud/cloud_internal_service.cpp | 59 +
be/src/cloud/cloud_internal_service.h | 6 +
be/src/cloud/cloud_tablet.cpp | 43 +-
be/src/cloud/cloud_tablet.h | 6 +-
be/src/cloud/cloud_tablet_hotspot.cpp | 197 +
be/src/cloud/cloud_tablet_hotspot.h | 77 +
be/src/cloud/cloud_warm_up_manager.cpp | 208 +
be/src/cloud/cloud_warm_up_manager.h | 86 +
be/src/cloud/config.cpp | 2 +
be/src/cloud/config.h | 3 +
be/src/common/config.cpp | 16 +-
be/src/common/config.h | 6 +-
be/src/io/cache/block_file_cache_downloader.cpp | 408 +
be/src/io/cache/block_file_cache_downloader.h | 109 +
be/src/io/cache/block_file_cache_factory.cpp | 8 +
be/src/io/cache/block_file_cache_factory.h | 2 +
be/src/io/cache/file_block.cpp | 2 +-
be/src/io/file_factory.cpp | 10 +-
be/src/io/fs/hdfs_file_system.cpp | 12 +-
be/src/io/fs/hdfs_file_system.h | 4 +-
be/src/io/fs/hdfs_file_writer.cpp | 11 +-
be/src/io/fs/hdfs_file_writer.h | 11 +-
be/src/io/fs/s3_file_bufferpool.cpp | 81 +
be/src/io/fs/s3_file_bufferpool.h | 22 +
be/src/io/fs/s3_file_system.h | 3 +
be/src/io/fs/s3_file_writer.cpp | 1 -
be/src/io/hdfs_util.cpp | 20 +-
be/src/io/hdfs_util.h | 23 +-
be/src/olap/base_tablet.h | 2 +
be/src/olap/compaction.cpp | 2 +
be/src/olap/memtable_flush_executor.cpp | 3 +-
be/src/olap/merger.cpp | 6 +
be/src/olap/parallel_scanner_builder.cpp | 2 +
be/src/olap/rowset/beta_rowset.cpp | 24 +-
be/src/olap/rowset/beta_rowset.h | 3 +
be/src/olap/rowset/beta_rowset_writer.cpp | 1 +
be/src/olap/rowset/beta_rowset_writer_v2.cpp | 1 +
be/src/olap/rowset/rowset.cpp | 6 +
be/src/olap/rowset/rowset.h | 4 +
be/src/olap/rowset/vertical_beta_rowset_writer.cpp | 10 +-
be/src/olap/storage_engine.cpp | 1 -
be/src/olap/storage_engine.h | 2 -
be/src/olap/tablet.cpp | 13 +
be/src/olap/tablet.h | 4 +
be/src/olap/tablet_manager.cpp | 42 +-
be/src/olap/tablet_meta.h | 12 +
be/src/pipeline/exec/data_queue.cpp | 8 +-
be/src/pipeline/exec/data_queue.h | 4 +
.../distinct_streaming_aggregation_operator.cpp | 5 +-
.../exec/distinct_streaming_aggregation_operator.h | 1 +
be/src/pipeline/exec/es_scan_operator.cpp | 4 +-
be/src/pipeline/exec/es_scan_operator.h | 2 +-
be/src/pipeline/exec/exchange_sink_operator.cpp | 3 +-
be/src/pipeline/exec/file_scan_operator.cpp | 4 +-
be/src/pipeline/exec/file_scan_operator.h | 2 +-
be/src/pipeline/exec/meta_scan_operator.cpp | 2 +-
be/src/pipeline/exec/meta_scan_operator.h | 2 +-
be/src/pipeline/exec/olap_scan_operator.cpp | 4 +-
be/src/pipeline/exec/olap_scan_operator.h | 4 +-
.../exec/partitioned_aggregation_sink_operator.cpp | 2 +-
.../exec/partitioned_aggregation_sink_operator.h | 46 +-
.../partitioned_aggregation_source_operator.cpp | 2 +-
.../exec/partitioned_hash_join_probe_operator.cpp | 12 +-
.../exec/partitioned_hash_join_sink_operator.cpp | 4 +-
be/src/pipeline/exec/scan_operator.cpp | 40 +-
be/src/pipeline/exec/scan_operator.h | 15 +-
be/src/pipeline/exec/sort_sink_operator.cpp | 2 +-
be/src/pipeline/exec/spill_sort_sink_operator.cpp | 140 +-
.../pipeline/exec/spill_sort_source_operator.cpp | 3 +-
.../exec/streaming_aggregation_operator.cpp | 4 +-
.../pipeline/exec/streaming_aggregation_operator.h | 2 +-
be/src/pipeline/exec/union_sink_operator.cpp | 1 +
be/src/pipeline/pipeline_fragment_context.cpp | 5 +
be/src/pipeline/pipeline_x/dependency.cpp | 1 -
be/src/pipeline/pipeline_x/dependency.h | 6 +-
.../pipeline_x/pipeline_x_fragment_context.cpp | 10 +
be/src/runtime/exec_env.h | 29 +-
be/src/runtime/exec_env_init.cpp | 32 +-
be/src/runtime/group_commit_mgr.cpp | 27 +-
be/src/runtime/runtime_predicate.cpp | 6 +-
be/src/runtime/runtime_predicate.h | 17 +
be/src/runtime/runtime_state.h | 18 +-
be/src/runtime/thread_context.h | 32 +-
be/src/runtime/workload_group/workload_group.cpp | 4 +-
be/src/runtime/workload_group/workload_group.h | 7 +-
.../workload_group/workload_group_manager.cpp | 67 +-
be/src/service/backend_service.cpp | 18 +-
be/src/service/backend_service.h | 8 +-
be/src/util/runtime_profile.cpp | 12 +
be/src/util/runtime_profile.h | 2 +
be/src/util/s3_rate_limiter.cpp | 129 +
be/src/util/s3_rate_limiter.h | 79 +
be/src/util/s3_util.cpp | 4 +
be/src/util/s3_util.h | 24 +
be/src/vec/columns/subcolumn_tree.h | 1 +
be/src/vec/core/block.cpp | 7 +
be/src/vec/exec/format/csv/csv_reader.cpp | 8 +-
be/src/vec/exec/jni_connector.cpp | 5 +-
be/src/vec/exec/scan/new_olap_scanner.cpp | 26 +-
be/src/vec/exprs/table_function/table_function.h | 12 +-
.../table_function/table_function_factory.cpp | 27 +-
be/src/vec/exprs/table_function/vexplode.cpp | 25 +-
be/src/vec/exprs/table_function/vexplode.h | 1 +
.../exprs/table_function/vexplode_json_array.cpp | 213 +-
.../vec/exprs/table_function/vexplode_json_array.h | 234 +-
be/src/vec/exprs/table_function/vexplode_map.cpp | 34 +
be/src/vec/exprs/table_function/vexplode_map.h | 1 +
be/src/vec/exprs/vliteral.cpp | 6 -
be/src/vec/exprs/vliteral.h | 2 -
be/src/vec/exprs/vruntimefilter_wrapper.cpp | 88 +-
be/src/vec/exprs/vtopn_pred.h | 116 +
be/src/vec/functions/function_ip.h | 127 +-
be/src/vec/olap/vertical_merge_iterator.cpp | 15 +-
be/src/vec/sink/writer/vtablet_writer.cpp | 27 +
be/src/vec/spill/spill_stream.cpp | 64 +-
be/src/vec/spill/spill_stream.h | 10 +-
be/src/vec/spill/spill_stream_manager.cpp | 25 +-
be/src/vec/spill/spill_stream_manager.h | 10 +-
be/src/vec/utils/util.hpp | 59 +
be/test/vec/olap/vertical_compaction_test.cpp | 5 +
cloud/src/recycler/recycler.cpp | 2 +-
cloud/src/recycler/s3_accessor.cpp | 3 +-
docker/runtime/be/resource/be_entrypoint.sh | 35 +-
.../runtime/broker/resource/broker_entrypoint.sh | 12 -
docker/runtime/fe/resource/fe_entrypoint.sh | 45 +-
.../hive/hadoop-hive-metastore.env.tpl | 2 +
.../docker-compose/hive/hadoop-hive.env | 2 +
.../docker-compose/hive/hive-2x.yaml.tpl | 4 +
.../docker-compose/hive/hive-2x_settings.env | 8 +-
.../docker-compose/hive/hive-3x.yaml.tpl | 4 +
.../docker-compose/hive/hive-3x_settings.env | 8 +-
docker/thirdparties/run-thirdparties-docker.sh | 16 +-
.../main/java/org/apache/doris/common/Config.java | 63 +-
.../antlr4/org/apache/doris/nereids/DorisParser.g4 | 2 +
fe/fe-core/src/main/cup/sql_parser.cup | 158 +-
.../doris/alter/MaterializedViewHandler.java | 16 +-
.../java/org/apache/doris/alter/SystemHandler.java | 6 +-
.../org/apache/doris/analysis/AlterViewStmt.java | 9 +
.../doris/analysis/CancelCloudWarmUpStmt.java | 89 +
.../org/apache/doris/analysis/CopyFromParam.java | 261 +
.../apache/doris/analysis/CopyIntoProperties.java | 95 +
.../org/apache/doris/analysis/CopyProperties.java | 230 +
.../java/org/apache/doris/analysis/CopyStmt.java | 271 +
.../org/apache/doris/analysis/CreateStageStmt.java | 192 +
.../org/apache/doris/analysis/DataDescription.java | 14 +
.../org/apache/doris/analysis/DropStageStmt.java | 62 +
.../doris/analysis/ShowCacheHotSpotStmt.java | 186 +
.../apache/doris/analysis/ShowCloudWarmUpStmt.java | 129 +
.../org/apache/doris/analysis/ShowCopyStmt.java | 216 +
.../org/apache/doris/analysis/ShowLoadStmt.java | 51 +-
.../apache/doris/analysis/ShowProcesslistStmt.java | 19 +-
.../org/apache/doris/analysis/ShowStageStmt.java | 97 +
.../org/apache/doris/analysis/StageAndPattern.java | 30 +-
.../org/apache/doris/analysis/StageProperties.java | 233 +
.../org/apache/doris/analysis/TablePattern.java | 13 -
.../apache/doris/analysis/WarmUpClusterStmt.java | 166 +
.../java/org/apache/doris/catalog/Database.java | 12 +
.../main/java/org/apache/doris/catalog/Env.java | 25 +-
.../java/org/apache/doris/catalog/EnvFactory.java | 6 +
.../java/org/apache/doris/catalog/OlapTable.java | 4 +
.../main/java/org/apache/doris/catalog/Table.java | 30 +-
.../clone/ColocateTableCheckerAndBalancer.java | 25 +-
.../java/org/apache/doris/clone/TabletChecker.java | 30 +-
.../apache/doris/cloud/CacheHotspotManager.java | 715 +
.../doris/cloud/CacheHotspotManagerUtils.java | 251 +
.../org/apache/doris/cloud/CloudWarmUpJob.java | 513 +
.../doris/cloud/catalog/CloudClusterChecker.java | 7 +-
.../org/apache/doris/cloud/catalog/CloudEnv.java | 110 +
.../doris/cloud/catalog/CloudTabletRebalancer.java | 32 +-
.../doris/cloud/catalog/CloudUpgradeMgr.java | 153 +
.../cloud/datasource/CloudInternalCatalog.java | 397 +-
.../org/apache/doris/cloud/stage/StageUtil.java | 469 +
.../apache/doris/cloud/transaction/TxnUtil.java | 6 +-
.../java/org/apache/doris/common/FeConstants.java | 4 +
.../java/org/apache/doris/common/IdGenerator.java | 6 +
.../org/apache/doris/common/InternalErrorCode.java | 3 +
.../main/java/org/apache/doris/common/Status.java | 48 +-
.../org/apache/doris/common/ThreadPoolManager.java | 7 +
.../org/apache/doris/common/proc/LoadProcDir.java | 20 +-
.../doris/common/publish/TopicPublisherThread.java | 24 +-
.../common/publish/WorkloadGroupPublisher.java | 14 +-
.../doris/common/util/FileFormatConstants.java | 1 +
.../apache/doris/datasource/InternalCatalog.java | 2 +-
.../apache/doris/datasource/LoadScanProvider.java | 1 +
.../doris/datasource/hive/HMSExternalTable.java | 4 +-
.../httpv2/config/HttpToHttpsJettyConfig.java | 6 +
.../doris/httpv2/controller/SessionController.java | 19 +-
.../apache/doris/httpv2/rest/CopyIntoAction.java | 286 +
.../doris/httpv2/rest/RestBaseController.java | 8 +
.../doris/httpv2/rest/StmtExecutionAction.java | 2 +-
.../doris/httpv2/util/StatementSubmitter.java | 110 +-
.../org/apache/doris/journal/JournalEntity.java | 11 +-
.../apache/doris/journal/bdbje/BDBJEJournal.java | 22 +-
.../org/apache/doris/load/BrokerFileGroup.java | 7 +
.../apache/doris/load/loadv2/BrokerLoadJob.java | 117 +-
.../doris/load/loadv2/BrokerLoadPendingTask.java | 6 +-
.../load/loadv2/BrokerPendingTaskAttachment.java | 4 +
.../org/apache/doris/load/loadv2/BulkLoadJob.java | 40 +-
.../doris/load/loadv2/CleanCopyJobScheduler.java | 65 +
.../apache/doris/load/loadv2/CleanCopyJobTask.java | 72 +
.../java/org/apache/doris/load/loadv2/CopyJob.java | 314 +
.../doris/load/loadv2/CopyLoadPendingTask.java | 360 +
.../java/org/apache/doris/load/loadv2/LoadJob.java | 205 +-
.../doris/load/loadv2/LoadJobFinalOperation.java | 43 +
.../apache/doris/load/loadv2/LoadLoadingTask.java | 63 +
.../org/apache/doris/load/loadv2/LoadManager.java | 125 +-
.../load/routineload/KafkaRoutineLoadJob.java | 15 +-
.../java/org/apache/doris/metric/MetricRepo.java | 26 +
.../org/apache/doris/nereids/StatementContext.java | 17 +-
.../doris/nereids/jobs/executor/Rewriter.java | 8 +-
.../java/org/apache/doris/nereids/memo/Memo.java | 4 +
.../apache/doris/nereids/memo/StructInfoMap.java | 59 +-
.../doris/nereids/parser/LogicalPlanBuilder.java | 13 +
.../apache/doris/nereids/properties/FuncDeps.java | 63 +
.../doris/nereids/properties/FuncDepsDAG.java | 99 +
.../org/apache/doris/nereids/rules/RuleType.java | 2 +
.../nereids/rules/exploration/mv/StructInfo.java | 14 +-
.../rules/expression/ExpressionOptimization.java | 4 +-
.../expression/rules/FoldConstantRuleOnBE.java | 50 +-
.../rules/expression/rules/LikeToEqualRewrite.java | 70 +
...ProjectOtherJoinConditionForNestedLoopJoin.java | 127 +
.../rules/rewrite/SimplifyWindowExpression.java | 123 +
.../doris/nereids/trees/expressions/ExprId.java | 9 +-
.../expressions/StatementScopeIdGenerator.java | 5 +-
.../expressions/functions/scalar/Tokenize.java | 10 +-
.../apache/doris/nereids/trees/plans/PlanType.java | 3 +-
.../trees/plans/commands/AlterViewCommand.java | 49 +
.../plans/commands/UpdateMvByPartitionCommand.java | 39 +-
.../trees/plans/commands/info/AlterViewInfo.java | 121 +
.../{CreateViewInfo.java => BaseViewInfo.java} | 112 +-
.../trees/plans/commands/info/CreateMTMVInfo.java | 5 +
.../trees/plans/commands/info/CreateViewInfo.java | 221 +-
.../plans/commands/insert/OlapInsertExecutor.java | 18 +
.../trees/plans/visitor/CommandVisitor.java | 5 +
.../java/org/apache/doris/persist/EditLog.java | 15 +-
.../doris/persist/meta/MetaPersistMethod.java | 6 +
.../doris/persist/meta/PersistMetaModules.java | 2 +-
.../org/apache/doris/planner/OlapScanNode.java | 6 +-
.../java/org/apache/doris/qe/ConnectContext.java | 8 +-
.../java/org/apache/doris/qe/ConnectScheduler.java | 4 +-
.../main/java/org/apache/doris/qe/Coordinator.java | 24 +-
.../main/java/org/apache/doris/qe/DdlExecutor.java | 109 +
.../java/org/apache/doris/qe/PointQueryExec.java | 22 +-
.../main/java/org/apache/doris/qe/QueryState.java | 10 +
.../java/org/apache/doris/qe/ResultReceiver.java | 28 +-
.../java/org/apache/doris/qe/SessionVariable.java | 11 +-
.../java/org/apache/doris/qe/ShowExecutor.java | 98 +-
.../java/org/apache/doris/qe/StmtExecutor.java | 55 +-
.../org/apache/doris/qe/cache/CacheBeProxy.java | 18 +-
.../org/apache/doris/qe/cache/PartitionCache.java | 3 +-
.../apache/doris/service/FrontendServiceImpl.java | 2 +-
.../arrowflight/FlightSqlConnectProcessor.java | 8 +-
.../apache/doris/statistics/StatisticsCache.java | 5 +-
.../main/java/org/apache/doris/system/Backend.java | 12 +-
fe/fe-core/src/main/jflex/sql_scanner.flex | 5 +
.../org/apache/doris/analysis/CopyIntoTest.java | 573 +
.../java/org/apache/doris/analysis/StageTest.java | 341 +
.../apache/doris/cloud/stage/StageUtilTest.java | 109 +
.../doris/cluster/DecommissionBackendTest.java | 106 +-
.../org/apache/doris/common/GenericPoolTest.java | 12 +-
.../org/apache/doris/http/DorisHttpTestCase.java | 2 +
.../java/org/apache/doris/httpv2/CopyIntoTest.java | 186 +
.../org/apache/doris/load/loadv2/CopyJobTest.java | 147 +
.../doris/load/loadv2/CopyLoadPendingTaskTest.java | 363 +
.../doris/nereids/properties/FuncDepsDAGTest.java | 75 +
.../doris/nereids/properties/UniqueTest.java | 2 +-
.../expression/rules/LikeToEqualRewriteTest.java | 147 +
...ectOtherJoinConditionForNestedLoopJoinTest.java | 82 +
.../rules/rewrite/PullUpProjectUnderLimitTest.java | 5 +-
.../rules/rewrite/PullUpProjectUnderTopNTest.java | 5 +-
.../doris/persist/ModifyCloudWarmUpJobTest.java | 117 +
.../org/apache/doris/qe/ConnectContextTest.java | 4 +-
.../apache/doris/utframe/MockedBackendFactory.java | 16 +-
.../org/apache/doris/utframe/MockedMetaServer.java | 71 +
.../doris/utframe/MockedMetaServerFactory.java | 91 +
.../apache/doris/utframe/TestWithFeService.java | 6 +-
.../org/apache/doris/utframe/UtFrameUtils.java | 11 +
fe/fe-core/src/test/resources/stageUtilTest.txt | 4956 ++
gensrc/proto/internal_service.proto | 4 +-
gensrc/script/gen_build_version.sh | 4 +-
gensrc/thrift/BackendService.thrift | 12 +-
gensrc/thrift/PaloInternalService.thrift | 3 +
gensrc/thrift/PlanNodes.thrift | 2 +
regression-test/conf/regression-conf.groovy | 16 +-
.../data/clone_p0/test_decommission_mtmv.out | 13 +
.../data/ddl_p0/test_alter_view_nereids.out | 17 +
.../export/hive_read/orc/test_hive_read_orc.out | 45 +
.../orc/test_hive_read_orc_complex_type.out | 123 +
.../hive_read/parquet/test_hive_read_parquet.out | 45 +
.../parquet/test_hive_read_parquet_comlex_type.out | 123 +
.../external_table_p0/hive/ddl/test_hive_ctas.out | 92 +
.../hive/ddl/test_hive_write_type.out | 18 +
.../external_table_p0/hive/hive_tpch_sf1_orc.out | 60390 +++++++++++++++++++
.../hive/hive_tpch_sf1_parquet.out | 60390 +++++++++++++++++++
.../hive/jdbc_hive_meta/test_jdbc_hive_orc.out | 102 +
.../hive/test_different_column_orders.out | 28 +
.../hive/test_hive_basic_type.out | 266 +
.../hive/test_hive_broker_scan.out | 8 +
.../data/external_table_p0/hive/test_hive_orc.out | 154 +
.../external_table_p0/hive/test_hive_other.out | 690 +
.../external_table_p0/hive/test_hive_parquet.out | 10158 ++++
.../hive/test_hive_partitions.out | 121 +
.../hive/test_hive_query_cache.out | 212 +
.../hive/test_hive_schema_evolution.out | 36 +
.../hive/test_hive_serde_prop.out | 4 +
.../hive/test_information_schema_external.out | 132 +
.../hive/test_prepare_hive_data_in_case.out | 10 +
.../hive/test_transactional_hive.out | 38 +
.../hive/write/test_hive_write_insert.out | 231 +
.../hive/write/test_hive_write_partitions.out | 177 +
.../hive/test_hive_parquet_alter_column.out | 1674 +
.../data/insert_p0/insert_group_commit_into.out | 32 +-
.../load_p0/insert/test_insert_move_memtable.out | 12 +
.../test_load_block_to_single_tablet.csv | 4100 ++
.../test_load_block_to_single_tablet.out | 11 +
.../stream_load/test_stream_load_move_memtable.out | 4 +
regression-test/data/mtmv_p0/test_build_mtmv.out | 6 +
.../data/mtmv_p0/test_hive_default_mtmv.out | 11 +
.../mtmv_p0/test_hive_limit_partition_mtmv.out | 9 +
regression-test/data/mtmv_p0/test_hive_mtmv.out | 18 +
.../mtmv_p0/test_hive_multi_partition_mtmv.out | 42 +
.../data/mtmv_p0/test_hive_olap_mtmv.out | 15 +
.../data/mtmv_p0/test_hive_refresh_mtmv.out | 16 +
.../data/nereids_hint_tpcds_p0/shape/query24.out | 15 +-
.../data/nereids_hint_tpch_p0/shape/q11.out | 37 +-
.../data/nereids_hint_tpch_p0/shape/q7.out | 43 +-
.../data/nereids_p0/hint/fix_leading.out | 4 +-
.../data/nereids_p0/hint/multi_leading.out | 22 +-
.../push_down_filter_other_condition.out | 6 +-
.../like_to_equal_to_rewrite.out | 24 +
.../simplify_window_expression.out | 254 +
.../shape/query14.out | 126 +-
.../shape/query23.out | 13 +-
.../shape/query24.out | 15 +-
.../shape/query44.out | 38 +-
.../shape/query54.out | 121 +-
.../shape/query70.out | 36 +-
.../constraints/query23.out | 13 +-
.../noStatsRfPrune/query14.out | 132 +-
.../noStatsRfPrune/query23.out | 13 +-
.../noStatsRfPrune/query24.out | 15 +-
.../noStatsRfPrune/query44.out | 38 +-
.../noStatsRfPrune/query54.out | 115 +-
.../noStatsRfPrune/query70.out | 36 +-
.../no_stats_shape/query14.out | 132 +-
.../no_stats_shape/query23.out | 13 +-
.../no_stats_shape/query24.out | 15 +-
.../no_stats_shape/query44.out | 38 +-
.../no_stats_shape/query54.out | 115 +-
.../no_stats_shape/query70.out | 35 +-
.../rf_prune/query14.out | 126 +-
.../rf_prune/query23.out | 13 +-
.../rf_prune/query24.out | 15 +-
.../rf_prune/query44.out | 38 +-
.../rf_prune/query54.out | 120 +-
.../rf_prune/query70.out | 36 +-
.../nereids_tpcds_shape_sf100_p0/shape/query14.out | 126 +-
.../nereids_tpcds_shape_sf100_p0/shape/query23.out | 13 +-
.../nereids_tpcds_shape_sf100_p0/shape/query24.out | 15 +-
.../nereids_tpcds_shape_sf100_p0/shape/query44.out | 38 +-
.../nereids_tpcds_shape_sf100_p0/shape/query54.out | 120 +-
.../nereids_tpcds_shape_sf100_p0/shape/query70.out | 35 +-
.../nostats_rf_prune/q11.out | 33 +-
.../nereids_tpch_shape_sf1000_p0/rf_prune/q11.out | 25 +-
.../nereids_tpch_shape_sf1000_p0/shape/q11.out | 25 +-
.../shape_no_stats/q11.out | 33 +-
.../hll_functions/test_hll_functions.out | 2 +-
.../ip_functions/test_ipv4_cidr_to_range.out | 30 +
.../test_ipv6_cidr_to_range_function.out | 33 +
.../org/apache/doris/regression/Config.groovy | 3 +
.../apache/doris/regression/ConfigOptions.groovy | 8 +
.../org/apache/doris/regression/suite/Suite.groovy | 36 +-
.../doris/regression/suite/SuiteCluster.groovy | 9 +-
.../doris/regression/suite/SuiteContext.groovy | 52 +-
.../pipeline/external/conf/regression-conf.groovy | 16 +-
.../pipeline/p0/conf/regression-conf.groovy | 16 +-
.../test_decommission_with_replica_num_fail.groovy | 5 +
.../test_grant_auth.groovy} | 18 +-
.../suites/autobucket/test_autobucket.groovy | 3 +-
.../test_autobucket_dynamic_partition.groovy | 3 +-
.../suites/clone_p0/test_decommission_mtmv.groovy | 93 +
.../multi_cluster/read_write/ddl/customer.sql | 12 +
.../read_write/ddl/customer_delete.sql | 1 +
.../read_write}/ddl/customer_load.sql | 0
.../multi_cluster/read_write/sync_insert.groovy | 150 +
.../read_write/test_multi_stale_rowset.groovy | 245 +
.../warm_up/cluster/test_warm_up_cluster.groovy | 264 +
.../cluster/test_warm_up_cluster_batch.groovy | 191 +
.../cluster/test_warm_up_cluster_bigsize.groovy | 190 +
.../cluster/test_warm_up_cluster_empty.groovy | 165 +
.../cache/multi_cluster/warm_up/ddl/customer.sql | 29 +
.../warm_up}/ddl/customer_delete.sql | 0
.../multi_cluster/warm_up/ddl/customer_load.sql | 24 +
.../warm_up/ddl/customer_with_partition.sql | 35 +
.../cache/multi_cluster/warm_up/ddl/supplier.sql | 27 +
.../multi_cluster/warm_up/ddl/supplier_delete.sql | 18 +
.../multi_cluster/warm_up/ddl/supplier_load.sql | 23 +
.../warm_up/hotspot/test_warmup_show_stmt.groovy | 127 +
.../warm_up/hotspot/test_warmup_show_stmt_2.groovy | 93 +
.../warm_up/hotspot/test_warmup_show_stmt_3.groovy | 87 +
.../warm_up/table/test_warm_up_partition.groovy | 192 +
.../warm_up/table/test_warm_up_table.groovy | 209 +
.../warm_up/table/test_warm_up_tables.groovy | 232 +
.../suites/ddl_p0/test_alter_view_nereids.groovy | 69 +
.../outfile/csv/test_outfile_empty_data.groovy | 2 +-
.../export_p0/test_show_create_database.groovy | 2 +-
.../broker_load/test_broker_load_func.groovy | 2 +-
.../export/hive_read/orc/test_hive_read_orc.groovy | 452 +-
.../orc/test_hive_read_orc_complex_type.groovy | 405 +-
.../parquet/test_hive_read_parquet.groovy | 460 +-
.../test_hive_read_parquet_comlex_type.groovy | 420 +-
.../hive/ddl/test_hive_ctas.groovy | 17 +-
.../hive/ddl/test_hive_ddl.groovy | 4 +-
.../hive/ddl/test_hive_write_type.groovy | 15 +-
.../hive/hive_tpch_sf1_orc.groovy | 11 +-
.../hive/hive_tpch_sf1_parquet.groovy | 11 +-
.../hive/jdbc_hive_meta/test_jdbc_hive_orc.groovy | 13 +-
.../hive/test_autoinc_broker_load.groovy | 2 +-
.../hive/test_different_column_orders.groovy | 11 +-
.../hive/test_different_parquet_types.groovy | 266 +-
.../hive/test_hive_basic_type.groovy | 13 +-
.../hive/test_hive_broker_scan.groovy | 11 +-
.../external_table_p0/hive/test_hive_orc.groovy | 11 +-
.../external_table_p0/hive/test_hive_other.groovy | 13 +-
.../hive/test_hive_parquet.groovy | 11 +-
.../hive/test_hive_partitions.groovy | 11 +-
.../hive/test_hive_query_cache.groovy | 14 +-
.../hive/test_hive_schema_evolution.groovy | 13 +-
.../hive/test_hive_serde_prop.groovy | 11 +-
.../hive/test_hive_statistics_all_type_p0.groovy | 11 +-
.../hive/test_hive_statistics_p0.groovy | 11 +-
.../hive/test_hive_tablesample_p0.groovy | 11 +-
.../hive/test_information_schema_external.groovy | 12 +-
.../hive/test_partial_update_broker_load.groovy | 2 +-
.../hive/test_prepare_hive_data_in_case.groovy | 10 +-
.../hive/test_transactional_hive.groovy | 11 +-
.../hive/write/test_hive_write_insert.groovy | 14 +-
.../hive/write/test_hive_write_partitions.groovy | 14 +-
.../info_schema_db/test_info_schema_db.groovy | 2 +-
.../paimon/test_paimon_catalog.groovy | 2 +-
.../paimon/test_paimon_statistics.groovy | 2 +-
.../paimon/test_paimon_table_stats.groovy | 2 +-
.../hive/test_trino_different_parquet_types.groovy | 4 +-
.../hive/test_trino_hive_orc.groovy | 2 +-
.../hive/test_trino_hive_other.groovy | 4 +-
.../hive/test_trino_hive_parquet.groovy | 2 +-
.../hive/test_trino_hive_schema_evolution.groovy | 2 +-
.../hive/test_trino_hive_serde_prop.groovy | 2 +-
.../hive/test_trino_hive_tablesample_p0.groovy | 2 +-
.../hive/test_trino_hive_tpch_sf1_orc.groovy | 2 +-
.../hive/test_trino_hive_tpch_sf1_parquet.groovy | 2 +-
.../test_trino_prepare_hive_data_in_case.groovy | 2 +-
.../external_table_p0/tvf/test_hdfs_tvf.groovy | 2 +-
.../tvf/test_hdfs_tvf_error_uri.groovy | 2 +-
.../external_table_p0/tvf/test_tvf_avro.groovy | 2 +-
.../hive/test_hive_parquet_alter_column.groovy | 11 +-
.../insert_p0/insert_group_commit_into.groovy | 66 +-
.../insert/test_insert_move_memtable.groovy | 30 +
.../load_p0/stream_load/test_hdfs_json_load.groovy | 2 +-
.../test_load_block_to_single_tablet.groovy | 58 +
.../test_stream_load_move_memtable.groovy | 51 +
.../suites/mtmv_p0/test_build_mtmv.groovy | 59 +
.../suites/mtmv_p0/test_hive_default_mtmv.groovy | 171 +-
.../mtmv_p0/test_hive_limit_partition_mtmv.groovy | 256 +-
.../suites/mtmv_p0/test_hive_mtmv.groovy | 11 +-
.../mtmv_p0/test_hive_multi_partition_mtmv.groovy | 406 +-
.../suites/mtmv_p0/test_hive_olap_mtmv.groovy | 8 +-
.../suites/mtmv_p0/test_hive_refresh_mtmv.groovy | 300 +-
.../suites/mtmv_p0/test_paimon_mtmv.groovy | 2 +-
.../suites/nereids_p0/hint/test_leading.groovy | 2 +
.../like_to_equal_to_rewrite.groovy | 53 +
.../mv_contain_external_table.groovy | 2 +-
.../simplify_window_expression.groovy | 110 +
.../query_p0/explain/test_pushdown_explain.groovy | 14 +
.../hll_functions/test_hll_functions.groovy | 2 +-
.../ip_functions/test_ipv4_cidr_to_range.groovy | 3 +
.../test_ipv6_cidr_to_range_function.groovy | 6 +-
.../test_alter_colocate_table.groovy | 1 -
.../suites/show_p0/test_show_processlist.groovy | 40 +
regression-test/suites/vaults/create/create.groovy | 24 +
run-regression-test.sh | 1 +
488 files changed, 164664 insertions(+), 4472 deletions(-)
create mode 100644 be/src/cloud/cloud_tablet_hotspot.cpp
create mode 100644 be/src/cloud/cloud_tablet_hotspot.h
create mode 100644 be/src/cloud/cloud_warm_up_manager.cpp
create mode 100644 be/src/cloud/cloud_warm_up_manager.h
create mode 100644 be/src/io/cache/block_file_cache_downloader.cpp
create mode 100644 be/src/io/cache/block_file_cache_downloader.h
create mode 100644 be/src/util/s3_rate_limiter.cpp
create mode 100644 be/src/util/s3_rate_limiter.h
create mode 100644 be/src/vec/exprs/vtopn_pred.h
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/CancelCloudWarmUpStmt.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/CopyFromParam.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/CopyIntoProperties.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/CopyProperties.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/CopyStmt.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/CreateStageStmt.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/DropStageStmt.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCacheHotSpotStmt.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCloudWarmUpStmt.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCopyStmt.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/ShowStageStmt.java
copy regression-test/suites/query_p0/explain/test_pushdown_explain.groovy =>
fe/fe-core/src/main/java/org/apache/doris/analysis/StageAndPattern.java (59%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/StageProperties.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/WarmUpClusterStmt.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/cloud/CacheHotspotManager.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/cloud/CacheHotspotManagerUtils.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/cloud/CloudWarmUpJob.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/cloud/catalog/CloudUpgradeMgr.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/cloud/stage/StageUtil.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/httpv2/rest/CopyIntoAction.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/load/loadv2/CleanCopyJobScheduler.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/load/loadv2/CleanCopyJobTask.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/load/loadv2/CopyJob.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/load/loadv2/CopyLoadPendingTask.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/properties/FuncDeps.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/properties/FuncDepsDAG.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/expression/rules/LikeToEqualRewrite.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/ProjectOtherJoinConditionForNestedLoopJoin.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/SimplifyWindowExpression.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/AlterViewCommand.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/info/AlterViewInfo.java
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/info/{CreateViewInfo.java
=> BaseViewInfo.java} (67%)
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/analysis/CopyIntoTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/analysis/StageTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/cloud/stage/StageUtilTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/httpv2/CopyIntoTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/load/loadv2/CopyJobTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/load/loadv2/CopyLoadPendingTaskTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/properties/FuncDepsDAGTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/rules/expression/rules/LikeToEqualRewriteTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/rules/rewrite/ProjectOtherJoinConditionForNestedLoopJoinTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/persist/ModifyCloudWarmUpJobTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/utframe/MockedMetaServer.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/utframe/MockedMetaServerFactory.java
create mode 100644 fe/fe-core/src/test/resources/stageUtilTest.txt
create mode 100644 regression-test/data/clone_p0/test_decommission_mtmv.out
create mode 100644 regression-test/data/ddl_p0/test_alter_view_nereids.out
create mode 100644
regression-test/data/load_p0/stream_load/test_load_block_to_single_tablet.csv
create mode 100644
regression-test/data/load_p0/stream_load/test_load_block_to_single_tablet.out
create mode 100644
regression-test/data/nereids_rules_p0/like_to_equal_to_rewrite/like_to_equal_to_rewrite.out
create mode 100644
regression-test/data/nereids_rules_p0/simplify_window_expression/simplify_window_expression.out
copy regression-test/suites/{query_p0/explain/test_pushdown_explain.groovy =>
auth_p0/test_grant_auth.groovy} (71%)
create mode 100644
regression-test/suites/clone_p0/test_decommission_mtmv.groovy
create mode 100644
regression-test/suites/cloud_p0/cache/multi_cluster/read_write/ddl/customer.sql
create mode 100644
regression-test/suites/cloud_p0/cache/multi_cluster/read_write/ddl/customer_delete.sql
copy regression-test/suites/{tpch_sf100_p2 =>
cloud_p0/cache/multi_cluster/read_write}/ddl/customer_load.sql (100%)
create mode 100644
regression-test/suites/cloud_p0/cache/multi_cluster/read_write/sync_insert.groovy
create mode 100644
regression-test/suites/cloud_p0/cache/multi_cluster/read_write/test_multi_stale_rowset.groovy
create mode 100644
regression-test/suites/cloud_p0/cache/multi_cluster/warm_up/cluster/test_warm_up_cluster.groovy
create mode 100644
regression-test/suites/cloud_p0/cache/multi_cluster/warm_up/cluster/test_warm_up_cluster_batch.groovy
create mode 100644
regression-test/suites/cloud_p0/cache/multi_cluster/warm_up/cluster/test_warm_up_cluster_bigsize.groovy
create mode 100644
regression-test/suites/cloud_p0/cache/multi_cluster/warm_up/cluster/test_warm_up_cluster_empty.groovy
create mode 100644
regression-test/suites/cloud_p0/cache/multi_cluster/warm_up/ddl/customer.sql
copy regression-test/suites/cloud_p0/cache/{ =>
multi_cluster/warm_up}/ddl/customer_delete.sql (100%)
create mode 100644
regression-test/suites/cloud_p0/cache/multi_cluster/warm_up/ddl/customer_load.sql
create mode 100644
regression-test/suites/cloud_p0/cache/multi_cluster/warm_up/ddl/customer_with_partition.sql
create mode 100644
regression-test/suites/cloud_p0/cache/multi_cluster/warm_up/ddl/supplier.sql
create mode 100644
regression-test/suites/cloud_p0/cache/multi_cluster/warm_up/ddl/supplier_delete.sql
create mode 100644
regression-test/suites/cloud_p0/cache/multi_cluster/warm_up/ddl/supplier_load.sql
create mode 100644
regression-test/suites/cloud_p0/cache/multi_cluster/warm_up/hotspot/test_warmup_show_stmt.groovy
create mode 100644
regression-test/suites/cloud_p0/cache/multi_cluster/warm_up/hotspot/test_warmup_show_stmt_2.groovy
create mode 100644
regression-test/suites/cloud_p0/cache/multi_cluster/warm_up/hotspot/test_warmup_show_stmt_3.groovy
create mode 100644
regression-test/suites/cloud_p0/cache/multi_cluster/warm_up/table/test_warm_up_partition.groovy
create mode 100644
regression-test/suites/cloud_p0/cache/multi_cluster/warm_up/table/test_warm_up_table.groovy
create mode 100644
regression-test/suites/cloud_p0/cache/multi_cluster/warm_up/table/test_warm_up_tables.groovy
create mode 100644 regression-test/suites/ddl_p0/test_alter_view_nereids.groovy
create mode 100644
regression-test/suites/load_p0/stream_load/test_load_block_to_single_tablet.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/like_to_equal_to_rewrite/like_to_equal_to_rewrite.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/simplify_window_expression/simplify_window_expression.groovy
create mode 100644 regression-test/suites/show_p0/test_show_processlist.groovy
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
