This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a change to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
from 4701dd49c36 (selectdb-cloud) Use info level in
recordCreatePartitionFailedMsg() due to intersection happens all the time
(#30448)
new 847db2c0157 [Enhancement](group commit) Add retry message for group
commit load while schema changing (#30391)
new 8d4e0c50c67 [feature](sink) support paritition tablet sink shuffle
(#30821)
new 2e4daa7006a [fix](Nereids): fix wrong case in
TransposeSemiJoinLogicalJoinProject (#30874)
new 5c2a4a80dd2 [fix](nereids) Fix use aggregate mv wrongly when rewrite
query which only contains join (#30858)
new 5ca10d95b7b [fix](Docs) Modify the document of data export #30785
new 2cb46eed945 [Feature](auto-inc) Add start value for auto increment
column (#30512)
new 89695f43d4b [refactor](queryctx) move tg related code to task group
(#30829)
new 2667e10ba25 [improve](group-commit) Modify some log (#30842)
new c6cd6b125dd [nereids] group by key elimination (#30774)
new 08508d65fd0 [feature-wip](plsql)(step1) Support PL-SQL (#30817)
new f95d0cf8024 [fix](Nereids) should not infer not null from mark join
(#30897)
new cb43ac8ab22 [feature](nereids) using rollup column stats (#30852)
new 37c36b0491f [fix](regression-test) fixtest_show_export case #30892
new b39cee9c167 [fix](docs) fix log level configuration error in fe.config
(#30863)
new 5b343911e89 [log](gc) add log for unused rowsets gc (#30854)
new b23a785775d [Fix](Variant) support materialize view for variant and
accessing variant subcolumns (#30603)
new c4a8d5497d5 [fix](gc) process exception while iteratoring directory
(#30850)
new 517e7a0567c [Fix](load) fix load channel leak when load exception
occurs (#30915)
new 042934e5451 Add auto analyze mv and show task case. (#30894)
new 32ef6cd4bc3 [fix](Nereids): fix name of rule EliminateJoinByFK #30884
new 0442d5dc0eb [fix](Variant Type) Add sparse columns meta to fix
compaction (#28673)
new e086d0d719e [test](statistics)Add analyze mtmv test case (#30847)
new 5295e167275 [fix](Nereids) make all variables lower case (#30905)
new 4052746f1c0 [improvement](balance) fix multiple problems for balance
on large cluster (#30713)
new 2bb477bae7a [feature](agg-func) support corr function #30822
new 663f748ab71 [fix](multi-catalog)enable use self splitter default
(#30846)
new b01625b7a9c [chore](regression-test) fix legacy use of get tablet info
(#30931)
new 3017c0a6ff1 [enhance](mtmv) Limit the number of partitions for table
creation (#30867)
new e96b3db6f8f [Improvement](memory) clear arena when finalize one row
#30788
new a3ef8d7bd0b [test](mtmv) Add mtmv negative cases (#30918)
new 34de374e78c [Doc](group commit) Modify group commit doc (#30938)
new 1d10132aa1d [fix](Nereids) should distribute first when do sort
enforce on must shuffle (#30948)
new de1724ab6ac [case](mtmv) MTMV hive case (#30930)
new 16cdab816a9 [refactor](move-memtable) remove phmap and use shared ptr
in delta writer v2 (#30949)
new 366a6792bfa [refactor](scanner) refactoring and optimizing scanner
scheduling (#30746)
new 5bb8a726265 [fix](group_commit) Fix write column id twice problem on
wal file (#30935)
new 36d753eacb9 [opt](ES catalog) Increase to 3 connect attempts per node
(#30957)
new 22cc8342d4c [Enhancement](wal) Optimize group commit manager log
(#30849)
new abbd1c7edea disable OR predicate for bitmap index (#30951)
new 7571ecc42f9 [fix](group_commit)Add bounds checking when reading wal
file on group commit (#30940)
new c72f634c10d [enhancement](schema change) some types changes (#30919)
new a1bf00e5eaf [fix](nereids)aggregate function cannot contain aggregate
parameters (#30928)
new 041db03c944 [fix](gc) fix a core introduced by #30854 (#30932)
new 02c37b8ead2 opt the rf code and remove rf unless code (#30861)
new 1437348040f [fix](group_commit) Wal file should be removed from
_wal_path_map when renaming it to tmp directory (#30974)
new e8f614791e6 [fix](pipeline) Set the flag of short circuit only when
hash join sink finished (#30977)
new 5e6e2f80617 [fix](nereids)should not infer predicate for nullaware
anti-join (#30924)
new 6596f954003 [test](mtmv) Add mtmv increment create case (#30751)
new ac756075bbd Alter workload group queue prop sync for regression test
(#30869)
new ad715ab9779 [feature](StoragePolicy) Add one http action to add
storage policy back (#30879)
new b0835b43365 [fix](test) Increase the timeout duration for the test
case (#30952)
new bbbe3e666aa [improvement](group_commit) Rename fail wal to tmp should
only use in test P0 scenario (#30959)
new ff82e2ab590 [improvement](group_commit) Add bvar to monitor the count
of replaying wal fail on group commit (#30941)
new 08c196f3dc2 [enhancement](stmt-forward) record query result for proxy
query to avoid EOF (#30536)
new 3e07167897d [enhancement](mysql-channel) avoid potential buffer
overflow when flushing send buffer occurs IOE (#30868)
new cef31f6709d [feat](fe) Show db total size and recycle bin size with
`ShowDataStmt` (#30663)
new 927dd8a2462 [fix](Docs) fix dev-prepare doc #30923
new d60ecdba6f4 [fix](regex) fix wrong escape of function LIKE (#30557)
new 448fb70f687 [fix](nereids) collect all correlated slots from subquery
in correct way (#30908)
new 5cfd7c2a1c8 [improvement](memtracker) should counter memory usage to
query when exchange sink buffer rpc (#30964)
new 40e1326bc9a [feature](window-func) support percent_rank window
function (#30926)
new 7f509984063 fix compile
The 62 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/common/config.cpp | 1 +
be/src/common/config.h | 1 +
be/src/exprs/runtime_filter.cpp | 110 +-
be/src/exprs/runtime_filter.h | 20 +-
be/src/exprs/runtime_filter_slots.h | 5 +-
be/src/io/fs/local_file_system.cpp | 33 +-
be/src/olap/compaction.cpp | 2 +
be/src/olap/data_dir.cpp | 8 +-
be/src/olap/delta_writer_v2.cpp | 10 +-
be/src/olap/delta_writer_v2.h | 11 +-
be/src/olap/memtable.cpp | 18 +-
be/src/olap/rowset/segment_creator.cpp | 81 +-
.../rowset/segment_v2/hierarchical_data_reader.cpp | 4 +
.../rowset/segment_v2/hierarchical_data_reader.h | 9 +-
be/src/olap/rowset/segment_v2/segment.cpp | 107 +-
be/src/olap/rowset/segment_v2/segment.h | 9 +
be/src/olap/rowset/segment_v2/segment_iterator.cpp | 22 +-
be/src/olap/rowset/segment_v2/segment_iterator.h | 3 -
be/src/olap/rowset/segment_v2/segment_writer.cpp | 4 +
.../rowset/segment_v2/vertical_segment_writer.cpp | 4 +
be/src/olap/storage_engine.cpp | 16 +
be/src/olap/tablet_schema.cpp | 29 +
be/src/olap/tablet_schema.h | 15 +
be/src/olap/wal/wal_dirs_info.cpp | 1 -
be/src/olap/wal/wal_info.cpp | 2 +-
be/src/olap/wal/wal_info.h | 4 +-
be/src/olap/wal/wal_manager.cpp | 34 +-
be/src/olap/wal/wal_reader.cpp | 14 +-
be/src/olap/wal/wal_table.cpp | 85 +-
be/src/olap/wal/wal_writer.cpp | 2 +-
be/src/pipeline/exec/analytic_source_operator.cpp | 4 +-
be/src/pipeline/exec/datagen_operator.cpp | 8 +-
be/src/pipeline/exec/exchange_sink_buffer.cpp | 9 +
be/src/pipeline/exec/exchange_sink_buffer.h | 1 +
be/src/pipeline/exec/file_scan_operator.cpp | 8 +-
be/src/pipeline/exec/hashjoin_build_sink.cpp | 2 +-
be/src/pipeline/exec/scan_operator.cpp | 27 +-
be/src/pipeline/exec/scan_operator.h | 3 +-
be/src/pipeline/pipeline_task.cpp | 1 -
be/src/pipeline/pipeline_task.h | 2 +
be/src/pipeline/pipeline_x/pipeline_x_task.cpp | 1 -
be/src/pipeline/task_scheduler.cpp | 6 +-
be/src/runtime/fragment_mgr.cpp | 93 +-
be/src/runtime/group_commit_mgr.cpp | 23 +-
be/src/runtime/query_context.cpp | 51 +-
be/src/runtime/query_context.h | 17 +-
be/src/runtime/runtime_filter_mgr.cpp | 69 +-
be/src/runtime/runtime_filter_mgr.h | 10 +-
be/src/runtime/runtime_state.h | 8 +-
be/src/runtime/task_group/task_group.h | 32 +-
be/src/runtime/task_group/task_group_manager.cpp | 28 -
be/src/runtime/task_group/task_group_manager.h | 4 -
.../aggregate_function_binary.h | 130 ++
.../aggregate_function_corr.cpp | 92 +
.../aggregate_function_simple_factory.cpp | 3 +
.../aggregate_function_window.cpp | 2 +
.../aggregate_function_window.h | 59 +-
be/src/vec/columns/column_object.cpp | 5 +
be/src/vec/columns/column_object.h | 8 +-
be/src/vec/columns/subcolumn_tree.h | 3 +-
be/src/vec/common/schema_util.cpp | 203 +-
be/src/vec/common/schema_util.h | 19 +-
be/src/vec/data_types/data_type_factory.cpp | 4 +-
be/src/vec/exec/format/wal/wal_reader.cpp | 12 +-
be/src/vec/exec/format/wal/wal_reader.h | 1 +
be/src/vec/exec/join/vhash_join_node.cpp | 2 +-
be/src/vec/exec/runtime_filter_consumer.cpp | 15 +-
be/src/vec/exec/scan/new_file_scan_node.cpp | 9 +-
be/src/vec/exec/scan/pip_scanner_context.h | 242 +-
be/src/vec/exec/scan/scanner_context.cpp | 515 ++---
be/src/vec/exec/scan/scanner_context.h | 213 +-
be/src/vec/exec/scan/scanner_scheduler.cpp | 293 +--
be/src/vec/exec/scan/scanner_scheduler.h | 44 +-
be/src/vec/exec/scan/vscan_node.cpp | 25 +-
be/src/vec/exec/scan/vscan_node.h | 3 +-
be/src/vec/exec/vanalytic_eval_node.cpp | 2 +-
be/src/vec/exec/vdata_gen_scan_node.cpp | 8 +-
be/src/vec/functions/function_variant_element.cpp | 178 ++
be/src/vec/functions/like.cpp | 64 +-
be/src/vec/functions/simple_function_factory.h | 10 +-
be/src/vec/olap/block_reader.cpp | 7 +-
be/src/vec/sink/autoinc_buffer.cpp | 2 +-
be/src/vec/sink/delta_writer_v2_pool.cpp | 41 +-
be/src/vec/sink/delta_writer_v2_pool.h | 15 +-
be/src/vec/sink/writer/vtablet_writer.cpp | 8 +-
be/src/vec/sink/writer/vtablet_writer_v2.cpp | 4 +-
.../developer-guide/mac-dev/dev-prepare.md | 5 +-
docs/en/docs/admin-manual/config/fe-config.md | 2 +-
docs/en/docs/admin-manual/data-admin/backup.md | 19 +-
docs/en/docs/data-operate/export/export-manual.md | 36 +-
.../import/import-way/group-commit-manual.md | 180 +-
.../sql-functions/aggregate-functions/corr.md | 49 +
.../window-function-percent-rank.md | 128 ++
.../sql-reference/Show-Statements/SHOW-DATA.md | 28 +-
docs/sidebars.json | 2 +
.../developer-guide/mac-dev/dev-prepare.md | 5 +-
docs/zh-CN/docs/admin-manual/config/fe-config.md | 2 +-
docs/zh-CN/docs/admin-manual/data-admin/backup.md | 18 +-
.../docs/data-operate/export/export-manual.md | 35 +-
.../import/import-way/group-commit-manual.md | 180 +-
.../sql-functions/aggregate-functions/corr.md | 50 +
.../window-function-percent-rank.md | 128 ++
.../sql-reference/Show-Statements/SHOW-DATA.md | 28 +-
.../org/apache/doris/catalog/MysqlColType.java | 79 +-
.../main/java/org/apache/doris/common/Config.java | 37 +-
.../main/java/org/apache/doris/common/Pair.java | 2 +-
fe/fe-core/pom.xml | 7 +-
.../antlr4/org/apache/doris/nereids/DorisParser.g4 | 9 +-
.../antlr4/org/apache/doris/nereids/PLLexer.g4 | 216 ++
.../antlr4/org/apache/doris/nereids/PLParser.g4 | 938 ++++++++
fe/fe-core/src/main/cup/sql_parser.cup | 27 +-
.../java/org/apache/doris/analysis/Analyzer.java | 2 +-
.../java/org/apache/doris/analysis/ColumnDef.java | 35 +-
.../org/apache/doris/analysis/PartitionDesc.java | 9 +
.../org/apache/doris/analysis/ShowDataStmt.java | 88 +
.../doris/catalog/AutoIncrementGenerator.java | 3 +-
.../doris/catalog/BuiltinAggregateFunctions.java | 2 +
.../doris/catalog/BuiltinWindowFunctions.java | 2 +
.../apache/doris/catalog/CatalogRecycleBin.java | 39 +
.../main/java/org/apache/doris/catalog/Column.java | 32 +-
.../java/org/apache/doris/catalog/Database.java | 20 +-
.../main/java/org/apache/doris/catalog/Env.java | 19 +
.../java/org/apache/doris/catalog/FunctionSet.java | 41 +
.../java/org/apache/doris/catalog/OlapTable.java | 3 +-
.../apache/doris/catalog/TabletInvertedIndex.java | 19 +-
.../apache/doris/clone/BackendLoadStatistic.java | 68 +-
.../org/apache/doris/clone/BeLoadRebalancer.java | 190 +-
.../apache/doris/clone/LoadStatisticForTag.java | 166 +-
.../apache/doris/clone/RootPathLoadStatistic.java | 30 +-
.../org/apache/doris/clone/TabletScheduler.java | 96 +-
.../common/proc/BackendLoadStatisticProcNode.java | 2 +-
.../common/proc/ClusterLoadStatisticProcDir.java | 2 +-
.../apache/doris/datasource/ExternalCatalog.java | 10 -
.../doris/datasource/HMSExternalCatalog.java | 1 -
.../apache/doris/datasource/InternalCatalog.java | 4 +-
.../doris/datasource/hive/HiveMetaStoreCache.java | 54 +-
.../doris/datasource/jdbc/client/JdbcClient.java | 2 +-
.../datasource/jdbc/client/JdbcMySQLClient.java | 4 +-
.../doris/external/elasticsearch/EsRestClient.java | 5 +-
.../httpv2/restv2/AddStoragePolicyAction.java | 89 +
.../org/apache/doris/journal/JournalEntity.java | 23 +
.../org/apache/doris/mtmv/MTMVPartitionUtil.java | 31 +-
.../java/org/apache/doris/mtmv/MTMVService.java | 4 -
.../java/org/apache/doris/mysql/MysqlChannel.java | 34 +-
.../ProxyMysqlChannel.java} | 23 +-
.../glue/translator/PhysicalPlanTranslator.java | 31 +-
.../doris/nereids/jobs/executor/Rewriter.java | 6 +
.../doris/nereids/parser/LogicalPlanBuilder.java | 43 +-
.../apache/doris/nereids/parser/NereidsParser.java | 5 +
.../parser/plsql/PLSqlLogicalPlanBuilder.java | 53 +
.../properties/EnforceMissingPropertiesHelper.java | 8 +-
.../ExprFdItem.java} | 24 +-
.../apache/doris/nereids/properties/FdFactory.java | 43 +
.../apache/doris/nereids/properties/FdItem.java | 64 +
.../nereids/properties/FunctionalDependencies.java | 23 +-
.../nereids/properties/LogicalProperties.java | 6 +-
.../doris/nereids/properties/TableFdItem.java | 93 +
.../org/apache/doris/nereids/rules/RuleType.java | 2 +
.../nereids/rules/analysis/NormalizeAggregate.java | 6 +
.../rules/analysis/WindowFunctionChecker.java | 13 +
.../mv/AbstractMaterializedViewAggregateRule.java | 13 +-
.../mv/AbstractMaterializedViewJoinRule.java | 8 +-
.../nereids/rules/exploration/mv/StructInfo.java | 76 +-
.../rules/expression/ExpressionOptimization.java | 4 +-
.../rules/expression/rules/ElementAtToSlot.java | 89 -
.../rules/expression/rules/FunctionBinder.java | 5 +-
.../nereids/rules/rewrite/EliminateGroupByKey.java | 217 ++
.../nereids/rules/rewrite/EliminateJoinByFK.java | 2 +-
.../nereids/rules/rewrite/InferJoinNotNull.java | 1 +
.../nereids/rules/rewrite/InferPredicates.java | 1 -
.../TransposeSemiJoinLogicalJoinProject.java | 12 +-
.../doris/nereids/stats/StatsCalculator.java | 19 +-
.../trees/expressions/functions/agg/Corr.java | 85 +
.../expressions/functions/scalar/ElementAt.java | 4 +-
.../scalar/PushDownToProjectionFunction.java | 50 +-
.../expressions/functions/window/PercentRank.java | 61 +
.../visitor/AggregateFunctionVisitor.java | 5 +
.../expressions/visitor/WindowFunctionVisitor.java | 5 +
.../trees/plans/BlockFuncDepsPropagation.java | 8 +
.../apache/doris/nereids/trees/plans/PlanType.java | 3 +-
.../nereids/trees/plans/PropagateFuncDeps.java | 19 +
.../nereids/trees/plans/commands/CallCommand.java | 6 +-
.../plans/commands/CreateProcedureCommand.java | 68 +
.../trees/plans/commands/call/CallFunc.java | 9 +-
.../call/{CallFunc.java => CallProcedure.java} | 37 +-
.../plans/commands/info/ColumnDefinition.java | 16 +-
.../trees/plans/commands/info/CreateMTMVInfo.java | 28 +-
.../trees/plans/commands/info/CreateTableInfo.java | 11 +
.../trees/plans/commands/info/FuncNameInfo.java | 143 ++
.../trees/plans/logical/LogicalAggregate.java | 28 +
.../plans/logical/LogicalCatalogRelation.java | 53 +
.../plans/logical/LogicalDeferMaterializeTopN.java | 23 +
.../nereids/trees/plans/logical/LogicalExcept.java | 30 +
.../nereids/trees/plans/logical/LogicalFilter.java | 13 +
.../trees/plans/logical/LogicalGenerate.java | 9 +
.../nereids/trees/plans/logical/LogicalHaving.java | 13 +
.../trees/plans/logical/LogicalIntersect.java | 32 +
.../nereids/trees/plans/logical/LogicalJoin.java | 165 +-
.../nereids/trees/plans/logical/LogicalLimit.java | 24 +
.../trees/plans/logical/LogicalOneRowRelation.java | 22 +
.../nereids/trees/plans/logical/LogicalPlan.java | 4 +
.../trees/plans/logical/LogicalProject.java | 13 +
.../nereids/trees/plans/logical/LogicalRepeat.java | 14 +
.../trees/plans/logical/LogicalSubQueryAlias.java | 10 +
.../nereids/trees/plans/logical/LogicalTopN.java | 24 +
.../nereids/trees/plans/logical/LogicalUnion.java | 24 +
.../nereids/trees/plans/logical/LogicalWindow.java | 35 +-
.../trees/plans/visitor/CommandVisitor.java | 5 +
.../org/apache/doris/nereids/util/PlanUtils.java | 25 +
.../java/org/apache/doris/nereids/util/Utils.java | 21 +-
.../java/org/apache/doris/persist/EditLog.java | 35 +
.../org/apache/doris/persist/OperationType.java | 11 +-
.../doris/persist/meta/MetaPersistMethod.java | 7 +
.../doris/persist/meta/PersistMetaModules.java | 2 +-
.../doris/planner/external/HiveScanNode.java | 13 +-
.../java/org/apache/doris/plsql/Arguments.java | 215 ++
.../main/java/org/apache/doris/plsql/Column.java | 70 +
.../ColumnDefinition.java} | 36 +-
.../java/org/apache/doris/plsql/ColumnMap.java | 53 +
.../java/org/apache/doris/plsql/ColumnType.java | 76 +
.../src/main/java/org/apache/doris/plsql/Conf.java | 159 ++
.../src/main/java/org/apache/doris/plsql/Conn.java | 253 +++
.../Console.java} | 42 +-
.../java/org/apache/doris/plsql/Converter.java | 83 +
.../main/java/org/apache/doris/plsql/Cursor.java | 128 ++
.../src/main/java/org/apache/doris/plsql/Exec.java | 2401 ++++++++++++++++++++
.../java/org/apache/doris/plsql/Expression.java | 578 +++++
.../src/main/java/org/apache/doris/plsql/File.java | 157 ++
.../call/CallFunc.java => plsql/Handler.java} | 42 +-
.../main/java/org/apache/doris/plsql/Interval.java | 111 +
.../src/main/java/org/apache/doris/plsql/Meta.java | 314 +++
.../main/java/org/apache/doris/plsql/Package.java | 196 ++
.../main/java/org/apache/doris/plsql/Plsql.java | 29 +-
.../main/java/org/apache/doris/plsql/Query.java | 144 ++
.../src/main/java/org/apache/doris/plsql/Row.java | 104 +
.../main/java/org/apache/doris/plsql/Scope.java | 80 +
.../main/java/org/apache/doris/plsql/Signal.java | 54 +
.../main/java/org/apache/doris/plsql/SqlCodes.java | 30 +-
.../src/main/java/org/apache/doris/plsql/Stmt.java | 1026 +++++++++
.../java/org/apache/doris/plsql/StreamGobbler.java | 55 +
.../SyntaxErrorReporter.java} | 28 +-
.../main/java/org/apache/doris/plsql/Timer.java | 61 +
.../main/java/org/apache/doris/plsql/Utils.java | 330 +++
.../src/main/java/org/apache/doris/plsql/Var.java | 634 ++++++
.../exception/ArityException.java} | 27 +-
.../plsql/exception/NoSuchPlMethodException.java | 29 +-
.../plsql/exception/PlValidationException.java | 36 +-
.../exception/QueryException.java} | 32 +-
.../doris/plsql/exception/TypeException.java | 39 +
.../plsql/exception/UndefinedIdentException.java | 29 +-
.../apache/doris/plsql/executor/ColumnMeta.java | 57 +
.../doris/plsql/executor/DorisRowResult.java | 145 ++
.../doris/plsql/executor/JdbcQueryExecutor.java | 115 +
.../org/apache/doris/plsql/executor/Metadata.java | 57 +
.../doris/plsql/executor/PlSqlOperation.java | 74 +
.../doris/plsql/executor/PlsqlQueryExecutor.java | 80 +
.../apache/doris/plsql/executor/PlsqlResult.java | 208 ++
.../executor/QueryExecutor.java} | 28 +-
.../apache/doris/plsql/executor/QueryResult.java | 122 +
.../doris/plsql/executor/ResultListener.java | 65 +
.../executor/RowResult.java} | 31 +-
.../doris/plsql/functions/BuiltinFunctions.java | 442 ++++
.../plsql/functions/DorisFunctionRegistry.java | 240 ++
.../apache/doris/plsql/functions/FuncCommand.java | 27 +-
.../doris/plsql/functions/FuncSpecCommand.java | 27 +-
.../doris/plsql/functions/FunctionDatetime.java | 203 ++
.../apache/doris/plsql/functions/FunctionMisc.java | 315 +++
.../doris/plsql/functions/FunctionRegistry.java | 40 +
.../doris/plsql/functions/FunctionString.java | 290 +++
.../plsql/functions/InMemoryFunctionRegistry.java | 274 +++
.../apache/doris/plsql/metastore/PlsqlManager.java | 126 +
.../doris/plsql/metastore/PlsqlMetaClient.java | 207 ++
.../apache/doris/plsql/metastore/PlsqlPackage.java | 74 +
.../doris/plsql/metastore/PlsqlProcedureKey.java | 90 +
.../plsql/metastore/PlsqlStoredProcedure.java | 71 +
.../objects/DbmOutput.java} | 38 +-
.../apache/doris/plsql/objects/DbmOutputClass.java | 46 +
.../org/apache/doris/plsql/objects/Method.java | 29 +-
.../doris/plsql/objects/MethodDictionary.java | 46 +
.../apache/doris/plsql/objects/MethodParams.java | 96 +
.../org/apache/doris/plsql/objects/PlClass.java | 27 +-
.../org/apache/doris/plsql/objects/PlObject.java | 27 +-
.../java/org/apache/doris/plsql/objects/Table.java | 225 ++
.../org/apache/doris/plsql/objects/TableClass.java | 135 ++
.../org/apache/doris/plsql/objects/UtlFile.java | 78 +
.../apache/doris/plsql/objects/UtlFileClass.java | 80 +
.../doris/plsql/packages/DorisPackageRegistry.java | 95 +
.../plsql/packages/InMemoryPackageRegistry.java | 74 +
.../doris/plsql/packages/PackageRegistry.java | 33 +-
.../java/org/apache/doris/policy/PolicyMgr.java | 28 +
.../apache/doris/qe/AutoCloseConnectContext.java | 5 +
.../java/org/apache/doris/qe/ConnectContext.java | 50 +-
.../java/org/apache/doris/qe/ConnectProcessor.java | 30 +-
.../java/org/apache/doris/qe/MasterOpExecutor.java | 10 +-
.../java/org/apache/doris/qe/SessionVariable.java | 64 +-
.../java/org/apache/doris/qe/StmtExecutor.java | 59 +-
.../resource/workloadgroup/WorkloadGroupMgr.java | 4 +
.../doris/rewrite/ElementAtToSlotRefRule.java | 6 -
.../apache/doris/service/FrontendServiceImpl.java | 118 +-
.../apache/doris/statistics/AnalysisManager.java | 2 +-
.../doris/statistics/util/StatisticsUtil.java | 2 +-
.../doris/clone/ClusterLoadStatisticsTest.java | 72 +-
.../org/apache/doris/mysql/MysqlChannelTest.java | 92 +
.../rules/rewrite/InferJoinNotNullTest.java | 12 +
.../doris/nereids/util/LogicalPlanBuilder.java | 13 +
gensrc/proto/olap_file.proto | 2 +
gensrc/proto/segment_v2.proto | 2 +
gensrc/thrift/DataSinks.thrift | 20 +-
gensrc/thrift/FrontendService.thrift | 55 +
gensrc/thrift/PaloInternalService.thrift | 2 +
gensrc/thrift/Partitions.thrift | 5 +-
.../test_null_aware_left_anti_join.out | 2 +
.../storage/test_dup_tab_auto_inc_10000.out | 6 +-
.../storage/test_dup_tab_auto_inc_basic.out | 36 +-
...=> test_dup_tab_auto_inc_start_value_10000.out} | 6 +-
.../test_dup_tab_auto_inc_start_value_basic.out | 34 +
...t => test_dup_tab_auto_inc_start_value_col.out} | 0
...test_dup_tab_auto_inc_start_value_with_null.out | 72 +
.../storage/test_dup_tab_auto_inc_with_null.out | 74 +-
.../unique/auto_inc_partial_update1.csv | 10 +-
.../unique/test_unique_table_auto_inc.out | 188 +-
.../datatype_p0/decimalv3}/test.csv | 0
.../hive/test_autoinc_broker_load.out | 42 +-
.../insert_p0/insert_group_commit_into_unique.out | 12 +-
.../insert_group_commit_into_unique_sync_mode.out | 12 +-
.../data/insert_p0/test_group_commit_2.csv | 2 +-
.../data/insert_p0/test_group_commit_4.csv | 2 +-
.../test_agg_table_mtmv.out} | 16 +-
.../data/mtmv_p0/test_hive_olap_mtmv.out | 17 +
.../data/mtmv_p0/test_hive_refresh_mtmv.out | 17 +
.../test_mor_table_mtmv.out} | 16 +-
.../test_mow_table_mtmv.out} | 16 +-
.../nereids_function_p0/agg_function/test_corr.out | 13 +
.../window_function/window_fn.out | 58 +
.../conditional_functions/test_query_like.out | 18 +
.../nereids_p0/subquery/subquery_unnesting.out | 12 +
.../push_down_filter_other_condition.out | 8 -
.../mv/agg_with_roll_up/aggregate_with_roll_up.out | 14 +
.../constraints/query23.out | 47 +-
.../test_plsql_loop_cursor.out} | 16 +-
.../conditional_functions/test_query_like.out | 18 +
.../window_functions/test_window_fn.out | 12 +
.../window_functions/test_window_function.out | 11 +
.../test_schema_change_agg_check_all_types.out | 55 +
.../data/statistics/test_analyze_mtmv.out | 6 +
.../data/variant_p0/compaction_sparse_column.out | 97 +
regression-test/data/variant_p0/load.out | 2 +-
regression-test/data/variant_p0/mv/multi_slot.out | 43 +
.../variant_p0/test_compaction_extract_root.out | 19 +
.../org/apache/doris/regression/suite/Suite.groovy | 14 +-
.../doris/regression/suite/SuiteCluster.groovy | 5 +
.../test_null_aware_left_anti_join.groovy | 8 +
.../storage/test_dup_tab_auto_inc_col.groovy | 23 +
.../test_dup_tab_auto_inc_start_value_10000.groovy | 115 +
.../test_dup_tab_auto_inc_start_value_basic.groovy | 114 +
...> test_dup_tab_auto_inc_start_value_col.groovy} | 72 +-
...t_dup_tab_auto_inc_start_value_with_null.groovy | 235 ++
.../suites/datatype_p0/decimalv3/test_load.groovy | 31 +-
.../export_p0/export/test_show_export.groovy | 4 +-
.../suites/mtmv_p0/test_agg_table_mtmv.groovy | 62 +
.../suites/mtmv_p0/test_hive_mtmv.groovy | 2 +-
.../suites/mtmv_p0/test_hive_olap_mtmv.groovy | 90 +
.../suites/mtmv_p0/test_hive_refresh_mtmv.groovy | 180 ++
.../suites/mtmv_p0/test_mor_table_mtmv.groovy | 62 +
.../suites/mtmv_p0/test_mow_table_mtmv.groovy | 62 +
.../mtmv_p0/test_partition_limit_mtmv.groovy | 74 +
.../mtmv_p0/test_partition_refresh_mtmv.groovy | 2 +
.../agg_function/test_corr.groovy | 85 +
.../window_function/window_fn.groovy | 10 +
.../suites/nereids_p0/aggregate/aggregate.groovy | 7 +
.../cte/test_cte_reuse_with_window.groovy | 43 +-
.../conditional_functions/test_query_like.groovy | 7 +
.../nereids_p0/subquery/subquery_unnesting.groovy | 1 +
.../push_down_filter_other_condition.groovy | 4 -
.../agg_with_roll_up/aggregate_with_roll_up.groovy | 43 +
.../mv/dimension/dimension_2_5.groovy | 4 +-
.../cross_join_list_str_increment_create.groovy | 361 +++
.../cross_join_range_date_increment_create.groovy | 356 +++
...cross_join_range_number_increment_create.groovy | 365 +++
.../full_join_list_str_increment_create.groovy | 360 +++
.../full_join_range_date_increment_create.groovy | 351 +++
.../full_join_range_number_increment_create.groovy | 360 +++
.../inner_join_list_str_increment_create.groovy | 375 +++
.../inner_join_range_date_increment_create.groovy | 366 +++
...inner_join_range_number_increment_create.groovy | 376 +++
...left_anti_join_list_str_increment_create.groovy | 334 +++
...ft_anti_join_range_date_increment_create.groovy | 325 +++
..._anti_join_range_number_increment_create.groovy | 331 +++
.../left_join_list_str_increment_create.groovy | 334 +++
.../left_join_range_date_increment_create.groovy | 325 +++
.../left_join_range_number_increment_create.groovy | 331 +++
...left_semi_join_list_str_increment_create.groovy | 334 +++
...ft_semi_join_range_date_increment_create.groovy | 325 +++
..._semi_join_range_number_increment_create.groovy | 331 +++
...ight_anti_join_list_str_increment_create.groovy | 353 +++
...ht_anti_join_range_date_increment_create.groovy | 344 +++
..._anti_join_range_number_increment_create.groovy | 353 +++
.../right_join_list_str_increment_create.groovy | 375 +++
.../right_join_range_date_increment_create.groovy | 366 +++
...right_join_range_number_increment_create.groovy | 375 +++
...ight_semi_join_list_str_increment_create.groovy | 352 +++
...ht_semi_join_range_date_increment_create.groovy | 344 +++
..._semi_join_range_number_increment_create.groovy | 353 +++
.../self_conn_list_str_increment_create.groovy | 343 +++
.../self_conn_range_date_increment_create.groovy | 334 +++
.../self_conn_range_number_increment_create.groovy | 344 +++
.../mv/negative/negative_test.groovy | 633 ++++++
.../constraints/query23.groovy | 2 +
regression-test/suites/plsql_p0/test_plsql.groovy | 74 +
.../suites/plsql_p0/test_plsql_loop_cursor.groovy | 62 +
.../conditional_functions/test_query_like.groovy | 7 +
.../window_functions/test_window_fn.groovy | 3 +
.../window_functions/test_window_function.groovy | 2 +
.../suites/query_p0/test_forward_qeury.groovy | 52 +
.../test_schema_change_agg_check_all_types.groovy | 64 +
.../suites/show_p0/test_show_data.groovy | 30 +-
.../suites/statistics/test_analyze_mtmv.groovy | 420 ++++
.../suites/statistics/test_analyze_mv.groovy | 171 +-
.../suites/variant_github_events_p0/load.groovy | 11 +
.../variant_p0/compaction_sparse_column.groovy | 173 ++
regression-test/suites/variant_p0/load.groovy | 2 +-
.../suites/variant_p0/mv/multi_slot.groovy | 93 +
.../variant_p0/schema_change/schema_change.groovy | 4 +-
.../variant_p0/test_compaction_extract_root.groovy | 152 ++
.../suites/variant_p0/variant_with_rowstore.groovy | 6 +-
.../workload_manager_p0/test_curd_wlg.groovy | 6 +-
426 files changed, 33258 insertions(+), 3098 deletions(-)
create mode 100644 be/src/vec/aggregate_functions/aggregate_function_binary.h
create mode 100644 be/src/vec/aggregate_functions/aggregate_function_corr.cpp
create mode 100644 be/src/vec/functions/function_variant_element.cpp
create mode 100644
docs/en/docs/sql-manual/sql-functions/aggregate-functions/corr.md
create mode 100644
docs/en/docs/sql-manual/sql-functions/window-functions/window-function-percent-rank.md
create mode 100644
docs/zh-CN/docs/sql-manual/sql-functions/aggregate-functions/corr.md
create mode 100644
docs/zh-CN/docs/sql-manual/sql-functions/window-functions/window-function-percent-rank.md
create mode 100644
fe/fe-core/src/main/antlr4/org/apache/doris/nereids/PLLexer.g4
create mode 100644
fe/fe-core/src/main/antlr4/org/apache/doris/nereids/PLParser.g4
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/httpv2/restv2/AddStoragePolicyAction.java
copy
fe/fe-core/src/main/java/org/apache/doris/{nereids/trees/plans/BlockFuncDepsPropagation.java
=> mysql/ProxyMysqlChannel.java} (61%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/parser/plsql/PLSqlLogicalPlanBuilder.java
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/{trees/plans/BlockFuncDepsPropagation.java
=> properties/ExprFdItem.java} (57%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/properties/FdFactory.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/properties/FdItem.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/properties/TableFdItem.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/expression/rules/ElementAtToSlot.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/EliminateGroupByKey.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/agg/Corr.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/window/PercentRank.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/CreateProcedureCommand.java
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/call/{CallFunc.java
=> CallProcedure.java} (51%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/info/FuncNameInfo.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/plsql/Arguments.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/plsql/Column.java
copy
fe/fe-core/src/main/java/org/apache/doris/{qe/AutoCloseConnectContext.java =>
plsql/ColumnDefinition.java} (52%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/plsql/ColumnMap.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/plsql/ColumnType.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/plsql/Conf.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/plsql/Conn.java
copy
fe/fe-core/src/main/java/org/apache/doris/{qe/AutoCloseConnectContext.java =>
plsql/Console.java} (52%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/plsql/Converter.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/plsql/Cursor.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/plsql/Exec.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/plsql/Expression.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/plsql/File.java
copy
fe/fe-core/src/main/java/org/apache/doris/{nereids/trees/plans/commands/call/CallFunc.java
=> plsql/Handler.java} (51%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/plsql/Interval.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/plsql/Meta.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/plsql/Package.java
copy be/src/olap/wal/wal_info.h =>
fe/fe-core/src/main/java/org/apache/doris/plsql/Plsql.java (62%)
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/plsql/Query.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/plsql/Row.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/plsql/Scope.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/plsql/Signal.java
copy be/src/olap/wal/wal_info.h =>
fe/fe-core/src/main/java/org/apache/doris/plsql/SqlCodes.java (62%)
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/plsql/Stmt.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/plsql/StreamGobbler.java
copy
fe/fe-core/src/main/java/org/apache/doris/{qe/AutoCloseConnectContext.java =>
plsql/SyntaxErrorReporter.java} (51%)
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/plsql/Timer.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/plsql/Utils.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/plsql/Var.java
copy
fe/fe-core/src/main/java/org/apache/doris/{qe/AutoCloseConnectContext.java =>
plsql/exception/ArityException.java} (55%)
copy be/src/olap/wal/wal_info.h =>
fe/fe-core/src/main/java/org/apache/doris/plsql/exception/NoSuchPlMethodException.java
(62%)
copy be/src/olap/wal/wal_info.h =>
fe/fe-core/src/main/java/org/apache/doris/plsql/exception/PlValidationException.java
(58%)
copy
fe/fe-core/src/main/java/org/apache/doris/{qe/AutoCloseConnectContext.java =>
plsql/exception/QueryException.java} (53%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/plsql/exception/TypeException.java
copy be/src/olap/wal/wal_info.h =>
fe/fe-core/src/main/java/org/apache/doris/plsql/exception/UndefinedIdentException.java
(62%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/plsql/executor/ColumnMeta.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/plsql/executor/DorisRowResult.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/plsql/executor/JdbcQueryExecutor.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/plsql/executor/Metadata.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/plsql/executor/PlSqlOperation.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/plsql/executor/PlsqlQueryExecutor.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/plsql/executor/PlsqlResult.java
copy
fe/fe-core/src/main/java/org/apache/doris/{qe/AutoCloseConnectContext.java =>
plsql/executor/QueryExecutor.java} (57%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/plsql/executor/QueryResult.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/plsql/executor/ResultListener.java
copy
fe/fe-core/src/main/java/org/apache/doris/{nereids/trees/plans/BlockFuncDepsPropagation.java
=> plsql/executor/RowResult.java} (58%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/plsql/functions/BuiltinFunctions.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/plsql/functions/DorisFunctionRegistry.java
copy be/src/olap/wal/wal_info.h =>
fe/fe-core/src/main/java/org/apache/doris/plsql/functions/FuncCommand.java (62%)
copy be/src/olap/wal/wal_info.h =>
fe/fe-core/src/main/java/org/apache/doris/plsql/functions/FuncSpecCommand.java
(62%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/plsql/functions/FunctionDatetime.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/plsql/functions/FunctionMisc.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/plsql/functions/FunctionRegistry.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/plsql/functions/FunctionString.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/plsql/functions/InMemoryFunctionRegistry.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/plsql/metastore/PlsqlManager.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/plsql/metastore/PlsqlMetaClient.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/plsql/metastore/PlsqlPackage.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/plsql/metastore/PlsqlProcedureKey.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/plsql/metastore/PlsqlStoredProcedure.java
copy
fe/fe-core/src/main/java/org/apache/doris/{nereids/trees/plans/BlockFuncDepsPropagation.java
=> plsql/objects/DbmOutput.java} (52%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/plsql/objects/DbmOutputClass.java
copy be/src/olap/wal/wal_info.h =>
fe/fe-core/src/main/java/org/apache/doris/plsql/objects/Method.java (62%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/plsql/objects/MethodDictionary.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/plsql/objects/MethodParams.java
copy be/src/olap/wal/wal_info.h =>
fe/fe-core/src/main/java/org/apache/doris/plsql/objects/PlClass.java (62%)
copy be/src/olap/wal/wal_info.h =>
fe/fe-core/src/main/java/org/apache/doris/plsql/objects/PlObject.java (62%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/plsql/objects/Table.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/plsql/objects/TableClass.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/plsql/objects/UtlFile.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/plsql/objects/UtlFileClass.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/plsql/packages/DorisPackageRegistry.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/plsql/packages/InMemoryPackageRegistry.java
copy be/src/olap/wal/wal_info.h =>
fe/fe-core/src/main/java/org/apache/doris/plsql/packages/PackageRegistry.java
(61%)
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/mysql/MysqlChannelTest.java
copy
regression-test/data/data_model_p0/duplicate/storage/{test_dup_tab_auto_inc_10000.out
=> test_dup_tab_auto_inc_start_value_10000.out} (74%)
create mode 100644
regression-test/data/data_model_p0/duplicate/storage/test_dup_tab_auto_inc_start_value_basic.out
copy
regression-test/data/data_model_p0/duplicate/storage/{test_dup_tab_auto_inc_col.out
=> test_dup_tab_auto_inc_start_value_col.out} (100%)
create mode 100644
regression-test/data/data_model_p0/duplicate/storage/test_dup_tab_auto_inc_start_value_with_null.out
copy regression-test/{suites/datatype_p0/decimalv3/test_data =>
data/datatype_p0/decimalv3}/test.csv (100%)
copy regression-test/data/{correctness_p0/test_null_aware_left_anti_join.out
=> mtmv_p0/test_agg_table_mtmv.out} (50%)
create mode 100644 regression-test/data/mtmv_p0/test_hive_olap_mtmv.out
create mode 100644 regression-test/data/mtmv_p0/test_hive_refresh_mtmv.out
copy regression-test/data/{correctness_p0/test_null_aware_left_anti_join.out
=> mtmv_p0/test_mor_table_mtmv.out} (50%)
copy regression-test/data/{correctness_p0/test_null_aware_left_anti_join.out
=> mtmv_p0/test_mow_table_mtmv.out} (50%)
create mode 100644
regression-test/data/nereids_function_p0/agg_function/test_corr.out
copy regression-test/data/{correctness_p0/test_null_aware_left_anti_join.out
=> plsql_p0/test_plsql_loop_cursor.out} (50%)
create mode 100644 regression-test/data/statistics/test_analyze_mtmv.out
create mode 100644 regression-test/data/variant_p0/compaction_sparse_column.out
create mode 100644 regression-test/data/variant_p0/mv/multi_slot.out
create mode 100644
regression-test/data/variant_p0/test_compaction_extract_root.out
create mode 100644
regression-test/suites/data_model_p0/duplicate/storage/test_dup_tab_auto_inc_start_value_10000.groovy
create mode 100644
regression-test/suites/data_model_p0/duplicate/storage/test_dup_tab_auto_inc_start_value_basic.groovy
copy
regression-test/suites/data_model_p0/duplicate/storage/{test_dup_tab_auto_inc_col.groovy
=> test_dup_tab_auto_inc_start_value_col.groovy} (73%)
create mode 100644
regression-test/suites/data_model_p0/duplicate/storage/test_dup_tab_auto_inc_start_value_with_null.groovy
create mode 100644 regression-test/suites/mtmv_p0/test_agg_table_mtmv.groovy
create mode 100644 regression-test/suites/mtmv_p0/test_hive_olap_mtmv.groovy
create mode 100644 regression-test/suites/mtmv_p0/test_hive_refresh_mtmv.groovy
create mode 100644 regression-test/suites/mtmv_p0/test_mor_table_mtmv.groovy
create mode 100644 regression-test/suites/mtmv_p0/test_mow_table_mtmv.groovy
create mode 100644
regression-test/suites/mtmv_p0/test_partition_limit_mtmv.groovy
create mode 100644
regression-test/suites/nereids_function_p0/agg_function/test_corr.groovy
copy be/src/olap/wal/wal_info.cpp =>
regression-test/suites/nereids_p0/cte/test_cte_reuse_with_window.groovy (50%)
create mode 100644
regression-test/suites/nereids_rules_p0/mv/increment_create/cross_join_list_str_increment_create.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/mv/increment_create/cross_join_range_date_increment_create.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/mv/increment_create/cross_join_range_number_increment_create.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/mv/increment_create/full_join_list_str_increment_create.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/mv/increment_create/full_join_range_date_increment_create.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/mv/increment_create/full_join_range_number_increment_create.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/mv/increment_create/inner_join_list_str_increment_create.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/mv/increment_create/inner_join_range_date_increment_create.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/mv/increment_create/inner_join_range_number_increment_create.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/mv/increment_create/left_anti_join_list_str_increment_create.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/mv/increment_create/left_anti_join_range_date_increment_create.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/mv/increment_create/left_anti_join_range_number_increment_create.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/mv/increment_create/left_join_list_str_increment_create.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/mv/increment_create/left_join_range_date_increment_create.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/mv/increment_create/left_join_range_number_increment_create.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/mv/increment_create/left_semi_join_list_str_increment_create.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/mv/increment_create/left_semi_join_range_date_increment_create.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/mv/increment_create/left_semi_join_range_number_increment_create.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/mv/increment_create/right_anti_join_list_str_increment_create.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/mv/increment_create/right_anti_join_range_date_increment_create.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/mv/increment_create/right_anti_join_range_number_increment_create.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/mv/increment_create/right_join_list_str_increment_create.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/mv/increment_create/right_join_range_date_increment_create.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/mv/increment_create/right_join_range_number_increment_create.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/mv/increment_create/right_semi_join_list_str_increment_create.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/mv/increment_create/right_semi_join_range_date_increment_create.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/mv/increment_create/right_semi_join_range_number_increment_create.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/mv/increment_create/self_conn_list_str_increment_create.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/mv/increment_create/self_conn_range_date_increment_create.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/mv/increment_create/self_conn_range_number_increment_create.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/mv/negative/negative_test.groovy
create mode 100644 regression-test/suites/plsql_p0/test_plsql.groovy
create mode 100644
regression-test/suites/plsql_p0/test_plsql_loop_cursor.groovy
create mode 100644 regression-test/suites/query_p0/test_forward_qeury.groovy
copy fe/fe-core/src/main/java/org/apache/doris/qe/AutoCloseConnectContext.java
=> regression-test/suites/show_p0/test_show_data.groovy (61%)
create mode 100644 regression-test/suites/statistics/test_analyze_mtmv.groovy
create mode 100644
regression-test/suites/variant_p0/compaction_sparse_column.groovy
create mode 100644 regression-test/suites/variant_p0/mv/multi_slot.groovy
create mode 100644
regression-test/suites/variant_p0/test_compaction_extract_root.groovy
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
