This is an automated email from the ASF dual-hosted git repository. morningman pushed a change to branch branch-1.2-lts in repository https://gitbox.apache.org/repos/asf/doris.git
discard 2ed8f15ba8 (bin) do not set heap limit for tcmalloc until doris does not allocates large unused memory add 458cb8f072 [chore](macOS) Support macOS Ventura (13.0) (#13626) add 9691db7918 [Enhancement](metrics) add more metrics (#11693) add 2563dcca95 [fix](load) fix core dump when get_memtable_consumption_inflush (#13629) add c486d9746d [fix](broker) fix bug when broker load with s3a (#13650) add b13061360f [enhancement](chore) build fe-common when build java-udf (#13647) add e00734348b [Chore](regression) Fix wrong result for decimal (#13644) add bd2b803019 [opt](tpch) opt the q9 of tpch to change instance to 8 (#13656) add a02a56eb38 [fix](postgresql) fix postgresql cann't find table (#13550) add 295d887cf5 [improvement](thread) set name for priority thread pool (#13552) add c709998faa [improvement][refactor](mysql) remove old mysql server and add keep alive option (#13663) add e385cb063c [improvement](config) allow to modify the master-only configuration of non-master nodes (#13558) add e5b33abd3c [fix](planner) inlineView alias error (#13600) add 15130c469f [fix](planner) cannot recogonize column's table when analyze rewrite expr (#13597) add 44c9163b3c [Fix](multi-catalog)Fix partition external table query bug. (#13535) add c418bbd2d1 [feature-wip](new-scan) support Json reader (#13546) add 3548d0b824 [fix](statistics) fix cross join statistics exception (#13645) add 65aa863dcf [Bugfix](bitmap) Fix to_bitmap_with_check function symbol is incorrect (#13667) add 0841c5bf28 [Bugfix](manager) fix query profile key incompatible with old versions (#13596) add c5559877b4 [typo](docs)fix docs 404 link (#13677) add bed759b3f5 [Fix](array-type) support CTAS for ARRAY column from collect_list and collect_set (#13627) add f4c8d4ce85 [feature](nereids) estimate plan cost by column ndv and table row count (#13375) add ddb27b9c3f nereids use decimal(27,9) (#13678) add 06e433e14a [fix](cmake)fix cmake error (#13637) add 0134e9d2f4 [Improvement](runtime filter) Reduce merging time for bloom filter (#13668) add 3c95106d45 [Bug](jdbc) Fix memory leak for JDBC datasource (#13657) add d2262bc8fb [docs]fix 404 (#13695) add 3e8cd0c669 [typo](doc) Add the description of json HDFS broker load (#13683) add 5bd66243ee [minor](log) remove some unused logs (#13689) add ffcb2f8525 [opt](exec) Replace get_utf8_byte_length function by array (#13664) add 7557980d64 [improvement](regression-test) avoid query empty result after loading finished (#13682) add 2697f72d77 [Improvement][SET-PROPERTY] Support for set query_timeout property (#13444) add c874931ac8 [fix](join)output all value from no-null side of outer join (#13655) add d388de6c11 [Enhancement](threadpool) print thread pool name on error (#13706) add 0e70d681d9 [feature](Nereids): Construct join graph (#13679) add ec86e9c9b2 [feature-wip][MTMV] The schedule framework for the MTMV (#13147) add 738da0b139 [bugfix](join) inner join return wrong result (#13608) add bad950136d [chore](build) Pass the compile flag -Wno-unused-but-set-variable on demand (#13716) add 4bfa95f669 [enhancement](tools) opt tpch q21: change join order (#13699) add 578d956a6b [typo](doc):Correct spelling mistakes UDAF. (#13711) add 45b31506c7 [improvement](delete) support delete from partitioned table without partition specified (#13533) add 36053d2419 [fix](array-type) fix the be core dump when select the invalid array format (#13514) add 43c6428aea [Function](string) support sub_replace function (#13736) add 5dd052d386 [Function](array) support array_range function (#13547) add f51464af59 [chore](macOS) Support Java UDF (#13714) add c108554f14 [function](date function) add new date function 'to_monday' #13707 add 859ffa6304 [bugfix](concat) be crash caused by function concat(ifnull) (#13693) add 20363edc73 [BugFix](function) fix reverse function dynamic buffer overflow due to illegal character (#13671) add 2ef8f3f6f4 [enhancement](java-udf) Support loading libjvm at runtime (#13660) add a8a91a827a [fix] Fix the variable of boost_ROOT ,BOOST_ROOT will not work (#13450) add d6b72d9b89 [Bug](update) support to check optional value of agg_sort_infos (#13732) add 5805011629 [Feature](string-function) Add function mask/mask_first_n/mask_last_n (#13694) add 2fab0c45c7 [Feature](runtime-filter) add runtime filter breaking change adapt (#13246) add f325119362 [fix](regression-test) update table name string in tpch_sf1 explain case (#13724) add eab8876abc [Feature](remote) Using heavy schema change if the table is not enable light weight schema change (#13487) add e0667b297f [feature-wip](multi-catalog) reuse hdfsFs and decode parquet values in batch (#13688) add 2a5d3dbb6e feat(nereids): draw hyper graph by graphviz (#13749) 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 (2ed8f15ba8) \ N -- N -- N refs/heads/branch-1.2-lts (2a5d3dbb6e) 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. No new revisions were added by this update. Summary of changes: be/CMakeLists.txt | 25 +- ...eartbeat_server.h => be_exec_version_manager.h} | 60 +- be/src/agent/heartbeat_server.cpp | 34 +- be/src/agent/heartbeat_server.h | 17 - be/src/common/config.h | 2 + be/src/exec/odbc_connector.cpp | 2 +- be/src/exec/odbc_connector.h | 2 +- be/src/exec/odbc_scan_node.cpp | 2 +- be/src/exec/table_connector.h | 4 +- be/src/exprs/bitmap_function.cpp | 2 +- be/src/exprs/block_bloom_filter.hpp | 17 +- be/src/exprs/block_bloom_filter_avx_impl.cc | 1 + be/src/exprs/block_bloom_filter_impl.cc | 27 +- be/src/exprs/bloomfilter_predicate.h | 31 +- be/src/exprs/runtime_filter.cpp | 68 +- be/src/exprs/runtime_filter.h | 31 +- be/src/exprs/string_functions.cpp | 10 +- be/src/geo/CMakeLists.txt | 8 +- be/src/io/CMakeLists.txt | 1 + be/src/io/fs/file_system.h | 2 +- be/src/io/fs/file_system_map.cpp | 4 +- be/src/io/fs/file_system_map.h | 6 +- be/src/io/fs/local_file_system.cpp | 7 +- be/src/io/fs/local_file_system.h | 2 +- be/src/io/fs/s3_file_system.cpp | 5 +- be/src/io/fs/s3_file_system.h | 1 - be/src/io/fs/s3_file_writer.cpp | 243 +++ be/src/io/fs/s3_file_writer.h | 79 + be/src/io/hdfs_file_reader.cpp | 192 +- be/src/io/hdfs_file_reader.h | 87 +- be/src/olap/bloom_filter_predicate.cpp | 16 +- be/src/olap/bloom_filter_predicate.h | 14 +- be/src/olap/data_dir.h | 4 +- be/src/olap/delta_writer.cpp | 2 +- be/src/olap/reader.cpp | 14 +- be/src/olap/rowset/beta_rowset.cpp | 55 +- be/src/olap/rowset/beta_rowset.h | 7 +- be/src/olap/rowset/beta_rowset_writer.cpp | 20 +- be/src/olap/rowset/rowset.h | 3 + be/src/olap/rowset/rowset_meta.h | 8 +- be/src/olap/rowset/rowset_writer_context.h | 6 +- be/src/olap/rowset/segment_v2/segment.cpp | 2 +- be/src/olap/rowset/segment_v2/segment.h | 6 +- be/src/olap/schema_change.cpp | 14 +- be/src/olap/snapshot_manager.cpp | 2 +- be/src/olap/tablet.cpp | 17 +- be/src/olap/tablet.h | 6 + be/src/olap/tablet_meta.cpp | 2 +- be/src/olap/tablet_meta.h | 2 +- be/src/runtime/exec_env_init.cpp | 11 +- be/src/runtime/fragment_mgr.cpp | 16 +- be/src/runtime/fragment_mgr.h | 10 +- be/src/runtime/odbc_table_sink.cpp | 2 +- be/src/runtime/routine_load/data_consumer_group.h | 3 +- .../routine_load/routine_load_task_executor.cpp | 4 +- be/src/runtime/runtime_filter_mgr.cpp | 25 +- be/src/runtime/runtime_filter_mgr.h | 19 +- be/src/runtime/runtime_state.h | 16 +- be/src/service/internal_service.cpp | 16 +- be/src/util/CMakeLists.txt | 4 + be/src/util/doris_metrics.cpp | 8 + be/src/util/doris_metrics.h | 4 + be/src/util/jni-util.cpp | 61 +- be/src/util/libjvm_loader.cpp | 99 + .../fs/file_system_map.h => util/libjvm_loader.h} | 38 +- be/src/util/priority_thread_pool.hpp | 7 +- be/src/util/priority_work_stealing_thread_pool.hpp | 7 +- be/src/util/simd/vstring_function.h | 41 +- be/src/util/threadpool.cpp | 21 +- be/src/vec/CMakeLists.txt | 2 + .../aggregate_function_sort.cpp | 10 +- .../aggregate_functions/aggregate_function_sort.h | 24 +- be/src/vec/core/block.cpp | 9 +- be/src/vec/core/block.h | 4 +- be/src/vec/exec/format/json/new_json_reader.cpp | 754 +++++++ be/src/vec/exec/format/json/new_json_reader.h | 150 ++ be/src/vec/exec/format/parquet/parquet_common.cpp | 194 +- be/src/vec/exec/format/parquet/parquet_common.h | 340 ++-- .../parquet/vparquet_column_chunk_reader.cpp | 39 +- .../format/parquet/vparquet_column_chunk_reader.h | 5 +- .../exec/format/parquet/vparquet_column_reader.cpp | 153 +- .../exec/format/parquet/vparquet_group_reader.cpp | 22 + .../exec/format/parquet/vparquet_group_reader.h | 4 + be/src/vec/exec/format/parquet/vparquet_reader.cpp | 5 +- be/src/vec/exec/join/vhash_join_node.cpp | 52 +- be/src/vec/exec/scan/new_jdbc_scanner.cpp | 3 +- be/src/vec/exec/scan/new_odbc_scanner.cpp | 2 +- be/src/vec/exec/scan/scanner_scheduler.cpp | 4 +- be/src/vec/exec/scan/vfile_scanner.cpp | 33 +- be/src/vec/exec/vaggregation_node.cpp | 8 +- be/src/vec/exec/vjdbc_connector.cpp | 151 +- be/src/vec/exec/vjdbc_connector.h | 8 +- be/src/vec/exec/vjdbc_scan_node.cpp | 2 +- be/src/vec/exec/vodbc_scan_node.cpp | 2 +- be/src/vec/exec/vunion_node.cpp | 4 +- be/src/vec/exprs/vbloom_predicate.cpp | 7 +- be/src/vec/exprs/vbloom_predicate.h | 3 +- be/src/vec/exprs/vectorized_agg_fn.cpp | 4 +- be/src/vec/exprs/vexpr.cpp | 4 +- .../vec/functions/array/function_array_range.cpp | 195 ++ .../functions/array/function_array_register.cpp | 2 + be/src/vec/functions/function_ifnull.h | 4 +- be/src/vec/functions/function_string.cpp | 5 + be/src/vec/functions/function_string.h | 334 +++- be/src/vec/functions/function_timestamp.cpp | 122 ++ be/src/vec/sink/vdata_stream_sender.cpp | 5 +- be/src/vec/sink/vjdbc_table_sink.cpp | 3 +- be/src/vec/sink/vodbc_table_sink.cpp | 2 +- be/src/vec/sink/vtablet_sink.cpp | 3 +- .../olap/bloom_filter_column_predicate_test.cpp | 8 +- be/test/olap/rowid_conversion_test.cpp | 2 +- be/test/olap/rowset/beta_rowset_test.cpp | 2 +- .../olap/rowset/segment_v2/bitmap_index_test.cpp | 5 +- be/test/olap/skiplist_test.cpp | 2 +- be/test/runtime/test_env.cc | 2 +- be/test/vec/core/block_test.cpp | 4 +- be/test/vec/core/column_complex_test.cpp | 10 +- be/test/vec/exec/parquet/parquet_thrift_test.cpp | 26 +- bin/check_be_version.sh | 93 - bin/start_be.sh | 31 +- build.sh | 18 +- dist/LICENSE-dist.txt | 2 +- .../docker-compose/hive/scripts/hive-metastore.sh | 2 + .../scripts/json_format_test}/multi_line_json.json | 0 .../multi_line_json_lack_column.json | 2 + .../json_format_test/multi_line_json_unorder.json | 2 + .../hive/scripts/json_format_test/nest_json.json | 5 + .../json_format_test}/simple_object_json.json | 0 docs/dev.json | 6 +- .../release-and-verify/release-doris-manager.md | 2 +- .../community/release-and-verify/release-verify.md | 6 +- .../cluster-management/elastic-expansion.md | 4 +- docs/en/docs/admin-manual/config/fe-config.md | 14 +- .../docs/admin-manual/data-admin/delete-recover.md | 2 +- .../http-actions/fe/table-schema-action.md | 2 +- .../admin-manual/maint-monitor/disk-capacity.md | 2 +- .../maint-monitor/metadata-operation.md | 2 +- docs/en/docs/advanced/alter-table/replace-table.md | 4 +- docs/en/docs/advanced/alter-table/schema-change.md | 2 +- docs/en/docs/data-operate/export/outfile.md | 2 +- .../import/import-scenes/external-storage-load.md | 2 +- .../data-operate/import/import-scenes/jdbc-load.md | 2 +- docs/en/docs/data-table/basic-usage.md | 16 +- docs/en/docs/ecosystem/doris-manager/space-list.md | 6 +- .../ecosystem/external-table/hive-bitmap-udf.md | 4 +- .../docs/ecosystem/external-table/multi-catalog.md | 2 +- docs/en/docs/ecosystem/logstash.md | 4 +- docs/en/docs/install/install-deploy.md | 2 +- .../sql-functions/array-functions/array_range.md | 76 + .../date-time-functions/to_monday.md} | 34 +- .../sql-functions/string-functions/mask/mask.md | 66 + .../string-functions/mask/mask_first_n.md | 57 + .../string-functions/mask/mask_last_n.md | 57 + .../sql-functions/string-functions/sub_replace.md | 53 + .../Account-Management-Statements/SET-PROPERTY.md | 8 + .../Alter/ALTER-TABLE-PARTITION.md | 2 +- .../Alter/ALTER-TABLE-REPLACE.md | 4 +- .../Alter/ALTER-TABLE-ROLLUP.md | 2 +- .../Data-Definition-Statements/Drop/DROP-TABLE.md | 2 +- .../Load/BROKER-LOAD.md | 72 +- .../Load/CREATE-SYNC-JOB.md | 2 +- .../Load/STREAM-LOAD.md | 8 +- .../Manipulation/DELETE.md | 2 +- .../SHOW-ALTER-TABLE-MATERIALIZED-VIEW.md | 2 +- .../sql-reference/Show-Statements/SHOW-STATUS.md | 3 - docs/sidebars.json | 66 +- .../how-to-contribute/how-to-contribute.md | 2 +- .../release-and-verify/release-prepare.md | 2 +- .../community/release-and-verify/release-verify.md | 6 +- .../cluster-management/elastic-expansion.md | 2 +- docs/zh-CN/docs/admin-manual/config/fe-config.md | 12 +- .../docs/admin-manual/data-admin/delete-recover.md | 2 +- .../http-actions/fe/table-schema-action.md | 2 +- .../maint-monitor/monitor-metrics/metrics.md | 13 +- .../maint-monitor/tablet-repair-and-balance.md | 2 +- .../docs/advanced/alter-table/replace-table.md | 4 +- docs/zh-CN/docs/data-operate/export/outfile.md | 2 +- .../import/import-scenes/external-storage-load.md | 2 +- .../data-operate/import/import-scenes/jdbc-load.md | 2 +- docs/zh-CN/docs/data-table/basic-usage.md | 18 +- docs/zh-CN/docs/data-table/hit-the-rollup.md | 2 +- .../docs/ecosystem/doris-manager/space-list.md | 6 +- .../ecosystem/external-table/hive-bitmap-udf.md | 4 +- .../docs/ecosystem/external-table/multi-catalog.md | 2 +- docs/zh-CN/docs/ecosystem/logstash.md | 4 +- .../sql-functions/array-functions/array_range.md | 74 + .../date-time-functions/to_monday.md} | 33 +- .../sql-functions/string-functions/mask/mask.md | 66 + .../string-functions/mask/mask_first_n.md} | 51 +- .../string-functions/mask/mask_last_n.md} | 51 +- .../sql-functions/string-functions/sub_replace.md | 52 + .../Account-Management-Statements/SET-PROPERTY.md | 8 + .../Alter/ALTER-TABLE-PARTITION.md | 2 +- .../Alter/ALTER-TABLE-REPLACE.md | 2 +- .../Alter/ALTER-TABLE-ROLLUP.md | 2 +- .../Data-Definition-Statements/Drop/DROP-TABLE.md | 2 +- .../Load/BROKER-LOAD.md | 75 +- .../Manipulation/DELETE.md | 2 +- .../SHOW-ALTER-TABLE-MATERIALIZED-VIEW.md | 2 +- .../sql-reference/Show-Statements/SHOW-STATUS.md | 72 + env.sh | 1 + .../src/main/java/org/apache/doris/PaloFe.java | 3 +- .../doris/alter/MaterializedViewHandler.java | 2 +- .../java/org/apache/doris/analysis/Analyzer.java | 24 +- .../org/apache/doris/analysis/DataDescription.java | 9 +- .../java/org/apache/doris/analysis/ExportStmt.java | 11 +- .../apache/doris/analysis/FunctionCallExpr.java | 10 + .../org/apache/doris/analysis/InlineViewRef.java | 3 + .../java/org/apache/doris/analysis/SlotRef.java | 5 + .../org/apache/doris/analysis/TupleDescriptor.java | 4 + .../main/java/org/apache/doris/catalog/Env.java | 31 +- .../doris/catalog/HiveMetaStoreClientHelper.java | 5 +- .../java/org/apache/doris/catalog/OdbcTable.java | 4 +- .../main/java/org/apache/doris/common/Config.java | 20 +- .../java/org/apache/doris/common/ConfigBase.java | 5 - .../org/apache/doris/common/ThreadPoolManager.java | 53 +- .../apache/doris/datasource/InternalCatalog.java | 15 + .../httpv2/rest/manager/QueryProfileAction.java | 5 +- .../org/apache/doris/journal/JournalEntity.java | 30 + .../apache/doris/journal/bdbje/BDBDebugger.java | 3 +- .../org/apache/doris/load/BrokerFileGroup.java | 6 +- .../java/org/apache/doris/load/DeleteHandler.java | 129 +- .../org/apache/doris/metric/AutoMappedMetric.java | 22 +- .../java/org/apache/doris/metric/MetricRepo.java | 144 +- .../java/org/apache/doris/mtmv/MTMVJobFactory.java | 38 +- .../java/org/apache/doris/mtmv/MTMVJobManager.java | 421 ++++ .../org/apache/doris/mtmv/MTMVTaskContext.java | 61 + .../apache/doris/mtmv/MTMVTaskExecuteParams.java | 21 +- .../org/apache/doris/mtmv/MTMVTaskExecutor.java | 179 ++ .../apache/doris/mtmv/MTMVTaskExecutorPool.java | 76 + .../org/apache/doris/mtmv/MTMVTaskManager.java | 432 ++++ .../org/apache/doris/mtmv/MTMVTaskProcessor.java | 14 +- .../main/java/org/apache/doris/mtmv/MTMVUtils.java | 114 ++ .../apache/doris/mtmv/metadata/AlterMTMVTask.java | 133 ++ .../apache/doris/mtmv/metadata/ChangeMTMVJob.java | 98 + .../apache/doris/mtmv/metadata/DropMTMVJob.java | 52 + .../apache/doris/mtmv/metadata/DropMTMVTask.java | 53 + .../doris/mtmv/metadata/MTMVCheckpointData.java | 48 + .../org/apache/doris/mtmv/metadata/MTMVJob.java | 251 +++ .../org/apache/doris/mtmv/metadata/MTMVTask.java | 187 ++ .../java/org/apache/doris/mysql/MysqlChannel.java | 1 - .../java/org/apache/doris/mysql/MysqlServer.java | 149 -- .../org/apache/doris/mysql/nio/AcceptListener.java | 4 + .../org/apache/doris/mysql/nio/NMysqlServer.java | 12 +- .../mysql/privilege/CommonUserProperties.java | 11 + .../org/apache/doris/mysql/privilege/PaloAuth.java | 9 + .../apache/doris/mysql/privilege/UserProperty.java | 20 + .../doris/mysql/privilege/UserPropertyMgr.java | 9 + .../org/apache/doris/nereids/NereidsPlanner.java | 12 + .../apache/doris/nereids/cost/CostCalculator.java | 114 +- .../apache/doris/nereids/cost/CostEstimate.java | 40 +- .../org/apache/doris/nereids/cost/CostWeight.java | 8 +- .../nereids/jobs/cascades/CostAndEnforcerJob.java | 2 + .../apache/doris/nereids/memo/GroupExpression.java | 36 +- .../nereids/properties/DistributionSpecHash.java | 6 +- .../properties/EnforceMissingPropertiesHelper.java | 2 +- .../apache/doris/nereids/properties/OrderSpec.java | 1 + .../nereids/properties/PhysicalProperties.java | 6 + .../org/apache/doris/nereids/rules/RuleType.java | 3 + .../rules/exploration/join/JoinReorderRule.java | 40 + .../rules/exploration/join/hypergraph/Edge.java | 91 + .../exploration/join/hypergraph/HyperGraph.java | 178 ++ .../rules/exploration/join/hypergraph/Node.java | 60 + .../exploration/join/hypergraph/Receiver.java | 70 + .../doris/nereids/stats/ExpressionEstimation.java | 46 +- .../doris/nereids/stats/FilterEstimation.java | 282 ++- .../nereids/stats/FilterSelectivityCalculator.java | 13 +- .../apache/doris/nereids/stats/JoinEstimation.java | 80 +- .../doris/nereids/stats/StatsCalculator.java | 11 +- .../doris/nereids/stats/StatsCalculatorV2.java | 15 +- .../trees/expressions/literal/CharLiteral.java | 12 + .../nereids/trees/expressions/literal/Literal.java | 16 + .../trees/expressions/literal/StringLiteral.java | 12 + .../trees/expressions/literal/VarcharLiteral.java | 12 + .../trees/plans/physical/PhysicalAggregate.java | 3 +- .../trees/plans/physical/PhysicalOlapScan.java | 3 +- .../trees/plans/physical/PhysicalProject.java | 3 +- .../apache/doris/nereids/types/DecimalType.java | 2 +- .../java/org/apache/doris/persist/EditLog.java | 60 + .../org/apache/doris/persist/OperationType.java | 9 + .../doris/persist/meta/MetaPersistMethod.java | 6 + .../doris/persist/meta/PersistMetaModules.java | 2 +- .../org/apache/doris/planner/JdbcScanNode.java | 2 +- .../org/apache/doris/planner/OlapTableSink.java | 11 + .../apache/doris/planner/StreamLoadPlanner.java | 6 +- .../doris/planner/external/HiveScanProvider.java | 9 +- .../java/org/apache/doris/qe/ConnectContext.java | 27 +- .../java/org/apache/doris/qe/ConnectProcessor.java | 1 + .../java/org/apache/doris/qe/ConnectScheduler.java | 1 + .../main/java/org/apache/doris/qe/Coordinator.java | 4 + .../java/org/apache/doris/qe/QeProcessorImpl.java | 2 + .../main/java/org/apache/doris/qe/QeService.java | 21 +- .../java/org/apache/doris/qe/SessionVariable.java | 2 + .../org/apache/doris/rpc/BackendServiceProxy.java | 3 + .../java/org/apache/doris/service/FeServer.java | 18 +- .../org/apache/doris/statistics/ColumnStat.java | 61 +- .../doris/statistics/HashJoinStatsDerive.java | 9 +- .../apache/doris/statistics/StatsDeriveResult.java | 51 +- .../java/org/apache/doris/system/HeartbeatMgr.java | 1 - .../doris/transaction/DatabaseTransactionMgr.java | 44 +- .../doris/transaction/GlobalTransactionMgr.java | 28 + .../doris/transaction/PublishVersionDaemon.java | 5 + .../apache/doris/transaction/TransactionState.java | 25 +- .../org/apache/doris/catalog/UserPropertyTest.java | 4 + .../apache/doris/common/ThreadPoolManagerTest.java | 7 - .../org/apache/doris/mtmv/MTMVJobManagerTest.java | 79 + .../apache/doris/mtmv/MTMVTaskExecutorTest.java | 104 + .../java/org/apache/doris/mtmv/MTMVUtilsTest.java | 89 + .../org/apache/doris/mysql/MysqlServerTest.java | 21 +- .../rules/exploration/join/JoinReorderTest.java | 11 +- .../join/hypergraph/HyperGraphTest.java | 59 + .../doris/nereids/stats/FilterEstimationTest.java | 5 +- .../apache/doris/planner/ResourceTagQueryTest.java | 2 +- .../java/org/apache/doris/policy/PolicyTest.java | 2 +- .../org/apache/doris/qe/ConnectContextTest.java | 13 + fe/java-udf/pom.xml | 5 + .../java/org/apache/doris/udf/JdbcExecutor.java | 70 +- fe/pom.xml | 1 + gensrc/script/doris_builtins_functions.py | 23 +- gensrc/thrift/HeartbeatService.thrift | 1 - gensrc/thrift/PaloInternalService.thrift | 2 + gensrc/thrift/PlanNodes.thrift | 2 + gensrc/thrift/Types.thrift | 12 +- regression-test/conf/regression-conf.groovy | 1 + .../data/correctness_p0/test_mask_function.out | 57 + .../test_outer_join_with_null_value.out} | 7 +- .../data/datev2/tpch_sf1_p1/tpch_sf1/sql/q01.out | 7 + .../{ => datev2}/tpch_sf1_p1/tpch_sf1/sql/q02.out | 24 +- .../data/datev2/tpch_sf1_p1/tpch_sf1/sql/q03.out | 13 + .../datev2/tpch_sf1_p1/{ => tpch_sf1}/sql/q04.out | 0 .../data/datev2/tpch_sf1_p1/tpch_sf1/sql/q05.out | 8 + .../{ => datev2}/tpch_sf1_p1/tpch_sf1/sql/q06.out | 2 +- .../data/datev2/tpch_sf1_p1/tpch_sf1/sql/q07.out | 7 + .../{ => datev2}/tpch_sf1_p1/tpch_sf1/sql/q08.out | 2 +- .../data/datev2/tpch_sf1_p1/tpch_sf1/sql/q09.out | 178 ++ .../data/datev2/tpch_sf1_p1/tpch_sf1/sql/q10.out | 23 + .../data/datev2/tpch_sf1_p1/tpch_sf1/sql/q11.out | 1051 ++++++++++ .../datev2/tpch_sf1_p1/{ => tpch_sf1}/sql/q12.out | 0 .../datev2/tpch_sf1_p1/{ => tpch_sf1}/sql/q13.out | 0 .../datev2/tpch_sf1_p1/{ => tpch_sf1}/sql/q14.out | 0 .../{ => datev2}/tpch_sf1_p1/tpch_sf1/sql/q15.out | 2 +- .../datev2/tpch_sf1_p1/{ => tpch_sf1}/sql/q16.out | 0 .../datev2/tpch_sf1_p1/{ => tpch_sf1}/sql/q17.out | 0 .../data/datev2/tpch_sf1_p1/tpch_sf1/sql/q18.out | 60 + .../{ => datev2}/tpch_sf1_p1/tpch_sf1/sql/q19.out | 2 +- .../datev2/tpch_sf1_p1/{ => tpch_sf1}/sql/q20.out | 0 .../datev2/tpch_sf1_p1/{ => tpch_sf1}/sql/q21.out | 0 .../data/datev2/tpch_sf1_p1/tpch_sf1/sql/q22.out | 10 + .../data/delete_p0/test_delete_from_partition.out | 96 + .../data/load_p0/broker_load/test_array_load.out | 40 + .../stream_load/load_json_null_to_nullable.out | 12 + .../stream_load/load_json_with_jsonpath.out | 10 + .../data/load_p0/stream_load/nest_json.json | 3 + .../data/load_p0/stream_load/nest_json_array.json | 74 + .../data/load_p0/stream_load/simple_json2.json | 52 + .../stream_load/simple_json2_lack_one_column.json | 48 + .../load_p0/stream_load/test_hdfs_json_load.out | 305 +++ .../data/load_p0/stream_load/test_json_load.out | 236 ++- regression-test/data/query/join/test_join.out | 350 ++-- .../aggregate_functions/test_aggregate_collect.out | 3 + .../array_functions/test_issue_13606.out} | 14 +- .../conditional_functions/test_nullif.out | 6 + .../datetime_functions/test_date_function.out | 7 + .../string_functions/test_reverse.out | 3 + .../string_functions/test_string_function.out | 6 + regression-test/data/tpcds_sf100_p2/sql/q58.out | 200 +- regression-test/data/tpcds_sf100_p2/sql/q83.out | 196 +- .../data/tpch_sf1_p1/tpch_sf1/sql/q01.out | 8 +- .../data/tpch_sf1_p1/tpch_sf1/sql/q02.out | 24 +- .../data/tpch_sf1_p1/tpch_sf1/sql/q03.out | 20 +- .../data/tpch_sf1_p1/tpch_sf1/sql/q05.out | 10 +- .../data/tpch_sf1_p1/tpch_sf1/sql/q06.out | 2 +- .../data/tpch_sf1_p1/tpch_sf1/sql/q07.out | 8 +- .../data/tpch_sf1_p1/tpch_sf1/sql/q08.out | 2 +- .../data/tpch_sf1_p1/tpch_sf1/sql/q09.out | 350 ++-- .../data/tpch_sf1_p1/tpch_sf1/sql/q10.out | 40 +- .../data/tpch_sf1_p1/tpch_sf1/sql/q11.out | 2096 ++++++++++---------- .../data/tpch_sf1_p1/tpch_sf1/sql/q15.out | 2 +- .../data/tpch_sf1_p1/tpch_sf1/sql/q18.out | 114 +- .../data/tpch_sf1_p1/tpch_sf1/sql/q19.out | 2 +- .../data/tpch_sf1_p1/tpch_sf1/sql/q22.out | 14 +- .../apache/doris/regression/RegressionTest.groovy | 1 - .../doris/regression/suite/SuiteScript.groovy | 2 +- .../correctness/test_mv_alias_table_name.groovy | 63 + .../correctness/test_pushdown_pred_to_view.groovy | 2 +- .../suites/correctness/test_table_alias.groovy | 47 + .../correctness_p0/test_mask_function.groovy | 74 + .../test_outer_join_with_null_value.groovy | 91 + ...t_outer_join_with_window_function_datev2.groovy | 2 + .../tpch_sf1_p1/tpch_sf1/ddl/create_table.sql | 0 .../tpch_sf1_p1/tpch_sf1/ddl/customer.sql | 0 .../{ => tpch_sf1}/ddl/customer_delete.sql | 0 .../tpch_sf1_p1/tpch_sf1/ddl/lineitem.sql | 0 .../{ => tpch_sf1}/ddl/lineitem_delete.sql | 0 .../tpch_sf1_p1/tpch_sf1/ddl/nation.sql | 0 .../{ => tpch_sf1}/ddl/nation_delete.sql | 0 .../tpch_sf1_p1/tpch_sf1/ddl/orders.sql | 0 .../{ => tpch_sf1}/ddl/orders_delete.sql | 0 .../{ => datev2}/tpch_sf1_p1/tpch_sf1/ddl/part.sql | 0 .../tpch_sf1_p1/{ => tpch_sf1}/ddl/part_delete.sql | 0 .../tpch_sf1_p1/tpch_sf1/ddl/partsupp.sql | 0 .../{ => tpch_sf1}/ddl/partsupp_delete.sql | 0 .../tpch_sf1_p1/tpch_sf1/ddl/region.sql | 0 .../{ => tpch_sf1}/ddl/region_delete.sql | 0 .../tpch_sf1_p1/tpch_sf1}/ddl/revenue1.sql | 0 .../{ => tpch_sf1}/ddl/revenue1_delete.sql | 0 .../tpch_sf1_p1/tpch_sf1/ddl/supplier.sql | 0 .../{ => tpch_sf1}/ddl/supplier_delete.sql | 0 .../{ => datev2}/tpch_sf1_p1/tpch_sf1/load.groovy | 0 .../tpch_sf1_p1/tpch_sf1}/sql/q01.sql | 0 .../datev2/tpch_sf1_p1/{ => tpch_sf1}/sql/q02.sql | 0 .../tpch_sf1_p1/tpch_sf1}/sql/q03.sql | 0 .../tpch_sf1_p1/tpch_sf1}/sql/q04.sql | 0 .../tpch_sf1_p1/tpch_sf1}/sql/q05.sql | 0 .../tpch_sf1_p1/tpch_sf1}/sql/q06.sql | 0 .../tpch_sf1_p1/tpch_sf1}/sql/q07.sql | 0 .../tpch_sf1_p1/tpch_sf1}/sql/q08.sql | 0 .../datev2/tpch_sf1_p1/{ => tpch_sf1}/sql/q09.sql | 0 .../tpch_sf1_p1/tpch_sf1}/sql/q10.sql | 0 .../datev2/tpch_sf1_p1/{ => tpch_sf1}/sql/q11.sql | 0 .../tpch_sf1_p1/tpch_sf1}/sql/q12.sql | 0 .../datev2/tpch_sf1_p1/{ => tpch_sf1}/sql/q13.sql | 0 .../tpch_sf1_p1/tpch_sf1}/sql/q14.sql | 0 .../datev2/tpch_sf1_p1/{ => tpch_sf1}/sql/q15.sql | 0 .../datev2/tpch_sf1_p1/{ => tpch_sf1}/sql/q16.sql | 0 .../datev2/tpch_sf1_p1/{ => tpch_sf1}/sql/q17.sql | 0 .../datev2/tpch_sf1_p1/{ => tpch_sf1}/sql/q18.sql | 0 .../datev2/tpch_sf1_p1/{ => tpch_sf1}/sql/q19.sql | 0 .../tpch_sf1_p1/tpch_sf1}/sql/q20.sql | 0 .../datev2/tpch_sf1_p1/{ => tpch_sf1}/sql/q21.sql | 0 .../datev2/tpch_sf1_p1/{ => tpch_sf1}/sql/q22.sql | 0 .../delete_p0/test_delete_from_partition.groovy | 68 + .../load_p0/broker_load/test_array_load.groovy | 136 +- ...n_column_exclude_schema_without_jsonpath.groovy | 19 +- .../stream_load/load_json_null_to_nullable.groovy | 38 +- .../stream_load/load_json_with_jsonpath.groovy | 36 +- .../load_p0/stream_load/test_hdfs_json_load.groovy | 554 ++++++ .../load_p0/stream_load/test_json_load.groovy | 404 +++- regression-test/suites/query/join/test_join.groovy | 4 + .../test_aggregate_collect.groovy | 5 + .../test_array_functions_by_literal.groovy | 6 + .../array_functions/test_issue_13606.groovy | 56 + .../conditional_functions/test_nullif.groovy | 3 + .../datetime_functions/test_date_function.groovy | 27 + .../string_functions/test_reverse.groovy | 1 + .../string_functions/test_string_function.groovy | 3 + .../load_one_step/load.groovy | 2 + .../hive_catalog.groovy | 33 +- .../tpch_sf1_p1/tpch_sf1/explain/test_q1.groovy | 2 +- .../tpch_sf1_p1/tpch_sf1/explain/test_q10.groovy | 8 +- .../tpch_sf1_p1/tpch_sf1/explain/test_q11.groovy | 12 +- .../tpch_sf1_p1/tpch_sf1/explain/test_q12.groovy | 4 +- .../tpch_sf1_p1/tpch_sf1/explain/test_q13.groovy | 4 +- .../tpch_sf1_p1/tpch_sf1/explain/test_q14.groovy | 4 +- .../tpch_sf1_p1/tpch_sf1/explain/test_q15.groovy | 6 +- .../tpch_sf1_p1/tpch_sf1/explain/test_q16.groovy | 6 +- .../tpch_sf1_p1/tpch_sf1/explain/test_q17.groovy | 6 +- .../tpch_sf1_p1/tpch_sf1/explain/test_q18.groovy | 10 +- .../tpch_sf1_p1/tpch_sf1/explain/test_q19.groovy | 4 +- .../tpch_sf1_p1/tpch_sf1/explain/test_q2.groovy | 18 +- .../tpch_sf1_p1/tpch_sf1/explain/test_q20.groovy | 10 +- .../tpch_sf1_p1/tpch_sf1/explain/test_q21.groovy | 12 +- .../tpch_sf1_p1/tpch_sf1/explain/test_q22.groovy | 6 +- .../tpch_sf1_p1/tpch_sf1/explain/test_q3.groovy | 6 +- .../tpch_sf1_p1/tpch_sf1/explain/test_q4.groovy | 4 +- .../tpch_sf1_p1/tpch_sf1/explain/test_q5.groovy | 12 +- .../tpch_sf1_p1/tpch_sf1/explain/test_q6.groovy | 2 +- .../tpch_sf1_p1/tpch_sf1/explain/test_q7.groovy | 12 +- .../tpch_sf1_p1/tpch_sf1/explain/test_q8.groovy | 16 +- .../tpch_sf1_p1/tpch_sf1/explain/test_q9.groovy | 12 +- run-be-ut.sh | 29 - thirdparty/build-thirdparty.sh | 4 +- tools/tpch-tools/queries/q21.sql | 22 +- tools/tpch-tools/queries/q9.sql | 4 +- 474 files changed, 14573 insertions(+), 3844 deletions(-) copy be/src/agent/{heartbeat_server.h => be_exec_version_manager.h} (52%) create mode 100644 be/src/io/fs/s3_file_writer.cpp create mode 100644 be/src/io/fs/s3_file_writer.h create mode 100644 be/src/util/libjvm_loader.cpp copy be/src/{io/fs/file_system_map.h => util/libjvm_loader.h} (53%) create mode 100644 be/src/vec/exec/format/json/new_json_reader.cpp create mode 100644 be/src/vec/exec/format/json/new_json_reader.h create mode 100644 be/src/vec/functions/array/function_array_range.cpp delete mode 100755 bin/check_be_version.sh copy {regression-test/data/load_p0/stream_load => docker/thirdparties/docker-compose/hive/scripts/json_format_test}/multi_line_json.json (100%) create mode 100644 docker/thirdparties/docker-compose/hive/scripts/json_format_test/multi_line_json_lack_column.json create mode 100644 docker/thirdparties/docker-compose/hive/scripts/json_format_test/multi_line_json_unorder.json create mode 100644 docker/thirdparties/docker-compose/hive/scripts/json_format_test/nest_json.json copy {regression-test/data/load_p0/stream_load => docker/thirdparties/docker-compose/hive/scripts/json_format_test}/simple_object_json.json (100%) create mode 100644 docs/en/docs/sql-manual/sql-functions/array-functions/array_range.md copy docs/{zh-CN/docs/sql-manual/sql-reference/Show-Statements/SHOW-STATUS.md => en/docs/sql-manual/sql-functions/date-time-functions/to_monday.md} (58%) create mode 100644 docs/en/docs/sql-manual/sql-functions/string-functions/mask/mask.md create mode 100644 docs/en/docs/sql-manual/sql-functions/string-functions/mask/mask_first_n.md create mode 100644 docs/en/docs/sql-manual/sql-functions/string-functions/mask/mask_last_n.md create mode 100644 docs/en/docs/sql-manual/sql-functions/string-functions/sub_replace.md create mode 100644 docs/zh-CN/docs/sql-manual/sql-functions/array-functions/array_range.md copy docs/zh-CN/docs/sql-manual/{sql-reference/Show-Statements/SHOW-STATUS.md => sql-functions/date-time-functions/to_monday.md} (58%) create mode 100644 docs/zh-CN/docs/sql-manual/sql-functions/string-functions/mask/mask.md copy docs/zh-CN/docs/sql-manual/{sql-reference/Show-Statements/SHOW-STATUS.md => sql-functions/string-functions/mask/mask_first_n.md} (51%) copy docs/zh-CN/docs/sql-manual/{sql-reference/Show-Statements/SHOW-STATUS.md => sql-functions/string-functions/mask/mask_last_n.md} (51%) create mode 100644 docs/zh-CN/docs/sql-manual/sql-functions/string-functions/sub_replace.md copy regression-test/suites/query_p0/sql_functions/string_functions/test_reverse.groovy => fe/fe-core/src/main/java/org/apache/doris/metric/AutoMappedMetric.java (60%) copy be/src/io/fs/file_system_map.cpp => fe/fe-core/src/main/java/org/apache/doris/mtmv/MTMVJobFactory.java (52%) create mode 100644 fe/fe-core/src/main/java/org/apache/doris/mtmv/MTMVJobManager.java create mode 100644 fe/fe-core/src/main/java/org/apache/doris/mtmv/MTMVTaskContext.java copy regression-test/suites/query_p0/sql_functions/string_functions/test_reverse.groovy => fe/fe-core/src/main/java/org/apache/doris/mtmv/MTMVTaskExecuteParams.java (68%) create mode 100644 fe/fe-core/src/main/java/org/apache/doris/mtmv/MTMVTaskExecutor.java create mode 100644 fe/fe-core/src/main/java/org/apache/doris/mtmv/MTMVTaskExecutorPool.java create mode 100644 fe/fe-core/src/main/java/org/apache/doris/mtmv/MTMVTaskManager.java copy regression-test/suites/query_p0/sql_functions/string_functions/test_reverse.groovy => fe/fe-core/src/main/java/org/apache/doris/mtmv/MTMVTaskProcessor.java (70%) create mode 100644 fe/fe-core/src/main/java/org/apache/doris/mtmv/MTMVUtils.java create mode 100644 fe/fe-core/src/main/java/org/apache/doris/mtmv/metadata/AlterMTMVTask.java create mode 100644 fe/fe-core/src/main/java/org/apache/doris/mtmv/metadata/ChangeMTMVJob.java create mode 100644 fe/fe-core/src/main/java/org/apache/doris/mtmv/metadata/DropMTMVJob.java create mode 100644 fe/fe-core/src/main/java/org/apache/doris/mtmv/metadata/DropMTMVTask.java create mode 100644 fe/fe-core/src/main/java/org/apache/doris/mtmv/metadata/MTMVCheckpointData.java create mode 100644 fe/fe-core/src/main/java/org/apache/doris/mtmv/metadata/MTMVJob.java create mode 100644 fe/fe-core/src/main/java/org/apache/doris/mtmv/metadata/MTMVTask.java delete mode 100644 fe/fe-core/src/main/java/org/apache/doris/mysql/MysqlServer.java create mode 100644 fe/fe-core/src/main/java/org/apache/doris/nereids/rules/exploration/join/JoinReorderRule.java create mode 100644 fe/fe-core/src/main/java/org/apache/doris/nereids/rules/exploration/join/hypergraph/Edge.java create mode 100644 fe/fe-core/src/main/java/org/apache/doris/nereids/rules/exploration/join/hypergraph/HyperGraph.java create mode 100644 fe/fe-core/src/main/java/org/apache/doris/nereids/rules/exploration/join/hypergraph/Node.java create mode 100644 fe/fe-core/src/main/java/org/apache/doris/nereids/rules/exploration/join/hypergraph/Receiver.java create mode 100644 fe/fe-core/src/test/java/org/apache/doris/mtmv/MTMVJobManagerTest.java create mode 100644 fe/fe-core/src/test/java/org/apache/doris/mtmv/MTMVTaskExecutorTest.java create mode 100644 fe/fe-core/src/test/java/org/apache/doris/mtmv/MTMVUtilsTest.java copy regression-test/suites/query_p0/sql_functions/string_functions/test_reverse.groovy => fe/fe-core/src/test/java/org/apache/doris/nereids/rules/exploration/join/JoinReorderTest.java (83%) create mode 100644 fe/fe-core/src/test/java/org/apache/doris/nereids/rules/exploration/join/hypergraph/HyperGraphTest.java create mode 100644 regression-test/data/correctness_p0/test_mask_function.out copy regression-test/data/{tpch_sf1_p1/tpch_sf1/sql/q19.out => correctness_p0/test_outer_join_with_null_value.out} (73%) create mode 100644 regression-test/data/datev2/tpch_sf1_p1/tpch_sf1/sql/q01.out copy regression-test/data/{ => datev2}/tpch_sf1_p1/tpch_sf1/sql/q02.out (87%) create mode 100644 regression-test/data/datev2/tpch_sf1_p1/tpch_sf1/sql/q03.out copy regression-test/data/datev2/tpch_sf1_p1/{ => tpch_sf1}/sql/q04.out (100%) create mode 100644 regression-test/data/datev2/tpch_sf1_p1/tpch_sf1/sql/q05.out copy regression-test/data/{ => datev2}/tpch_sf1_p1/tpch_sf1/sql/q06.out (84%) create mode 100644 regression-test/data/datev2/tpch_sf1_p1/tpch_sf1/sql/q07.out copy regression-test/data/{ => datev2}/tpch_sf1_p1/tpch_sf1/sql/q08.out (87%) create mode 100644 regression-test/data/datev2/tpch_sf1_p1/tpch_sf1/sql/q09.out create mode 100644 regression-test/data/datev2/tpch_sf1_p1/tpch_sf1/sql/q10.out create mode 100644 regression-test/data/datev2/tpch_sf1_p1/tpch_sf1/sql/q11.out copy regression-test/data/datev2/tpch_sf1_p1/{ => tpch_sf1}/sql/q12.out (100%) copy regression-test/data/datev2/tpch_sf1_p1/{ => tpch_sf1}/sql/q13.out (100%) copy regression-test/data/datev2/tpch_sf1_p1/{ => tpch_sf1}/sql/q14.out (100%) copy regression-test/data/{ => datev2}/tpch_sf1_p1/tpch_sf1/sql/q15.out (93%) copy regression-test/data/datev2/tpch_sf1_p1/{ => tpch_sf1}/sql/q16.out (100%) copy regression-test/data/datev2/tpch_sf1_p1/{ => tpch_sf1}/sql/q17.out (100%) create mode 100644 regression-test/data/datev2/tpch_sf1_p1/tpch_sf1/sql/q18.out copy regression-test/data/{ => datev2}/tpch_sf1_p1/tpch_sf1/sql/q19.out (85%) copy regression-test/data/datev2/tpch_sf1_p1/{ => tpch_sf1}/sql/q20.out (100%) copy regression-test/data/datev2/tpch_sf1_p1/{ => tpch_sf1}/sql/q21.out (100%) create mode 100644 regression-test/data/datev2/tpch_sf1_p1/tpch_sf1/sql/q22.out create mode 100644 regression-test/data/delete_p0/test_delete_from_partition.out create mode 100644 regression-test/data/load_p0/stream_load/nest_json_array.json create mode 100644 regression-test/data/load_p0/stream_load/simple_json2.json create mode 100644 regression-test/data/load_p0/stream_load/simple_json2_lack_one_column.json create mode 100644 regression-test/data/load_p0/stream_load/test_hdfs_json_load.out copy regression-test/data/{load_p0/stream_load/load_json_null_to_nullable.out => query_p0/sql_functions/array_functions/test_issue_13606.out} (79%) create mode 100644 regression-test/suites/correctness/test_mv_alias_table_name.groovy create mode 100644 regression-test/suites/correctness/test_table_alias.groovy create mode 100644 regression-test/suites/correctness_p0/test_mask_function.groovy create mode 100644 regression-test/suites/correctness_p0/test_outer_join_with_null_value.groovy copy regression-test/suites/{ => datev2}/tpch_sf1_p1/tpch_sf1/ddl/create_table.sql (100%) copy regression-test/suites/{ => datev2}/tpch_sf1_p1/tpch_sf1/ddl/customer.sql (100%) copy regression-test/suites/datev2/tpch_sf1_p1/{ => tpch_sf1}/ddl/customer_delete.sql (100%) copy regression-test/suites/{ => datev2}/tpch_sf1_p1/tpch_sf1/ddl/lineitem.sql (100%) copy regression-test/suites/datev2/tpch_sf1_p1/{ => tpch_sf1}/ddl/lineitem_delete.sql (100%) copy regression-test/suites/{ => datev2}/tpch_sf1_p1/tpch_sf1/ddl/nation.sql (100%) copy regression-test/suites/datev2/tpch_sf1_p1/{ => tpch_sf1}/ddl/nation_delete.sql (100%) copy regression-test/suites/{ => datev2}/tpch_sf1_p1/tpch_sf1/ddl/orders.sql (100%) copy regression-test/suites/datev2/tpch_sf1_p1/{ => tpch_sf1}/ddl/orders_delete.sql (100%) copy regression-test/suites/{ => datev2}/tpch_sf1_p1/tpch_sf1/ddl/part.sql (100%) copy regression-test/suites/datev2/tpch_sf1_p1/{ => tpch_sf1}/ddl/part_delete.sql (100%) copy regression-test/suites/{ => datev2}/tpch_sf1_p1/tpch_sf1/ddl/partsupp.sql (100%) copy regression-test/suites/datev2/tpch_sf1_p1/{ => tpch_sf1}/ddl/partsupp_delete.sql (100%) copy regression-test/suites/{ => datev2}/tpch_sf1_p1/tpch_sf1/ddl/region.sql (100%) copy regression-test/suites/datev2/tpch_sf1_p1/{ => tpch_sf1}/ddl/region_delete.sql (100%) copy regression-test/suites/{tpch_sf1_p1 => datev2/tpch_sf1_p1/tpch_sf1}/ddl/revenue1.sql (100%) copy regression-test/suites/datev2/tpch_sf1_p1/{ => tpch_sf1}/ddl/revenue1_delete.sql (100%) copy regression-test/suites/{ => datev2}/tpch_sf1_p1/tpch_sf1/ddl/supplier.sql (100%) copy regression-test/suites/datev2/tpch_sf1_p1/{ => tpch_sf1}/ddl/supplier_delete.sql (100%) copy regression-test/suites/{ => datev2}/tpch_sf1_p1/tpch_sf1/load.groovy (100%) copy regression-test/suites/{tpch_sf100_p2 => datev2/tpch_sf1_p1/tpch_sf1}/sql/q01.sql (100%) copy regression-test/suites/datev2/tpch_sf1_p1/{ => tpch_sf1}/sql/q02.sql (100%) copy regression-test/suites/{tpch_sf100_p2 => datev2/tpch_sf1_p1/tpch_sf1}/sql/q03.sql (100%) copy regression-test/suites/{tpch_sf100_p2 => datev2/tpch_sf1_p1/tpch_sf1}/sql/q04.sql (100%) copy regression-test/suites/{tpch_sf100_p2 => datev2/tpch_sf1_p1/tpch_sf1}/sql/q05.sql (100%) copy regression-test/suites/{tpch_sf100_p2 => datev2/tpch_sf1_p1/tpch_sf1}/sql/q06.sql (100%) copy regression-test/suites/{tpch_sf100_p2 => datev2/tpch_sf1_p1/tpch_sf1}/sql/q07.sql (100%) copy regression-test/suites/{tpch_sf100_p2 => datev2/tpch_sf1_p1/tpch_sf1}/sql/q08.sql (100%) copy regression-test/suites/datev2/tpch_sf1_p1/{ => tpch_sf1}/sql/q09.sql (100%) copy regression-test/suites/{tpch_sf100_p2 => datev2/tpch_sf1_p1/tpch_sf1}/sql/q10.sql (100%) copy regression-test/suites/datev2/tpch_sf1_p1/{ => tpch_sf1}/sql/q11.sql (100%) copy regression-test/suites/{tpch_sf100_p2 => datev2/tpch_sf1_p1/tpch_sf1}/sql/q12.sql (100%) copy regression-test/suites/datev2/tpch_sf1_p1/{ => tpch_sf1}/sql/q13.sql (100%) copy regression-test/suites/{tpch_sf100_p2 => datev2/tpch_sf1_p1/tpch_sf1}/sql/q14.sql (100%) copy regression-test/suites/datev2/tpch_sf1_p1/{ => tpch_sf1}/sql/q15.sql (100%) copy regression-test/suites/datev2/tpch_sf1_p1/{ => tpch_sf1}/sql/q16.sql (100%) copy regression-test/suites/datev2/tpch_sf1_p1/{ => tpch_sf1}/sql/q17.sql (100%) copy regression-test/suites/datev2/tpch_sf1_p1/{ => tpch_sf1}/sql/q18.sql (100%) copy regression-test/suites/datev2/tpch_sf1_p1/{ => tpch_sf1}/sql/q19.sql (100%) copy regression-test/suites/{tpch_sf100_p2 => datev2/tpch_sf1_p1/tpch_sf1}/sql/q20.sql (100%) copy regression-test/suites/datev2/tpch_sf1_p1/{ => tpch_sf1}/sql/q21.sql (100%) copy regression-test/suites/datev2/tpch_sf1_p1/{ => tpch_sf1}/sql/q22.sql (100%) create mode 100644 regression-test/suites/delete_p0/test_delete_from_partition.groovy create mode 100644 regression-test/suites/load_p0/stream_load/test_hdfs_json_load.groovy create mode 100644 regression-test/suites/query_p0/sql_functions/array_functions/test_issue_13606.groovy --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org For additional commands, e-mail: commits-h...@doris.apache.org