This is an automated email from the ASF dual-hosted git repository. dataroaring pushed a change to branch branch-3.0 in repository https://gitbox.apache.org/repos/asf/doris.git
from 3df52cbf761 [improvement](segmentcache) limit segment cache by memory or segment num (#37026) new ee164dcb865 [Fix](autoinc) Hanlde the processing of auto_increment column on exchange node rather than on TabletWriter when using `TABLET_SINK_SHUFFLE_PARTITIONED` (#36836) new 8be0ce48007 [streamload](2pc) Fix 2pc stream load txn in cloud mode (#37033) new d85a6963e15 [enhance](recycler) Refactor Accessor for Recycler (#36590) new ae38c5ed995 [Refactor](Recycler) Refactor azure obj client's batch delete function to check the delete response (#37037) new 1ed52cdeb8c [Exec](agg) Fix agg limit result error (#37025) new 29cb612a4d6 [refactor](spill) unify the entry point of spill tasks (#37020) new f0c10fa57a8 [chore](Regression) Remove useless get provider code in regression framework (#37000) new 145afabedc8 [regression-test](connector) Add a case for the response of streamload that the connector depends (#36864) new caac4b7cdb7 [fix](local shuffle) Fix wrong partitioned expr in local exchanger (#37017) new ec1422aa9a0 [fix](ES Catalog)Add array types support in esquery function (#36936) new 51bf9ab1328 [regression-test](case) modify statistics table name (#36689) new 6248c68f3cf [feature](function) support ip functions named ipv4_to_ipv6 and cut_ipv6 (#36883) new fe21f742813 [opt](hive) save hive table schema in transaction (#37008) new 9d61bebee69 [opt](function)avoid virtual function calls in geo functions (#37003) new d29764be14c [fix](cloud) Allow access to MS during the replay (#37053) new 0c7dbe46a6d [fix](cloud) Update mtime only if partitions have updated time (#37055) new 82095706765 [feat](Nereids) Optimize query by pushing down aggregation through join on foreign key (#36035) new 19774867822 [Migrate-Test](multi-catalog) Migrate p2 tests from p2 to p0. (#36989) new 5c5261fc531 [opt](arena) lazy memory allocation in arena (#36498) new cefa74dd893 [improvement](jdbc catalog)Rename config from `disable_jdbc_sqlserver_encrypt` to `force_sqlserver_jdbc_encrypt_false` (#37015) new c97839a240f [Fix](regression) Fix p0 case `test_unique_table_auto_inc_concurrent` (#37048) new 4bd260a7dc2 [test](migrate) move 2 cases from p2 to p0 (#37004) new 97f2da58331 [opt](catalog) add some profile for parquet reader and change meta cache config (#37040) new ffbfe6b1138 [fix](Nereids) simplify window expression should inherit data type (#37061) new ee516656cf4 [profile](fe)update format of min/hour/sec unit in profile (#37010) new 9cd6667e19b [fix](nereids) ColStatsMeta.partitionUpdateRows npe (#37044) new fc78d1fd288 [feat](nereids) support explain delete from clause (#36782) new a4001b3a92c [fix](map)fix upgrade behavior from 1.2 version (#36937) new f5eb1db5b86 [feature](nereids)use mtmv to match legacy mv (#33699) new 9126492697c [improve](json)improve json support empty keys (#36762) new f5de3d59e06 [fix](stmt) fix show create table consistency (#37074) new 5f262d610a3 [fix](auth)fix mtmv name to resolve conflicts (#36958) new cabad36926b [fix](mtmv)Fix mtmv name to resolve conflicts in regression test (#36902) new e1c8d50b2fd [fix](function) fix nereids fold constant wrong result of abs (#37065) new 6563f258ee9 [opt](split) add max wait time of getting splits (#36843) new 6c602c803c9 [test](tvf) move p2 tvf tests from p2 to p0 (#37081) new 538a885697c [test](migrate) move test_hive_text_complex_type from p2 to p0 (#37007) new 2f8298e23be [fix](parquet) prevent parquet page reader print much warning logs (#37011) new e5d7eea453d [fix](regression) fix txn_insert case (#36892) new a7ba1b0eef8 [fix](routine-load) fix auto resume invalid when FE leader change (#37071) new 1ef9ab1453f [fix](merge-on-write) when full clone failed, duplicate key might occur (#37001) new 2206acececb [Fix]add set thread num config for wg flush pool (#37028) new 597bfebe2de [fix](nereids) fix This stopwatch is already running (#37095) new 9e4ca47e171 [fix](recycler) Fix DCHECK in ObjectListIterator (#37112) The 44 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/cloud/cloud_meta_mgr.cpp | 6 +- be/src/cloud/cloud_stream_load_executor.cpp | 69 +- be/src/common/config.cpp | 10 +- be/src/common/config.h | 6 + be/src/olap/delta_writer_v2.cpp | 2 +- be/src/olap/rowset/segment_v2/column_reader.cpp | 1 + be/src/olap/rowset/segment_v2/column_writer.cpp | 7 +- be/src/olap/snapshot_manager.cpp | 9 + be/src/olap/storage_engine.cpp | 3 +- be/src/olap/storage_engine.h | 4 + be/src/olap/tablet.cpp | 8 + be/src/olap/tablet_schema.cpp | 6 +- be/src/olap/task/engine_clone_task.cpp | 2 +- be/src/pipeline/dependency.cpp | 10 +- be/src/pipeline/dependency.h | 3 +- be/src/pipeline/exec/aggregation_sink_operator.cpp | 4 +- .../pipeline/exec/aggregation_source_operator.cpp | 8 +- be/src/pipeline/exec/exchange_sink_operator.cpp | 5 +- be/src/pipeline/exec/file_scan_operator.cpp | 3 +- be/src/pipeline/exec/hashjoin_build_sink.h | 4 +- be/src/pipeline/exec/hashjoin_probe_operator.h | 4 +- .../exec/partitioned_aggregation_sink_operator.cpp | 30 +- .../partitioned_aggregation_source_operator.cpp | 29 +- .../exec/partitioned_aggregation_source_operator.h | 1 - .../exec/partitioned_hash_join_probe_operator.cpp | 76 +- .../exec/partitioned_hash_join_probe_operator.h | 4 +- .../exec/partitioned_hash_join_sink_operator.cpp | 112 +- .../exec/partitioned_hash_join_sink_operator.h | 3 +- be/src/pipeline/exec/spill_sort_sink_operator.cpp | 30 +- .../pipeline/exec/spill_sort_source_operator.cpp | 27 +- be/src/pipeline/exec/spill_sort_source_operator.h | 1 - be/src/pipeline/exec/spill_utils.h | 76 + be/src/runtime/query_context.cpp | 6 +- be/src/runtime/query_context.h | 4 +- .../runtime/stream_load/stream_load_executor.cpp | 42 +- be/src/runtime/workload_group/workload_group.cpp | 53 +- be/src/runtime/workload_group/workload_group.h | 4 +- be/src/util/jsonb_document.h | 1 + be/src/util/jsonb_utils.h | 7 +- be/src/util/jsonb_writer.h | 15 +- be/src/util/thrift_util.h | 2 +- be/src/vec/common/arena.h | 59 +- be/src/vec/exec/format/parquet/vparquet_reader.cpp | 23 +- be/src/vec/exec/format/parquet/vparquet_reader.h | 4 + be/src/vec/exec/scan/split_source_connector.cpp | 2 +- be/src/vec/exec/scan/split_source_connector.h | 15 +- be/src/vec/exec/scan/vfile_scanner.cpp | 2 - be/src/vec/exec/scan/vfile_scanner.h | 1 - be/src/vec/functions/function_ip.cpp | 6 + be/src/vec/functions/function_ip.h | 137 ++ be/src/vec/functions/functions_geo.cpp | 285 ++-- be/src/vec/functions/functions_geo.h | 5 +- be/src/vec/sink/vtablet_block_convertor.cpp | 5 +- be/src/vec/sink/writer/async_result_writer.cpp | 27 +- be/src/vec/sink/writer/vtablet_writer.cpp | 2 + be/src/vec/sink/writer/vtablet_writer_v2.cpp | 2 + be/test/vec/function/function_ip_test.cpp | 75 + be/test/vec/function/function_test_util.cpp | 16 + be/test/vec/function/function_test_util.h | 3 + cloud/CMakeLists.txt | 2 +- cloud/src/common/config.h | 17 +- cloud/src/common/string_util.h | 16 +- cloud/src/meta-service/meta_service_resource.cpp | 33 +- cloud/src/recycler/azure_obj_client.cpp | 321 ++--- cloud/src/recycler/azure_obj_client.h | 46 +- cloud/src/recycler/checker.cpp | 239 ++-- cloud/src/recycler/checker.h | 6 +- cloud/src/recycler/hdfs_accessor.cpp | 334 +++-- cloud/src/recycler/hdfs_accessor.h | 48 +- cloud/src/recycler/obj_storage_client.cpp | 60 + cloud/src/recycler/obj_storage_client.h | 97 ++ cloud/src/recycler/obj_store_accessor.h | 138 -- cloud/src/recycler/recycler.cpp | 176 +-- cloud/src/recycler/recycler.h | 9 +- cloud/src/recycler/recycler_service.cpp | 1 + cloud/src/recycler/s3_accessor.cpp | 341 +++-- cloud/src/recycler/s3_accessor.h | 76 +- cloud/src/recycler/s3_obj_client.cpp | 448 +++--- cloud/src/recycler/s3_obj_client.h | 43 +- cloud/src/recycler/storage_vault_accessor.h | 104 ++ cloud/test/CMakeLists.txt | 2 +- cloud/test/hdfs_accessor_test.cpp | 190 ++- cloud/test/meta_service_test.cpp | 2 +- cloud/test/mock_accessor.cpp | 186 +++ cloud/test/mock_accessor.h | 134 +- cloud/test/recycler_test.cpp | 222 ++- .../s3_accessor_mock_test.cpp} | 42 +- cloud/test/s3_accessor_test.cpp | 1133 ++++----------- cloud/test/s3_rate_limiter_test.cpp | 1 + .../docker-compose/hive/hive-2x.yaml.tpl | 2 +- .../docker-compose/hive/hive-3x.yaml.tpl | 2 +- .../hive/scripts/create_preinstalled_table.hql | 108 -- .../data/default/account_fund/create_table.hql | 28 + .../scripts/data/default/account_fund/data.tar.gz | Bin 0 -> 234 bytes .../hive/scripts/data/default/account_fund/run.sh | 12 + .../scripts/data/default/hive01/create_table.hql | 22 + .../hive/scripts/data/default/hive01/data.tar.gz | Bin 0 -> 186 bytes .../hive/scripts/data/default/hive01/run.sh | 12 + .../data/default/sale_table/create_table.hql | 24 + .../scripts/data/default/sale_table/data.tar.gz | Bin 0 -> 221 bytes .../hive/scripts/data/default/sale_table/run.sh | 12 + .../data/default/string_table/create_table.hql | 27 + .../scripts/data/default/string_table/data.tar.gz | Bin 0 -> 260 bytes .../hive/scripts/data/default/string_table/run.sh | 12 + .../scripts/data/default/student/create_table.hql | 24 + .../hive/scripts/data/default/student/data.tar.gz | Bin 0 -> 210 bytes .../hive/scripts/data/default/student/run.sh | 12 + .../scripts/data/default/test1/create_table.hql | 23 + .../hive/scripts/data/default/test1/data.tar.gz | Bin 0 -> 211 bytes .../hive/scripts/data/default/test1/run.sh | 12 + .../scripts/data/default/test2/create_table.hql | 23 + .../hive/scripts/data/default/test2/data.tar.gz | Bin 0 -> 197 bytes .../hive/scripts/data/default/test2/run.sh | 12 + .../data/default/test_hive_doris/create_table.hql | 20 + .../data/default/test_hive_doris/data.tar.gz | Bin 0 -> 181 bytes .../scripts/data/default/test_hive_doris/run.sh | 12 + .../hive_text_complex_type/create_table.hql | 27 + .../hive_text_complex_type/data.tar.gz | Bin 0 -> 560 bytes .../multi_catalog/hive_text_complex_type/run.sh | 12 + .../hive_text_complex_type2/create_table.hql | 21 + .../hive_text_complex_type2/data.tar.gz | Bin 0 -> 366 bytes .../multi_catalog/hive_text_complex_type2/run.sh | 12 + .../hive_text_complex_type3/create_table.hql | 24 + .../hive_text_complex_type3/data.tar.gz | Bin 0 -> 977 bytes .../multi_catalog/hive_text_complex_type3/run.sh | 12 + .../create_table.hql | 33 + .../hive_text_complex_type_delimiter/data.tar.gz | Bin 0 -> 568 bytes .../hive_text_complex_type_delimiter/run.sh | 12 + .../create_table.hql | 27 + .../hive_text_complex_type_delimiter2/data.tar.gz | Bin 0 -> 376 bytes .../hive_text_complex_type_delimiter2/run.sh | 12 + .../create_table.hql | 26 + .../hive_text_complex_type_delimiter3/data.tar.gz | Bin 0 -> 978 bytes .../hive_text_complex_type_delimiter3/run.sh | 12 + .../hive_textfile_array_all_types/create_table.hql | 27 + .../hive_textfile_array_all_types/data.tar.gz | Bin 0 -> 625 bytes .../run.sh | 0 .../hive_textfile_array_delimiter/create_table.hql | 32 + .../hive_textfile_array_delimiter/data.tar.gz | Bin 0 -> 690 bytes .../run.sh | 0 .../hive_textfile_nestedarray/create_table.hql | 16 + .../hive_textfile_nestedarray/data.tar.gz | Bin 0 -> 280 bytes .../run.sh | 0 .../multi_catalog/logs1_parquet/create_table.hql | 39 + .../data/multi_catalog/logs1_parquet/run.sh | 22 + .../multi_catalog/one_partition/create_table.hql | 22 + .../data/multi_catalog/one_partition/data.tar.gz | Bin 0 -> 296 bytes .../{datev2_csv => one_partition}/run.sh | 0 .../par_fields_in_file_orc/create_table.hql | 21 + .../par_fields_in_file_orc/data.tar.gz | Bin 0 -> 751 bytes .../multi_catalog/par_fields_in_file_orc/run.sh | 12 + .../par_fields_in_file_parquet/create_table.hql | 21 + .../par_fields_in_file_parquet/data.tar.gz | Bin 0 -> 548 bytes .../par_fields_in_file_parquet/run.sh | 12 + .../parquet_predicate_table/create_table.hql | 18 + .../parquet_predicate_table/data.tar.gz | Bin 0 -> 828 bytes .../multi_catalog/parquet_predicate_table/run.sh | 12 + .../partition_location_1/create_table.hql | 22 + .../multi_catalog/partition_location_1/data.tar.gz | Bin 0 -> 583 bytes .../data/multi_catalog/partition_location_1/run.sh | 12 + .../partition_location_2/create_table.hql | 23 + .../multi_catalog/partition_location_2/data.tar.gz | Bin 0 -> 600 bytes .../data/multi_catalog/partition_location_2/run.sh | 12 + .../test_csv_format_error/create_table.hql | 68 + .../test_csv_format_error/data.tar.gz | Bin 0 -> 151583 bytes .../{datev2_csv => test_csv_format_error}/run.sh | 0 .../test_date_string_partition/create_table.hql | 25 + .../test_date_string_partition/data.tar.gz | Bin 0 -> 353 bytes .../run.sh | 0 .../timestamp_with_time_zone/create_table.hql | 17 + .../timestamp_with_time_zone/data.tar.gz | Bin 0 -> 1499 bytes .../multi_catalog/timestamp_with_time_zone/run.sh | 12 + .../multi_catalog/two_partition/create_table.hql | 25 + .../data/multi_catalog/two_partition/data.tar.gz | Bin 0 -> 375 bytes .../{datev2_csv => two_partition}/run.sh | 0 .../data/statistics/statistics/create_table.hql | 33 + .../scripts/data/statistics/statistics/data.tar.gz | Bin 0 -> 3956 bytes .../hive/scripts/data/statistics/statistics/run.sh | 13 + .../scripts/data/test/hive_test/create_table.hql | 20 + .../hive/scripts/data/test/hive_test/data.tar.gz | Bin 0 -> 161 bytes .../hive/scripts/data/test/hive_test/run.sh | 12 + .../data/tpch_1000_parquet/part/create_table.hql | 24 + .../scripts/data/tpch_1000_parquet/part/run.sh | 22 + .../main/java/org/apache/doris/common/Config.java | 19 +- .../apache/doris/alter/CloudSchemaChangeJobV2.java | 4 - .../main/java/org/apache/doris/analysis/Expr.java | 2 +- .../java/org/apache/doris/analysis/SlotRef.java | 2 +- .../apache/doris/catalog/AggregateFunction.java | 3 +- .../doris/catalog/BuiltinScalarFunctions.java | 16 +- .../java/org/apache/doris/catalog/FunctionSet.java | 4 + .../org/apache/doris/catalog/JdbcResource.java | 2 +- .../apache/doris/cloud/catalog/CloudPartition.java | 4 +- .../apache/doris/cloud/rpc/MetaServiceProxy.java | 6 - .../org/apache/doris/common/util/DebugUtil.java | 6 +- .../apache/doris/datasource/FileQueryScanNode.java | 3 +- .../org/apache/doris/datasource/SplitSource.java | 18 +- .../doris/datasource/hive/HMSTransaction.java | 15 +- .../doris/datasource/hive/HiveMetaStoreCache.java | 6 +- .../doris/load/routineload/RoutineLoadJob.java | 5 + .../org/apache/doris/nereids/NereidsPlanner.java | 10 +- .../doris/nereids/analyzer/UnboundFunction.java | 48 +- .../doris/nereids/jobs/executor/Rewriter.java | 6 +- .../doris/nereids/parser/LogicalPlanBuilder.java | 16 +- .../parser/LogicalPlanBuilderForSyncMv.java | 194 +++ .../apache/doris/nereids/parser/NereidsParser.java | 7 + .../apache/doris/nereids/properties/FuncDeps.java | 19 + .../org/apache/doris/nereids/rules/RuleSet.java | 2 + .../org/apache/doris/nereids/rules/RuleType.java | 3 +- .../mv/AbstractMaterializedViewAggregateRule.java | 3 +- .../mv/AbstractMaterializedViewRule.java | 22 + .../mv/InitMaterializationContextHook.java | 160 +++ .../mv/MaterializedViewOnlyScanRule.java | 42 +- .../exploration/mv/MaterializedViewUtils.java | 67 + .../exploration/mv/SyncMaterializationContext.java | 117 ++ .../exploration/mv/rollup/DirectRollupHandler.java | 8 +- .../rewrite/PushDownAggThroughJoinOnPkFk.java | 348 +++++ .../rules/rewrite/SimplifyWindowExpression.java | 4 +- .../mv/SelectMaterializedIndexWithAggregate.java | 30 + .../SelectMaterializedIndexWithoutAggregate.java | 15 + .../doris/nereids/stats/StatsCalculator.java | 4 +- .../functions/agg/MultiDistinctCount.java | 10 +- .../functions/agg/NullableAggregateFunction.java | 14 + .../functions/executable/ExecutableFunctions.java | 8 +- .../scalar/{EsQuery.java => CutIpv6.java} | 36 +- .../expressions/functions/scalar/EsQuery.java | 4 +- .../scalar/{EsQuery.java => Ipv4ToIpv6.java} | 36 +- .../expressions/visitor/ScalarFunctionVisitor.java | 58 +- .../trees/plans/commands/DeleteFromCommand.java | 92 +- .../plans/commands/DeleteFromUsingCommand.java | 88 +- .../trees/plans/commands/info/AlterViewInfo.java | 5 +- .../trees/plans/commands/info/BaseViewInfo.java | 40 - .../trees/plans/commands/info/CreateViewInfo.java | 5 +- .../apache/doris/nereids/types/AggStateType.java | 23 +- .../org/apache/doris/nereids/util/PlanUtils.java | 40 + .../java/org/apache/doris/qe/SessionVariable.java | 33 + .../apache/doris/service/FrontendServiceImpl.java | 2 +- .../apache/doris/common/util/DebugUtilTest.java | 8 +- .../rewrite/PushDownAggThroughJoinOnPkFkTest.java | 158 +++ .../rules/rewrite/mv/SelectMvIndexTest.java | 1 + .../rules/rewrite/mv/SelectRollupIndexTest.java | 1 + .../functions/ExecutableFunctionsTest.java | 64 + .../planner/MaterializedViewFunctionTest.java | 1 + gensrc/script/doris_builtins_functions.py | 4 +- .../unique/test_unique_auto_inc_concurrent.out | 3 - .../unique/test_unique_table_auto_inc.out | 62 + .../data/external_table_p0/es/test_es_query.out | 42 +- .../hive/test_external_catalog_hive.out | 139 +- .../hive/test_hive_default_partition.out | 174 +++ .../hive/test_hive_partition_location.out | 40 + .../hive/test_hive_text_complex_type.out | 65 + .../hive/test_hive_to_array.out | 21 + .../hive/test_text_garbled_file.out | Bin 296830 -> 593565 bytes .../data/external_table_p0/tvf/test_tvf_view.out | 28 + .../external_table_p2/tvf/test_tvf_view_p2.out | 28 - .../data/flink_connector_p0/test_response.csv | 2 + regression-test/data/insert_p0/txn_insert.out | 2 - .../data/json_p0/test_json_load_and_function.out | 1262 ++++++++++++++++ .../data/jsonb_p0/test_jsonb_load_and_function.out | 896 ++++++++++++ .../mv_p0/agg_have_dup_base/agg_have_dup_base.out | 7 +- regression-test/data/mv_p0/k1s2m3/k1s2m3.out | 12 +- .../multi_slot_k1p2ap3ps/multi_slot_k1p2ap3ps.out | 3 +- .../multi_slot_multi_mv/multi_slot_multi_mv.out | 4 +- .../mv_ignore_predicate/mv_ignore_predicate.out | 5 +- .../mv_p0/test_upper_alias/test_upper_alias.out | 1 + .../json_p0/test_json_load_and_function.out | 656 +++++++++ .../jsonb_p0/test_jsonb_load_and_function.out | 863 +++++++++++ .../single_table_without_aggregate.out | 116 ++ .../simplify_window_expression.out | 8 + .../data/nereids_syntax_p0/mv/agg_mv_test.dat | 26 + .../nereids_syntax_p0/mv/aggregate/agg_sync_mv.out | 1501 ++++++++++++++++++++ .../nereids_syntax_p0/mv/newMv/aggHaveDupBase.out | 7 +- .../nereids_syntax_p0/mv/newMv/multi_slot4.out | 1 + .../data/nereids_syntax_p0/mv/ut/aggOnAggMV3.out | 3 +- .../data/nereids_syntax_p0/rollup/agg.out | 2 +- .../shape/query38.out | 51 +- .../shape/query87.out | 51 +- .../noStatsRfPrune/query38.out | 51 +- .../noStatsRfPrune/query87.out | 51 +- .../no_stats_shape/query38.out | 51 +- .../no_stats_shape/query87.out | 51 +- .../rf_prune/query38.out | 51 +- .../rf_prune/query87.out | 51 +- .../nereids_tpcds_shape_sf100_p0/shape/query38.out | 51 +- .../nereids_tpcds_shape_sf100_p0/shape/query87.out | 51 +- .../ip_functions/test_cut_ipv6_function.out | 19 + .../ip_functions/test_ipv4_to_ipv6_function.out | 14 + regression-test/data/rollup_p0/test_rollup_agg.out | 2 +- .../test_mow_full_clone_exception.out | 37 + .../org/apache/doris/regression/Config.groovy | 13 +- .../org/apache/doris/regression/suite/Suite.groovy | 15 - .../test_master_slave_consistency_auth.groovy | 49 +- .../suites/auth_p0/test_select_column_auth.groovy | 33 +- .../unique/test_unique_auto_inc_concurrent.groovy | 3 +- .../unique/test_unique_table_auto_inc.groovy | 38 + .../external_table_p0/es/test_es_query.groovy | 10 +- .../hive/test_external_catalog_hive.groovy | 99 +- .../hive/test_hive_default_partition.groovy | 17 +- .../hive/test_hive_partition_location.groovy | 18 +- .../hive/test_hive_statistic.groovy | 344 +++++ .../hive/test_hive_statistic_timeout.groovy | 23 +- .../hive/test_hive_text_complex_type.groovy | 15 +- .../hive/test_hive_to_array.groovy | 17 +- .../hive/test_text_garbled_file.groovy | 47 + .../tvf/test_tvf_view.groovy} | 12 +- .../tvf/test_tvf_view_count.groovy} | 10 +- .../hive/test_hive_statistic.groovy | 338 ----- .../hive/test_text_garbled_file.groovy | 46 - .../flink_connector_response.groovy | 186 +++ regression-test/suites/insert_p0/txn_insert.groovy | 2 +- .../txn_insert_concurrent_insert_duplicate.groovy | 13 +- .../txn_insert_concurrent_insert_ud.groovy | 15 +- .../txn_insert_concurrent_insert_unique.groovy | 15 +- .../txn_insert_concurrent_insert_update.groovy | 15 +- .../insert_p2/txn_insert_with_schema_change.groovy | 1 + .../json_p0/test_json_load_and_function.groovy | 11 + .../jsonb_p0/test_jsonb_load_and_function.groovy | 11 + .../load_p0/stream_load/test_stream_load.groovy | 1 + .../agg_have_dup_base/agg_have_dup_base.groovy | 22 + .../mv_p0/agg_state/test_agg_state_max_by.groovy | 26 + .../suites/mv_p0/case_ignore/case_ignore.groovy | 13 + .../suites/mv_p0/count_star/count_star.groovy | 27 +- .../suites/mv_p0/k1ap2spa/k1ap2spa.groovy | 10 + regression-test/suites/mv_p0/k1s2m3/k1s2m3.groovy | 37 + .../mv_p0/k1s2m3_auto_inc/k1s2m3_auto_inc.groovy | 9 + .../multi_agg_with_same_slot.groovy | 25 + .../mv_p0/multi_slot_k123p/multi_slot_k123p.groovy | 13 +- .../multi_slot_k1a2p2ap3p.groovy | 9 + .../multi_slot_k1a2p2ap3ps.groovy | 14 + .../multi_slot_k1p2ap3p/multi_slot_k1p2ap3p.groovy | 9 + .../multi_slot_k1p2ap3ps.groovy | 10 + .../multi_slot_multi_mv/multi_slot_multi_mv.groovy | 39 + .../mv_ignore_predicate/mv_ignore_predicate.groovy | 37 +- .../mv_p0/mv_percentile/mv_percentile.groovy | 50 +- .../suites/mv_p0/mv_with_view/mv_with_view.groovy | 45 +- .../suites/mv_p0/null_insert/null_insert.groovy | 11 + .../mv_p0/routine_load_hll/routine_load_hll.groovy | 9 + .../ssb/multiple_no_where/multiple_no_where.groovy | 62 + .../mv_p0/ssb/multiple_ssb/multiple_ssb.groovy | 66 + .../multiple_ssb_between.groovy | 56 + .../suites/mv_p0/ssb/q_1_1/q_1_1.groovy | 16 + .../suites/mv_p0/ssb/q_2_1/q_2_1.groovy | 15 + .../suites/mv_p0/ssb/q_3_1/q_3_1.groovy | 19 + .../suites/mv_p0/ssb/q_4_1/q_4_1.groovy | 18 +- .../suites/mv_p0/ssb/q_4_1_r1/q_4_1_r1.groovy | 17 + .../suites/mv_p0/sum_count/sum_count.groovy | 34 +- .../mv_p0/sum_divede_count/sum_devide_count.groovy | 24 + .../suites/mv_p0/test_28741/test_28741.groovy | 9 + .../test_approx_count_distinct.groovy | 19 + .../suites/mv_p0/test_base/test_base.groovy | 18 +- .../mv_p0/test_casewhen/test_casewhen.groovy | 9 + .../suites/mv_p0/test_doc_e4/test_doc_e4.groovy | 24 + .../test_dup_group_by_mv_abs.groovy | 14 + .../test_dup_group_by_mv_plus.groovy | 14 + .../mv_p0/test_dup_mv_abs/test_dup_mv_abs.groovy | 34 + .../mv_p0/test_dup_mv_bin/test_dup_mv_bin.groovy | 34 + .../test_dup_mv_bitmap_hash.groovy | 17 + .../test_dup_mv_expr_priority.groovy | 10 + .../mv_p0/test_dup_mv_plus/test_dup_mv_plus.groovy | 45 + .../test_dup_mv_repeat/test_dup_mv_repeat.groovy | 9 + .../mv_p0/test_dup_mv_year/test_dup_mv_year.groovy | 15 + .../test_insert_multi/test_insert_multi.groovy | 9 + .../suites/mv_p0/test_mv_dp/test_mv_dp.groovy | 11 + .../suites/mv_p0/test_mv_mow/test_mv_mow.groovy | 9 + .../suites/mv_p0/test_ndv/test_ndv.groovy | 19 + .../suites/mv_p0/test_nvl/test_nvl.groovy | 25 + .../suites/mv_p0/test_o2/test_o2.groovy | 9 + .../suites/mv_p0/test_substr/test_substr.groovy | 9 + .../mv_p0/test_tbl_name/test_tbl_name.groovy | 22 + .../mv_p0/test_upper_alias/test_upper_alias.groovy | 23 +- .../test_user_activity/test_user_activity.groovy | 9 + regression-test/suites/mv_p0/unique/unique.groovy | 9 + .../testAggQueryOnAggMV1.groovy | 39 + .../testAggQueryOnAggMV10.groovy | 14 + .../testAggQueryOnAggMV11.groovy | 14 + .../testAggQueryOnAggMV2.groovy | 12 +- .../testAggQueryOnAggMV3.groovy | 22 +- .../testAggQuqeryOnAggMV5.groovy | 16 +- .../testAggQuqeryOnAggMV6.groovy | 16 +- .../testAggQuqeryOnAggMV7.groovy | 14 + .../testAggTableCountDistinctInBitmapType.groovy | 9 + .../testAggregateMVCalcAggFunctionQuery.groovy | 13 + .../testBitmapUnionInQuery.groovy | 20 + .../testCountDistinctToBitmap.groovy | 25 + .../testIncorrectMVRewriteInSubquery.groovy | 15 + .../testIncorrectRewriteCountDistinct.groovy | 14 + .../testJoinOnLeftProjectToJoin.groovy | 10 + .../mv_p0/ut/testNDVToHll/testNDVToHll.groovy | 19 + .../testOrderByQueryOnProjectView.groovy | 15 +- .../ut/testProjectionMV1/testProjectionMV1.groovy | 29 +- .../ut/testProjectionMV2/testProjectionMV2.groovy | 18 + .../ut/testProjectionMV3/testProjectionMV3.groovy | 22 +- .../ut/testProjectionMV4/testProjectionMV4.groovy | 18 +- .../ut/testQueryOnStar/testQueryOnStar.groovy | 12 - .../testSelectMVWithTableAlias.groovy | 14 + .../testSingleMVMultiUsage.groovy | 13 + .../mv_p0/ut/testSubQuery/testSubQuery.groovy | 9 +- .../ut/testUnionDistinct/testUnionDistinct.groovy | 14 + .../suites/mv_p0/where/k123/k123.groovy | 39 + .../mv_p0/where/k123_nereids/k123_nereids.groovy | 81 +- .../suites/mv_p0/where/mvljc/mvljc.groovy | 14 + .../suites/nereids_p0/explain/explain_dml.groovy | 122 ++ .../json_p0/test_json_load_and_function.groovy | 11 + .../jsonb_p0/test_jsonb_load_and_function.groovy | 11 + .../suites/nereids_p0/test_mv_select.groovy | 21 - .../test_grouping_sets_combination.groovy | 9 +- .../aggregate_without_roll_up.groovy | 2 +- .../dimension_join_agg_negative.groovy | 2 +- .../mv/negative/negative_test.groovy | 2 +- .../single_table_without_aggregate.groovy | 326 +++++ .../simplify_window_expression.groovy | 7 +- .../suites/nereids_syntax_p0/advance_mv.groovy | 28 + .../mv/aggregate/agg_sync_mv.groovy | 516 +++++++ .../suites/nereids_syntax_p0/mv/load.groovy | 129 ++ .../mv/newMv/aggHaveDupBase.groovy | 26 + .../nereids_syntax_p0/mv/newMv/case_ignore.groovy | 14 + .../mv/newMv/dup_gb_mv_abs.groovy | 14 + .../mv/newMv/dup_gb_mv_plus.groovy | 14 + .../nereids_syntax_p0/mv/newMv/dup_mv_abs.groovy | 34 + .../nereids_syntax_p0/mv/newMv/dup_mv_bin.groovy | 34 + .../mv/newMv/dup_mv_bm_hash.groovy | 15 + .../nereids_syntax_p0/mv/newMv/dup_mv_plus.groovy | 35 + .../nereids_syntax_p0/mv/newMv/dup_mv_year.groovy | 15 + .../nereids_syntax_p0/mv/newMv/multi_slot1.groovy | 9 + .../nereids_syntax_p0/mv/newMv/multi_slot2.groovy | 14 + .../nereids_syntax_p0/mv/newMv/multi_slot3.groovy | 9 + .../nereids_syntax_p0/mv/newMv/multi_slot4.groovy | 10 + .../nereids_syntax_p0/mv/newMv/multi_slot5.groovy | 14 +- .../nereids_syntax_p0/mv/newMv/multi_slot6.groovy | 8 + .../nereids_syntax_p0/mv/newMv/mv_with_view.groovy | 68 +- .../nereids_syntax_p0/mv/newMv/rollback1.groovy | 3 + .../nereids_syntax_p0/mv/newMv/single_slot.groovy | 9 + .../mv/newMv/sum_devide_count.groovy | 25 + .../nereids_syntax_p0/mv/newMv/unique_mv.groovy | 9 + .../nereids_syntax_p0/mv/ut/MVMultiUsage.groovy | 14 + .../suites/nereids_syntax_p0/mv/ut/MVWithAs.groovy | 13 + .../nereids_syntax_p0/mv/ut/aggCDInBitmap.groovy | 9 + .../nereids_syntax_p0/mv/ut/aggMVCalcAggFun.groovy | 13 + .../nereids_syntax_p0/mv/ut/aggOnAggMV1.groovy | 12 + .../nereids_syntax_p0/mv/ut/aggOnAggMV10.groovy | 14 + .../nereids_syntax_p0/mv/ut/aggOnAggMV11.groovy | 14 + .../nereids_syntax_p0/mv/ut/aggOnAggMV2.groovy | 11 + .../nereids_syntax_p0/mv/ut/aggOnAggMV3.groovy | 15 + .../nereids_syntax_p0/mv/ut/aggOnAggMV5.groovy | 14 + .../nereids_syntax_p0/mv/ut/aggOnAggMV6.groovy | 14 + .../nereids_syntax_p0/mv/ut/aggOnAggMV7.groovy | 14 + .../nereids_syntax_p0/mv/ut/bitmapUnionIn.groovy | 14 + .../ut/{projectMV3.groovy => distinctQuery.groovy} | 41 +- .../nereids_syntax_p0/mv/ut/incMVReInSub.groovy | 14 + .../nereids_syntax_p0/mv/ut/incRewriteCD.groovy | 14 + ...nLeftPToJoin.groovy => joinOnCalcToJoin.groovy} | 40 +- .../mv/ut/joinOnLeftPToJoin.groovy | 11 + .../suites/nereids_syntax_p0/mv/ut/onStar.groovy | 16 +- .../ut/{projectMV1.groovy => onlyGroupBy.groovy} | 30 +- .../nereids_syntax_p0/mv/ut/orderByOnPView.groovy | 17 +- .../nereids_syntax_p0/mv/ut/projectMV1.groovy | 18 +- .../nereids_syntax_p0/mv/ut/projectMV2.groovy | 19 + .../nereids_syntax_p0/mv/ut/projectMV3.groovy | 20 +- .../nereids_syntax_p0/mv/ut/projectMV4.groovy | 23 +- .../suites/nereids_syntax_p0/mv/ut/subQuery.groovy | 10 + .../suites/nereids_syntax_p0/mv/ut/unionDis.groovy | 15 + .../suites/nereids_syntax_p0/rollup/agg.groovy | 10 + .../nereids_syntax_p0/rollup/agg_date.groovy | 10 + .../suites/nereids_syntax_p0/rollup/date.groovy | 22 + .../suites/nereids_syntax_p0/rollup/hll/hll.groovy | 9 + .../hll_with_light_sc/hll_with_light_sc.groovy | 9 + .../suites/pipeline_p0/statitics_compaction.groovy | 4 +- .../ip_functions/test_cut_ipv6_function.groovy | 56 + .../ip_functions/test_ipv4_to_ipv6_function.groovy | 51 + .../suites/rollup_p0/test_rollup_agg.groovy | 9 + .../test_mow_full_clone_exception.groovy | 137 ++ .../suites/variant_p0/mv/multi_slot.groovy | 70 +- 471 files changed, 16800 insertions(+), 4353 deletions(-) create mode 100644 be/src/pipeline/exec/spill_utils.h create mode 100644 cloud/src/recycler/obj_storage_client.cpp create mode 100644 cloud/src/recycler/obj_storage_client.h delete mode 100644 cloud/src/recycler/obj_store_accessor.h create mode 100644 cloud/src/recycler/storage_vault_accessor.h create mode 100644 cloud/test/mock_accessor.cpp copy cloud/{src/common/string_util.h => test/s3_accessor_mock_test.cpp} (54%) create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/default/account_fund/create_table.hql create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/default/account_fund/data.tar.gz create mode 100755 docker/thirdparties/docker-compose/hive/scripts/data/default/account_fund/run.sh create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/default/hive01/create_table.hql create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/default/hive01/data.tar.gz create mode 100755 docker/thirdparties/docker-compose/hive/scripts/data/default/hive01/run.sh create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/default/sale_table/create_table.hql create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/default/sale_table/data.tar.gz create mode 100755 docker/thirdparties/docker-compose/hive/scripts/data/default/sale_table/run.sh create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/default/string_table/create_table.hql create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/default/string_table/data.tar.gz create mode 100755 docker/thirdparties/docker-compose/hive/scripts/data/default/string_table/run.sh create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/default/student/create_table.hql create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/default/student/data.tar.gz create mode 100755 docker/thirdparties/docker-compose/hive/scripts/data/default/student/run.sh create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/default/test1/create_table.hql create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/default/test1/data.tar.gz create mode 100755 docker/thirdparties/docker-compose/hive/scripts/data/default/test1/run.sh create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/default/test2/create_table.hql create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/default/test2/data.tar.gz create mode 100755 docker/thirdparties/docker-compose/hive/scripts/data/default/test2/run.sh create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/default/test_hive_doris/create_table.hql create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/default/test_hive_doris/data.tar.gz create mode 100755 docker/thirdparties/docker-compose/hive/scripts/data/default/test_hive_doris/run.sh create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/hive_text_complex_type/create_table.hql create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/hive_text_complex_type/data.tar.gz create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/hive_text_complex_type/run.sh create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/hive_text_complex_type2/create_table.hql create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/hive_text_complex_type2/data.tar.gz create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/hive_text_complex_type2/run.sh create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/hive_text_complex_type3/create_table.hql create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/hive_text_complex_type3/data.tar.gz create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/hive_text_complex_type3/run.sh create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/hive_text_complex_type_delimiter/create_table.hql create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/hive_text_complex_type_delimiter/data.tar.gz create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/hive_text_complex_type_delimiter/run.sh create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/hive_text_complex_type_delimiter2/create_table.hql create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/hive_text_complex_type_delimiter2/data.tar.gz create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/hive_text_complex_type_delimiter2/run.sh create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/hive_text_complex_type_delimiter3/create_table.hql create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/hive_text_complex_type_delimiter3/data.tar.gz create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/hive_text_complex_type_delimiter3/run.sh create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/hive_textfile_array_all_types/create_table.hql create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/hive_textfile_array_all_types/data.tar.gz copy docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/{datev2_orc => hive_textfile_array_all_types}/run.sh (100%) create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/hive_textfile_array_delimiter/create_table.hql create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/hive_textfile_array_delimiter/data.tar.gz copy docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/{datev2_orc => hive_textfile_array_delimiter}/run.sh (100%) create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/hive_textfile_nestedarray/create_table.hql create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/hive_textfile_nestedarray/data.tar.gz copy docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/{datev2_orc => hive_textfile_nestedarray}/run.sh (100%) create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/logs1_parquet/create_table.hql create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/logs1_parquet/run.sh create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/one_partition/create_table.hql create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/one_partition/data.tar.gz copy docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/{datev2_csv => one_partition}/run.sh (100%) create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/par_fields_in_file_orc/create_table.hql create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/par_fields_in_file_orc/data.tar.gz create mode 100755 docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/par_fields_in_file_orc/run.sh create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/par_fields_in_file_parquet/create_table.hql create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/par_fields_in_file_parquet/data.tar.gz create mode 100755 docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/par_fields_in_file_parquet/run.sh create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/parquet_predicate_table/create_table.hql create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/parquet_predicate_table/data.tar.gz create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/parquet_predicate_table/run.sh create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/partition_location_1/create_table.hql create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/partition_location_1/data.tar.gz create mode 100755 docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/partition_location_1/run.sh create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/partition_location_2/create_table.hql create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/partition_location_2/data.tar.gz create mode 100755 docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/partition_location_2/run.sh create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/test_csv_format_error/create_table.hql create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/test_csv_format_error/data.tar.gz copy docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/{datev2_csv => test_csv_format_error}/run.sh (100%) create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/test_date_string_partition/create_table.hql create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/test_date_string_partition/data.tar.gz copy docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/{datev2_csv => test_date_string_partition}/run.sh (100%) create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/timestamp_with_time_zone/create_table.hql create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/timestamp_with_time_zone/data.tar.gz create mode 100755 docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/timestamp_with_time_zone/run.sh create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/two_partition/create_table.hql create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/two_partition/data.tar.gz copy docker/thirdparties/docker-compose/hive/scripts/data/multi_catalog/{datev2_csv => two_partition}/run.sh (100%) create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/statistics/statistics/create_table.hql create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/statistics/statistics/data.tar.gz create mode 100755 docker/thirdparties/docker-compose/hive/scripts/data/statistics/statistics/run.sh create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/test/hive_test/create_table.hql create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/test/hive_test/data.tar.gz create mode 100755 docker/thirdparties/docker-compose/hive/scripts/data/test/hive_test/run.sh create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/tpch_1000_parquet/part/create_table.hql create mode 100644 docker/thirdparties/docker-compose/hive/scripts/data/tpch_1000_parquet/part/run.sh create mode 100644 fe/fe-core/src/main/java/org/apache/doris/nereids/parser/LogicalPlanBuilderForSyncMv.java copy cloud/src/common/string_util.h => fe/fe-core/src/main/java/org/apache/doris/nereids/rules/exploration/mv/MaterializedViewOnlyScanRule.java (51%) create mode 100644 fe/fe-core/src/main/java/org/apache/doris/nereids/rules/exploration/mv/SyncMaterializationContext.java create mode 100644 fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/PushDownAggThroughJoinOnPkFk.java copy fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/{EsQuery.java => CutIpv6.java} (63%) copy fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/{EsQuery.java => Ipv4ToIpv6.java} (64%) create mode 100644 fe/fe-core/src/test/java/org/apache/doris/nereids/rules/rewrite/PushDownAggThroughJoinOnPkFkTest.java create mode 100644 fe/fe-core/src/test/java/org/apache/doris/nereids/trees/expressions/functions/ExecutableFunctionsTest.java rename regression-test/data/{external_table_p2 => external_table_p0}/hive/test_external_catalog_hive.out (50%) rename regression-test/data/{external_table_p2 => external_table_p0}/hive/test_hive_default_partition.out (51%) rename regression-test/data/{external_table_p2 => external_table_p0}/hive/test_hive_partition_location.out (54%) rename regression-test/data/{external_table_p2 => external_table_p0}/hive/test_hive_text_complex_type.out (50%) rename regression-test/data/{external_table_p2 => external_table_p0}/hive/test_hive_to_array.out (50%) rename regression-test/data/{external_table_p2 => external_table_p0}/hive/test_text_garbled_file.out (50%) create mode 100644 regression-test/data/external_table_p0/tvf/test_tvf_view.out delete mode 100644 regression-test/data/external_table_p2/tvf/test_tvf_view_p2.out create mode 100644 regression-test/data/flink_connector_p0/test_response.csv create mode 100644 regression-test/data/nereids_rules_p0/mv/single_table_without_agg/single_table_without_aggregate.out create mode 100644 regression-test/data/nereids_syntax_p0/mv/agg_mv_test.dat create mode 100644 regression-test/data/nereids_syntax_p0/mv/aggregate/agg_sync_mv.out create mode 100644 regression-test/data/query_p0/sql_functions/ip_functions/test_cut_ipv6_function.out create mode 100644 regression-test/data/query_p0/sql_functions/ip_functions/test_ipv4_to_ipv6_function.out create mode 100644 regression-test/data/unique_with_mow_p0/test_mow_full_clone_exception.out rename regression-test/suites/{external_table_p2 => external_table_p0}/hive/test_external_catalog_hive.groovy (54%) rename regression-test/suites/{external_table_p2 => external_table_p0}/hive/test_hive_default_partition.groovy (95%) rename regression-test/suites/{external_table_p2 => external_table_p0}/hive/test_hive_partition_location.groovy (80%) create mode 100644 regression-test/suites/external_table_p0/hive/test_hive_statistic.groovy rename regression-test/suites/{external_table_p2 => external_table_p0}/hive/test_hive_statistic_timeout.groovy (76%) rename regression-test/suites/{external_table_p2 => external_table_p0}/hive/test_hive_text_complex_type.groovy (86%) rename regression-test/suites/{external_table_p2 => external_table_p0}/hive/test_hive_to_array.groovy (79%) create mode 100644 regression-test/suites/external_table_p0/hive/test_text_garbled_file.groovy rename regression-test/suites/{external_table_p2/tvf/test_tvf_view_p2.groovy => external_table_p0/tvf/test_tvf_view.groovy} (85%) rename regression-test/suites/{external_table_p2/tvf/test_tvf_view_count_p2.groovy => external_table_p0/tvf/test_tvf_view_count.groovy} (79%) delete mode 100644 regression-test/suites/external_table_p2/hive/test_hive_statistic.groovy delete mode 100644 regression-test/suites/external_table_p2/hive/test_text_garbled_file.groovy create mode 100644 regression-test/suites/flink_connector_p0/flink_connector_response.groovy create mode 100644 regression-test/suites/nereids_p0/explain/explain_dml.groovy create mode 100644 regression-test/suites/nereids_rules_p0/mv/single_table_without_agg/single_table_without_aggregate.groovy create mode 100644 regression-test/suites/nereids_syntax_p0/mv/aggregate/agg_sync_mv.groovy create mode 100644 regression-test/suites/nereids_syntax_p0/mv/load.groovy copy regression-test/suites/nereids_syntax_p0/mv/ut/{projectMV3.groovy => distinctQuery.groovy} (52%) copy regression-test/suites/nereids_syntax_p0/mv/ut/{joinOnLeftPToJoin.groovy => joinOnCalcToJoin.groovy} (56%) copy regression-test/suites/nereids_syntax_p0/mv/ut/{projectMV1.groovy => onlyGroupBy.groovy} (62%) create mode 100644 regression-test/suites/query_p0/sql_functions/ip_functions/test_cut_ipv6_function.groovy create mode 100644 regression-test/suites/query_p0/sql_functions/ip_functions/test_ipv4_to_ipv6_function.groovy create mode 100644 regression-test/suites/unique_with_mow_p0/test_mow_full_clone_exception.groovy --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org For additional commands, e-mail: commits-h...@doris.apache.org