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: [email protected]
For additional commands, e-mail: [email protected]
