This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a change to branch auto-pick-58834-branch-4.0
in repository https://gitbox.apache.org/repos/asf/doris.git
discard 8180779b16a [fix](case)fix create sync mv failed in test case (#58834)
add 468b3f6dbb5 [test](mtls)test framwork support tls (#5874) (#58368)
(#58838)
add e40beaa4000 branch-4.0: [fix](test) fix unstable export external table
#58799 (#58887)
add 1362c00c7ef branch-4.0: [fix](regr) Use Youngs-Cramer for
REGR_SLOPE/INTERCEPT to align with PG #55940 (#58920)
add 07f248b7737 branch-4.0: [fix](test) fix unstable es catalog test
#58800 (#58888)
add bf22d3d3e7b branch-4.0: [feat](load) introduce load job system table
(#57421) (#58850)
add 62a5a1545c8 branch-4.0: [fix](test) fix regression case
limit_push_down #58873 (#58933)
add da806a9543f branch-4.0: [Improvement](join) lazy calculate
all_match_one #58729 (#58901)
add 43b4b98f193 branch-4.0: [test](doris catalog)Add test cases for doris
catalog #58831 (#58934)
add ffb11fc3cca branch-4.0: [fix](jdbc) Fix JNI global reference leak in
JdbcConnector close #58574 (#58753)
add 5d30bfdb684 branch-4.0: [fix](mv) Fix sync mv could not be chosen by
cbo stable because stats upload from be not in time #58720 (#58772)
add a0726e8f275 branch-4.0: [opt](partition pruner) add
cache_sorted_partition_interval_second #58766 (#58809)
add d5fd1b68aad branch-4.0: [Refactor](cast) Make all nullable for cast
from string to simple types #57949 (#58924)
add 17c8748c310 branch-4.0: [Improvement](hash) add int96 int104 to hash
method #58770 (#58902)
add 18054665cfc branch-4.0: [chore](security) Add ssrf check for create
stage #58585 (#58875)
add 99ea4a8f9fc branch-4.0: [opt](hive) use binary search to prune hive
partitions #58877 (#58921)
add 5ac57dd85a7 branch-4.0: [Chore](profile) adjust some profile #58861
(#58956)
add 017011d464f [test](doris catalog)Add more test cases for doris catalog
(#58784) (#58831) (#58891)
add bd6dad23957 [test](variable)add up and down test case of variables
persistence (#58818)
add 0f22ae9b27c [opt](filecache) schema change adaptive to file cache
(#58620)
add c11e585e996 branch-4.0: [feat](es) support es flatten type #58762
(#58794)
add 6997c87b017 branch-4.0: [bugfix](memory_profile) should split memtable
memory from task's memory profile #58908 (#58979)
add b37b8b63eb2 branch4.0: [feature](variable) enables views, materialized
views, generated columns, and alias functions to persist session variables
#58031 (#58821)
add aa9c1894d3f branch-4.0: [opt](jvm) add more --add-opens #58936 (#58984)
add 9ac212e1730 branch-4.0: [opt](agg) Adjust the parameters of
StreamingHtMinReductionEntry #58938 (#58986)
add 43f4cb862a4 branch-4.0: [fix](inverted index) fix incorrect variable
usage in phrase query building #58952 (#58992)
add 3b5f9b762d0 branch-4.0: [chore](ci) exclude test_insert_error_url to
avoid stop grace fail #58985 (#58987)
add 863f11b27ae Revert "[test](variable)add up and down test case of
variables persistence" (#59038)
add dd8d33da18b branch-4.0: [fix](ann search)
l2_distance_approximate/inner_product_approximate should not be deterministic
#58988 (#59001)
add 3255d1798c5 branch-4.0: [fix](test) Fix output result for
test_non_overlap_seg_heavy_sc #58805 (#59032)
add 6518277ea76 branch-4.0: [fix](json) Replace invalid JSONB with default
JSONB null value #59007 (#59022)
add 63f3d2e6923 branch-4.0: [Fix](fe) Fix NPE in
`OlapTableSink.createPaloNodesInfo` due to concurrent drop backend #58999
(#59057)
add 0c5f8e0a22d branch-4.0: [fix](close) Release resource once fragment
was cancelled #58909 (#58971)
add 04dd91f737f [fix](case)fix create sync mv failed in test case (#58834)
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 (8180779b16a)
\
N -- N -- N refs/heads/auto-pick-58834-branch-4.0 (04dd91f737f)
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/src/cloud/cloud_cumulative_compaction.cpp | 2 +-
be/src/cloud/cloud_schema_change_job.cpp | 48 +-
be/src/cloud/cloud_schema_change_job.h | 3 +-
be/src/cloud/cloud_tablet.cpp | 2 +-
be/src/common/config.cpp | 4 +
be/src/common/config.h | 2 +
be/src/exec/schema_scanner.cpp | 3 +
be/src/exec/schema_scanner/schema_helper.cpp | 9 +
be/src/exec/schema_scanner/schema_helper.h | 5 +
.../schema_scanner/schema_load_job_scanner.cpp | 189 ++++++++
.../exec/schema_scanner/schema_load_job_scanner.h} | 39 +-
be/src/olap/memtable.cpp | 6 +-
.../rowset/segment_v2/inverted_index_writer.cpp | 2 +-
be/src/olap/schema_change.h | 1 +
be/src/olap/tablet_schema.cpp | 3 +-
be/src/pipeline/common/agg_utils.h | 10 +
be/src/pipeline/common/distinct_agg_utils.h | 10 +
be/src/pipeline/common/join_utils.h | 9 +
be/src/pipeline/common/partition_sort_utils.h | 10 +
be/src/pipeline/common/set_utils.h | 10 +
be/src/pipeline/exec/analytic_sink_operator.h | 8 +-
.../distinct_streaming_aggregation_operator.cpp | 2 +-
.../pipeline/exec/join/process_hash_table_probe.h | 3 +-
.../exec/join/process_hash_table_probe_impl.h | 19 +-
be/src/pipeline/pipeline_fragment_context.cpp | 10 +-
be/src/pipeline/pipeline_task.cpp | 1 -
be/src/runtime/memory/memory_profile.cpp | 24 +-
be/src/runtime/memory/memory_profile.h | 5 +-
be/src/runtime/primitive_type.h | 129 +----
be/src/runtime/runtime_state.h | 4 -
be/src/util/jsonb_document.cpp | 38 ++
be/src/util/jsonb_document.h | 25 -
.../vec/aggregate_functions/aggregate_function.h | 1 -
.../aggregate_function_ai_agg.cpp | 2 +-
.../aggregate_function_approx_count_distinct.cpp | 4 +-
.../aggregate_function_array_agg.cpp | 1 +
.../aggregate_functions/aggregate_function_avg.cpp | 36 +-
.../aggregate_functions/aggregate_function_avg.h | 33 +-
.../aggregate_function_bitmap.cpp | 5 +-
.../aggregate_function_bitmap_agg.cpp | 1 +
.../aggregate_function_collect.cpp | 1 +
.../aggregate_function_corr.cpp | 2 +
.../aggregate_function_count.cpp | 5 +-
.../aggregate_function_count_by_enum.cpp | 1 +
.../aggregate_function_covar.cpp | 2 +
.../aggregate_function_distinct.cpp | 5 +-
.../aggregate_function_foreach.cpp | 10 +-
.../aggregate_function_foreachv2.cpp | 11 +-
.../aggregate_function_group_array_set_op.cpp | 8 +-
.../aggregate_function_group_concat.cpp | 1 +
.../aggregate_function_histogram.cpp | 1 +
.../aggregate_function_kurtosis.cpp | 1 +
.../aggregate_function_linear_histogram.cpp | 1 +
.../aggregate_functions/aggregate_function_map.cpp | 1 +
.../aggregate_function_map_v2.cpp | 1 +
.../aggregate_function_min_max.cpp | 7 +-
.../aggregate_function_min_max.h | 5 +-
.../aggregate_function_min_max_by.h | 1 +
.../aggregate_function_orthogonal_bitmap.cpp | 1 +
.../aggregate_function_percentile.cpp | 8 +-
.../aggregate_function_percentile_reservoir.cpp | 1 +
.../aggregate_function_product.h | 11 +-
.../aggregate_function_quantile_state.cpp | 4 +-
.../aggregate_function_quantile_state.h | 4 +-
.../aggregate_function_reader_first_last.h | 41 +-
.../aggregate_function_regr_union.cpp | 1 +
.../aggregate_function_regr_union.h | 250 ++++++++--
.../aggregate_functions/aggregate_function_sem.cpp | 12 +-
.../aggregate_function_sequence_match.cpp | 1 +
.../aggregate_function_simple_factory.h | 14 +-
.../aggregate_function_skew.cpp | 1 +
.../aggregate_function_stddev.cpp | 16 +-
.../aggregate_functions/aggregate_function_sum.cpp | 18 +-
.../aggregate_functions/aggregate_function_sum.h | 51 +-
.../aggregate_function_topn.cpp | 3 +
.../aggregate_function_uniq.cpp | 1 +
.../aggregate_function_uniq_distribute_key.cpp | 1 +
.../aggregate_function_window.cpp | 4 +-
.../aggregate_function_window_funnel.cpp | 1 +
be/src/vec/aggregate_functions/helpers.h | 72 +++
be/src/vec/common/hash_table/hash.h | 21 +
be/src/vec/common/hash_table/hash_key_type.h | 6 +
be/src/vec/common/uint128.h | 19 +
be/src/vec/core/call_on_type_index.h | 162 +++++++
be/src/vec/data_types/data_type_agg_state.h | 20 +-
.../data_types/serde/data_type_nullable_serde.cpp | 10 +-
be/src/vec/exec/scan/file_scanner.cpp | 5 +-
be/src/vec/exec/vjdbc_connector.cpp | 50 +-
be/src/vec/exprs/vcast_expr.cpp | 5 +-
be/src/vec/exprs/vectorized_agg_fn.cpp | 10 +-
be/src/vec/exprs/vectorized_fn_call.cpp | 3 +-
be/src/vec/exprs/vin_predicate.cpp | 5 +-
be/src/vec/exprs/vmatch_predicate.cpp | 5 +-
be/src/vec/exprs/vtopn_pred.h | 4 +-
.../functions/array/function_array_aggregation.cpp | 491 ++++++++++++-------
.../vec/functions/array/function_array_cum_sum.cpp | 131 +++--
be/src/vec/functions/cast/cast_base.cpp | 18 +-
.../functions/cast/cast_to_basic_number_common.h | 26 +-
be/src/vec/functions/cast/cast_to_boolean.h | 26 +-
be/src/vec/functions/cast/cast_to_date.h | 67 ++-
be/src/vec/functions/cast/cast_to_decimal.h | 80 ++--
be/src/vec/functions/cast/cast_to_float.h | 2 +-
be/src/vec/functions/cast/cast_to_int.h | 37 +-
be/src/vec/functions/cast/cast_to_ip.h | 25 +-
be/src/vec/functions/cast/cast_to_jsonb.h | 9 +-
be/src/vec/functions/comparison_equal_for_null.cpp | 10 +-
be/src/vec/functions/complex_dict_hash_map.h | 8 +
be/src/vec/functions/function.h | 73 ++-
be/src/vec/functions/function_ifnull.h | 3 +-
be/src/vec/functions/function_search.cpp | 9 +-
be/src/vec/functions/nullif.cpp | 10 +-
be/src/vec/functions/simple_function_factory.h | 32 +-
be/src/vec/sink/vdata_stream_sender.cpp | 4 -
be/test/ai/aggregate_function_ai_agg_test.cpp | 2 +-
.../pipeline/common/distinct_agg_utils_test.cpp | 10 +
be/test/pipeline/common/set_utils_test.cpp | 8 +
.../operator/analytic_sink_operator_test.cpp | 35 +-
.../operator/streaming_agg_operator_test.cpp | 5 +-
be/test/testutil/mock/mock_agg_fn_evaluator.cpp | 21 +-
be/test/testutil/mock/mock_agg_fn_evaluator.h | 4 +-
.../vec/aggregate_functions/agg_array_agg_test.cpp | 11 +-
be/test/vec/aggregate_functions/agg_avg_test.cpp | 3 +-
be/test/vec/aggregate_functions/agg_bit_test.cpp | 9 +-
.../vec/aggregate_functions/agg_bitmap_test.cpp | 10 +-
.../aggregate_functions/agg_bool_union_test.cpp | 18 +-
.../vec/aggregate_functions/agg_collect_test.cpp | 14 +-
be/test/vec/aggregate_functions/agg_corr_test.cpp | 6 +-
be/test/vec/aggregate_functions/agg_count_test.cpp | 3 +-
.../vec/aggregate_functions/agg_function_test.h | 5 +-
.../agg_group_array_intersect_test.cpp | 8 +-
.../vec/aggregate_functions/agg_histogram_test.cpp | 2 +-
.../agg_linear_histogram_test.cpp | 4 +-
.../aggregate_functions/agg_min_max_by_test.cpp | 2 +-
.../vec/aggregate_functions/agg_min_max_test.cpp | 8 +-
.../vec/aggregate_functions/agg_replace_test.cpp | 4 +-
be/test/vec/aggregate_functions/agg_test.cpp | 45 +-
.../aggregate_functions/vec_count_by_enum_test.cpp | 2 +-
.../vec/aggregate_functions/vec_retention_test.cpp | 2 +-
.../vec_sequence_match_test.cpp | 10 +-
.../aggregate_functions/vec_window_funnel_test.cpp | 2 +-
be/test/vec/function/cast/cast_to_integer.cpp | 7 +-
.../vec/function/function_dict_get_many_test.cpp | 4 +-
be/test/vec/function/function_dict_get_test.cpp | 4 +-
.../vec/function/simple_function_factory_test.cpp | 4 +-
be/test/vec/jsonb/jsonb_document_test.cpp | 15 +
conf/be.conf | 2 +-
conf/fe.conf | 2 +-
.../scripts/data/test_flatten_data.json | 26 +
.../elasticsearch/scripts/es_init.sh | 6 +
.../scripts/index/es7_test_flatten.json | 25 +
.../org/apache/doris/jdbc/BaseJdbcExecutor.java | 19 +-
.../main/java/org/apache/doris/alter/Alter.java | 12 +-
.../org/apache/doris/alter/AlterJobV2Factory.java | 9 +-
.../org/apache/doris/alter/CloudRollupJobV2.java | 4 +-
.../doris/alter/MaterializedViewHandler.java | 20 +-
.../java/org/apache/doris/alter/RollupJobV2.java | 15 +-
.../org/apache/doris/alter/SchemaChangeJobV2.java | 6 +-
.../org/apache/doris/analysis/MVColumnItem.java | 3 +-
.../org/apache/doris/analysis/SchemaTableType.java | 2 +
.../org/apache/doris/catalog/AliasFunction.java | 27 ++
.../main/java/org/apache/doris/catalog/Column.java | 34 +-
.../java/org/apache/doris/catalog/Database.java | 7 +-
.../main/java/org/apache/doris/catalog/Env.java | 5 +-
.../org/apache/doris/catalog/FunctionUtil.java | 37 +-
.../apache/doris/catalog/GlobalFunctionMgr.java | 4 +-
.../main/java/org/apache/doris/catalog/MTMV.java | 70 ++-
.../doris/catalog/MaterializedIndexMeta.java | 108 +++--
.../java/org/apache/doris/catalog/OlapTable.java | 10 +-
.../org/apache/doris/catalog/OlapTableFactory.java | 10 +
.../java/org/apache/doris/catalog/SchemaTable.java | 24 +
.../main/java/org/apache/doris/catalog/View.java | 18 +-
.../cache/NereidsSortedPartitionsCacheManager.java | 54 +--
.../org/apache/doris/datasource/ExternalTable.java | 14 +
.../org/apache/doris/datasource/es/EsUtil.java | 1 +
.../doris/datasource/hive/HMSExternalTable.java | 15 +
.../doris/datasource/hive/HiveMetaStoreCache.java | 143 ++----
.../doris/httpv2/restv2/ESCatalogAction.java | 4 -
.../main/java/org/apache/doris/mtmv/MTMVCache.java | 26 +-
.../java/org/apache/doris/mtmv/MTMVPlanUtil.java | 6 +-
.../org/apache/doris/nereids/SqlCacheContext.java | 2 +-
.../org/apache/doris/nereids/StatementContext.java | 10 +-
.../glue/translator/ExpressionTranslator.java | 6 +
.../glue/translator/PhysicalPlanTranslator.java | 46 +-
.../doris/nereids/jobs/executor/Rewriter.java | 2 +
.../apache/doris/nereids/memo/StructInfoMap.java | 13 +-
.../doris/nereids/minidump/MinidumpUtils.java | 4 +-
.../doris/nereids/parser/LogicalPlanBuilder.java | 6 +-
.../post/CommonSubExpressionCollector.java | 18 +-
.../doris/nereids/rules/analysis/BindRelation.java | 22 +-
.../doris/nereids/rules/analysis/BindSink.java | 66 ++-
.../nereids/rules/analysis/CollectRelation.java | 11 +-
.../nereids/rules/analysis/NormalizeAggregate.java | 12 +-
.../rules/analysis/SessionVarGuardRewriter.java | 149 ++++++
.../mv/InitMaterializationContextHook.java | 30 +-
.../expression/ExpressionBottomUpRewriter.java | 12 +-
.../rules/expression/ExpressionRuleType.java | 4 +-
.../nereids/rules/expression/MergeGuardExpr.java | 52 ++
.../rules/SimplifyComparisonPredicate.java | 6 +-
.../expression/rules/SortedPartitionRanges.java | 44 ++
.../implementation/SplitAggWithoutDistinct.java | 53 ++-
.../doris/nereids/rules/rewrite/ColumnPruning.java | 2 +-
.../rules/rewrite/DistinctAggregateRewriter.java | 22 +-
.../nereids/rules/rewrite/MergeAggregate.java | 46 +-
.../rules/rewrite/PruneFileScanPartition.java | 12 +-
.../doris/nereids/stats/StatsCalculator.java | 6 +
.../doris/nereids/trees/expressions/Add.java | 2 +-
.../doris/nereids/trees/expressions/CaseWhen.java | 2 +-
.../doris/nereids/trees/expressions/Cast.java | 13 -
.../doris/nereids/trees/expressions/Divide.java | 2 +-
.../doris/nereids/trees/expressions/Mod.java | 2 +-
.../doris/nereids/trees/expressions/Multiply.java | 2 +-
.../trees/expressions/NeedSessionVarGuard.java | 23 +-
.../trees/expressions/SessionVarGuardExpr.java | 147 ++++++
.../doris/nereids/trees/expressions/Subtract.java | 2 +-
.../trees/expressions/WindowExpression.java | 2 +-
.../functions/ComputePrecisionForSum.java | 6 +
.../functions/agg/AggregateFunction.java | 2 +-
.../trees/expressions/functions/agg/Avg.java | 4 +-
.../functions/agg/MultiDistinctSum.java | 3 +-
.../functions/agg/MultiDistinctSum0.java | 3 +-
.../trees/expressions/functions/agg/Sum.java | 3 +-
.../trees/expressions/functions/agg/Sum0.java | 3 +-
.../functions/executable/NumericArithmetic.java | 18 +-
.../expressions/functions/scalar/ArrayAvg.java | 3 +-
.../expressions/functions/scalar/ArrayCumSum.java | 4 +-
.../expressions/functions/scalar/ArrayMax.java | 3 +-
.../expressions/functions/scalar/ArrayMin.java | 3 +-
.../expressions/functions/scalar/ArrayProduct.java | 3 +-
.../expressions/functions/scalar/ArraySum.java | 3 +-
.../expressions/functions/scalar/Coalesce.java | 3 +-
.../trees/expressions/functions/scalar/Date.java | 1 +
.../functions/scalar/GreatestLeast.java | 3 +-
.../trees/expressions/functions/scalar/If.java | 3 +-
.../functions/scalar/InnerProductApproximate.java | 5 +
.../functions/scalar/L2DistanceApproximate.java | 5 +
.../trees/expressions/functions/scalar/NullIf.java | 3 +-
.../trees/expressions/functions/scalar/Nvl.java | 3 +-
.../trees/expressions/functions/udf/AliasUdf.java | 30 +-
.../expressions/functions/udf/AliasUdfBuilder.java | 64 ++-
.../expressions/literal/DecimalV3Literal.java | 19 +-
.../nereids/trees/expressions/literal/Literal.java | 2 +-
.../expressions/visitor/ExpressionVisitor.java | 5 +
.../nereids/trees/plans/algebra/Aggregate.java | 29 ++
.../plans/commands/CreateFunctionCommand.java | 5 +-
.../commands/CreateMaterializedViewCommand.java | 5 +-
.../trees/plans/commands/CreateStageCommand.java | 3 +
.../plans/commands/info/ColumnDefinition.java | 13 +-
.../trees/plans/commands/info/CreateMTMVInfo.java | 9 +-
.../plans/commands/info/ShowCreateMTMVInfo.java | 3 +-
.../apache/doris/nereids/types/DecimalV2Type.java | 2 +-
.../apache/doris/nereids/types/DecimalV3Type.java | 24 +-
.../org/apache/doris/nereids/util/PlanUtils.java | 42 ++
.../org/apache/doris/persist/AlterViewInfo.java | 20 +-
.../org/apache/doris/planner/OlapTableSink.java | 3 +
.../apache/doris/qe/AutoCloseSessionVariable.java | 63 +++
.../org/apache/doris/qe/ConnectContextUtil.java | 8 +
.../java/org/apache/doris/qe/SessionVariable.java | 186 ++++----
.../main/java/org/apache/doris/qe/VariableMgr.java | 87 ++--
.../apache/doris/service/FrontendServiceImpl.java | 81 ++++
.../doris/alter/MaterializedViewHandlerTest.java | 7 +-
.../org/apache/doris/alter/RollupJobV2Test.java | 2 +-
.../org/apache/doris/catalog/CreateViewTest.java | 5 +-
.../org/apache/doris/catalog/DatabaseTest.java | 1 +
.../expression/ExpressionRewriteTestHelper.java | 3 +-
.../doris/nereids/rules/rewrite/PrepareTest.java | 83 ++++
.../trees/expressions/VariablePersistTest.java | 215 +++++++++
.../plans/commands/merge/MergeIntoCommandTest.java | 42 +-
.../apache/doris/persist/AlterViewInfoTest.java | 3 +-
.../org/apache/doris/qe/OlapQueryCacheTest.java | 9 +-
.../org/apache/doris/qe/SessionVariablesTest.java | 3 +-
gensrc/thrift/Descriptors.thrift | 1 +
gensrc/thrift/FrontendService.thrift | 32 ++
regression-test/conf/regression-conf.groovy | 13 +
.../agg_state/decimal_sum/test_decimal_sum.out | 5 -
.../agg_state/decimalv3/test_decimalv3.out | 17 +
.../external_table_p0/es/test_es_flatten_type.out | 13 +
...est_query_remote_doris_as_olap_table_select.out | 24 +
.../test_remote_doris_agg_table_select.out | 54 +++
.../test_remote_doris_unique_table_select.out | 32 ++
.../test_remote_doris_variant_select.out | 81 ++++
.../data/inverted_index_p0/test_pinyin_phrase.out | 18 +
.../variables_persist/test_alias_function.out | 37 ++
.../variables_persist/test_array_agg_view.out | 41 ++
.../variables_persist/test_generated_column.out | 25 +
.../nereids_p0/variables_persist/test_mtmv.out | 21 +
.../nereids_p0/variables_persist/test_sync_mv.out | 16 +
.../variables_persist/test_view_var_persist.out | 216 +++++++++
.../variables_persist/use_view_create_mv.out | 11 +
.../limit_push_down/limit_push_down.out | 32 +-
.../support_type/regr_intercept/regr_intercept.out | 8 +-
.../support_type/regr_slope/regr_slope.out | 8 +-
.../test_non_overlap_seg_heavy_sc.out | 2 +-
.../org/apache/doris/regression/Config.groovy | 66 ++-
.../doris/regression/action/HttpCliAction.groovy | 223 +++++----
.../doris/regression/action/ProfileAction.groovy | 66 +++
.../regression/action/StreamLoadAction.groovy | 211 ++++++++-
.../org/apache/doris/regression/suite/Suite.groovy | 14 +-
.../doris/regression/suite/SuiteContext.groovy | 19 +
.../org/apache/doris/regression/util/Http.groovy | 78 +++
.../nonConcurrent/conf/regression-conf.groovy | 1 +
.../plugins/cloud_compaction_plugin.groovy | 16 +-
.../plugins/cloud_show_data_plugin.groovy | 3 +
.../plugins/plugin_curl_requester.groovy | 66 ++-
.../plugins/plugin_query_timeout_debugger.groovy | 103 +++-
.../auth_call/test_dml_stream_load_auth.groovy | 8 +-
...est_bloom_filter_hit_with_renamed_column.groovy | 69 +--
.../cloud_p0/balance/test_balance_warm_up.groovy | 3 +
.../test_balance_warm_up_use_peer_cache.groovy | 3 +
...e_warm_up_with_compaction_use_peer_cache.groovy | 3 +
.../balance/test_peer_read_async_warmup.groovy | 3 +
.../cache/compaction/test_stale_rowset.groovy | 9 +-
.../cluster/test_immediate_warmup_basic.groovy | 3 +
.../test_immediate_warmup_multi_segments.groovy | 12 +-
.../cluster/test_warm_up_cluster_event.groovy | 3 +
.../test_warm_up_cluster_event_add_new_be.groovy | 3 +
...test_warm_up_cluster_event_cancel_active.groovy | 3 +
...est_warm_up_cluster_event_cancel_passive.groovy | 3 +
.../test_warm_up_cluster_event_compaction.groovy | 3 +
...rm_up_cluster_event_compaction_sync_wait.groovy | 12 +-
...uster_event_compaction_sync_wait_timeout.groovy | 12 +-
.../test_warm_up_cluster_event_rename.groovy | 3 +
...est_warm_up_cluster_event_restart_all_be.groovy | 3 +
..._warm_up_cluster_event_restart_master_fe.groovy | 3 +
...test_warm_up_cluster_event_schema_change.groovy | 3 +
.../cluster/test_warm_up_cluster_periodic.groovy | 3 +
...test_warm_up_cluster_periodic_add_new_be.groovy | 3 +
.../test_warm_up_cluster_periodic_and_event.groovy | 3 +
.../test_warm_up_cluster_periodic_rename.groovy | 3 +
...rm_up_cluster_periodic_restart_master_fe.groovy | 3 +
.../test_warm_up_cluster_periodic_slow_job.groovy | 3 +
.../test_mow_agg_delete_bitmap.groovy | 36 +-
.../test_enable_prefer_cached_rowset.groovy | 3 +
.../test_query_freshness_tolerance.groovy | 3 +
..._warmup_delay_compaction_query_tolerance.groovy | 12 +-
.../test_warmup_delay_idx_query_tolerance.groovy | 12 +-
.../test_warmup_delay_sc_query_tolerance.groovy | 12 +-
...delay_timeout_compaction_query_tolerance.groovy | 12 +-
.../warmup/test_warmup_download_fail.groovy | 12 +-
.../cloud_p0/test_read_cluster_var_property.groovy | 3 +
.../test_compaction_fail_release_lock.groovy | 22 +-
...test_compaction_update_big_delete_bitmap.groovy | 22 +-
...e_compaction_and_read_stale_cloud_docker.groovy | 22 +-
...ultisegments_and_read_stale_cloud_docker.groovy | 13 +-
.../test_filecache_with_base_compaction.groovy | 22 +-
...ilecache_with_base_compaction_thresthold.groovy | 22 +-
.../test_mow_compact_multi_segments.groovy | 13 +-
...paction_agg_and_remove_pre_delete_bitmap.groovy | 22 +-
.../test_mow_compaction_and_read_stale.groovy | 22 +-
...w_compaction_and_read_stale_cloud_docker.groovy | 22 +-
...test_mow_compaction_and_rowset_not_exist.groovy | 22 +-
.../test_mow_compaction_and_schema_change.groovy | 22 +-
.../test_mow_delete_unused_rowset_dm_docker.groovy | 22 +-
.../test_mow_stale_rowset_delete_bitmap.groovy | 22 +-
.../test_single_compaction_fault_injection.groovy | 22 +-
...e_compaction_with_variant_inverted_index.groovy | 22 +-
.../test_single_replica_compaction.groovy | 22 +-
.../agg_state/decimalv3/test_decimalv3.groovy | 66 +++
.../import-way/group-commit-manual.md.groovy | 15 +-
.../doc/table-design/auto-increment.md.groovy | 11 +-
.../dynamic-partitioning.md.groovy | 10 +-
.../index/ngram-bloomfilter-index.md.groovy | 8 +-
.../suites/export/test_array_export.groovy | 7 +-
.../suites/export/test_map_export.groovy | 7 +-
.../suites/export/test_struct_export.groovy | 7 +-
.../outfile/parquet/test_outfile_parquet.groovy | 8 +-
.../suites/export_p0/test_export_basic.groovy | 8 +-
.../suites/export_p0/test_export_csv.groovy | 7 +-
.../export_p0/test_export_data_consistency.groovy | 7 +-
.../export_p0/test_export_delete_disallow.groovy | 7 +-
.../export_p0/test_export_empty_table.groovy | 7 +-
.../test_export_table_with_label_retry.groovy | 7 +-
.../suites/export_p0/test_export_view.groovy | 7 +-
.../suites/export_p0/test_outfile.groovy | 8 +-
.../export_p0/test_outfile_csv_with_names.groovy | 8 +-
.../test_outfile_csv_with_names_and_types.groovy | 7 +-
.../test_outfile_csv_with_success_prefix.groovy | 7 +-
.../suites/export_p0/test_outfile_expr.groovy | 7 +-
.../suites/export_p0/test_outfile_separator.groovy | 7 +-
.../suites/export_p2/test_export_big_data.groovy | 7 +-
.../es/test_es_flatten_type.groovy | 50 ++
.../export/test_export_external_table.groovy | 190 +++++---
..._query_remote_doris_as_olap_table_select.groovy | 104 ++++
.../test_remote_doris_agg_table_select.groovy | 307 ++++++++++++
.../test_remote_doris_unique_table_select.groovy | 238 ++++++++++
.../test_remote_doris_variant_select.groovy | 148 ++++++
.../test_cloud_mow_delete_bitmap_lock_case.groovy | 22 +-
.../test_delete_bitmap_lock_with_restart.groovy | 9 +-
.../flink_connector_response.groovy | 11 +-
.../cast/test_cast_to_complex_types_strict.groovy | 6 +
.../http_rest_api/get/test_schema_api.groovy | 14 +
.../http_rest_api/post/test_query_stmt.groovy | 54 ++-
..._index_change_with_cumulative_compaction.groovy | 12 +-
.../test_index_change_with_full_compaction.groovy | 12 +-
...est_cumulative_compaction_with_format_v2.groovy | 12 +-
.../test_mor_table_with_format_v2.groovy | 13 +-
.../test_mow_table_with_format_v2.groovy | 53 ++-
...single_replica_compaction_with_format_v2.groovy | 12 +-
.../test_arrayInvertedIdx_profile.groovy | 14 +-
.../inverted_index_p0/test_pinyin_phrase.groovy | 73 +++
.../test_load_job_info_system_table.groovy | 74 +++
.../stream_load/test_get_stream_load_state.groovy | 8 +-
...t_stream_load_with_nonexist_db_and_table.groovy | 3 +
.../stream_load/test_group_commit_wal_limit.groovy | 6 +
.../load_p0/stream_load/test_json_load.groovy | 2 +-
.../test_load_with_transfer_encoding.groovy | 3 +
.../stream_load/test_publish_timeout.groovy | 9 +-
.../test_s3_bytes_written_metrics.groovy | 3 +
.../load_p0/stream_load/test_stream_load.groovy | 175 +++----
.../stream_load/test_stream_load_2pc.groovy | 16 +-
.../test_stream_load_2pc_with_schema_change.groovy | 3 +
.../test_stream_load_err_log_limit.groovy | 9 +-
.../stream_load/test_stream_load_properties.groovy | 2 +-
.../suites/manager/test_manager_interface_1.groovy | 10 +-
.../metrics_p0/test_delete_bitmap_metrics.groovy | 3 +
.../ssb/multiple_no_where/multiple_no_where.groovy | 2 +
.../mv_p0/ssb/multiple_ssb/multiple_ssb.groovy | 4 +
.../multiple_ssb_between.groovy | 6 +-
.../suites/mv_p0/ssb/q_1_1/q_1_1.groovy | 1 +
.../suites/mv_p0/ssb/q_2_1/q_2_1.groovy | 1 +
.../suites/mv_p0/ssb/q_3_1/q_3_1.groovy | 1 +
.../suites/mv_p0/ssb/q_4_1/q_4_1.groovy | 1 +
.../suites/mv_p0/ssb/q_4_1_r1/q_4_1_r1.groovy | 1 +
.../mysql_ssl_p0/test_mysql_connection.groovy | 40 +-
.../nereids_p0/aggregate/window_funnel.groovy | 3 +
.../authorization/column_authorization.groovy | 7 +-
.../authorization/view_authorization.groovy | 7 +-
.../suites/nereids_p0/outfile/test_outfile.groovy | 7 +-
.../outfile/test_outfile_csv_with_names.groovy | 10 +-
.../nereids_p0/outfile/test_outfile_expr.groovy | 7 +-
.../nereids_p0/outfile/test_outfile_parquet.groovy | 10 +-
.../outfile/test_outfile_separator.groovy | 7 +-
.../nereids_p0/variables_persist/load.groovy | 44 ++
.../variables_persist/test_alias_function.groovy | 80 ++++
.../variables_persist/test_array_agg_view.groovy | 77 +++
.../variables_persist/test_generated_column.groovy | 147 ++++++
.../nereids_p0/variables_persist/test_mtmv.groovy | 249 ++++++++++
.../variables_persist/test_sync_mv.groovy | 117 +++++
.../variables_persist/test_view_var_persist.groovy | 525 +++++++++++++++++++++
.../variables_persist/use_view_create_mv.groovy | 68 +++
.../suites/prepared_stmt_p0/prepared_stmt.groovy | 31 +-
.../query_p0/aggregate/test_regr_intercept.groovy | 18 +-
.../query_p0/aggregate/test_regr_slope.groovy | 18 +-
...ptive_pipeline_task_serial_read_on_limit.groovy | 39 +-
.../query_profile/s3_load_profile_test.groovy | 25 +-
.../suites/query_profile/scanner_profile.groovy | 70 +--
.../query_profile/test_execute_by_frontend.groovy | 31 +-
.../suites/query_profile/test_profile.groovy | 28 +-
.../test_filecache_with_alter_table.groovy | 234 +++++++++
448 files changed, 9474 insertions(+), 2333 deletions(-)
create mode 100644 be/src/exec/schema_scanner/schema_load_job_scanner.cpp
copy be/{test/vec/aggregate_functions/agg_avg_test.cpp =>
src/exec/schema_scanner/schema_load_job_scanner.h} (52%)
create mode 100644
docker/thirdparties/docker-compose/elasticsearch/scripts/data/test_flatten_data.json
create mode 100644
docker/thirdparties/docker-compose/elasticsearch/scripts/index/es7_test_flatten.json
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/analysis/SessionVarGuardRewriter.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/expression/MergeGuardExpr.java
rename
regression-test/suites/datatype_p0/agg_state/decimal_sum/test_decimal_sum.groovy
=>
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/NeedSessionVarGuard.java
(54%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/SessionVarGuardExpr.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/qe/AutoCloseSessionVariable.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/rules/rewrite/PrepareTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/expressions/VariablePersistTest.java
delete mode 100644
regression-test/data/datatype_p0/agg_state/decimal_sum/test_decimal_sum.out
create mode 100644
regression-test/data/datatype_p0/agg_state/decimalv3/test_decimalv3.out
create mode 100644
regression-test/data/external_table_p0/es/test_es_flatten_type.out
create mode 100644
regression-test/data/external_table_p0/remote_doris/test_remote_doris_agg_table_select.out
create mode 100644
regression-test/data/external_table_p0/remote_doris/test_remote_doris_unique_table_select.out
create mode 100644
regression-test/data/external_table_p0/remote_doris/test_remote_doris_variant_select.out
create mode 100644
regression-test/data/inverted_index_p0/test_pinyin_phrase.out
create mode 100644
regression-test/data/nereids_p0/variables_persist/test_alias_function.out
create mode 100644
regression-test/data/nereids_p0/variables_persist/test_array_agg_view.out
create mode 100644
regression-test/data/nereids_p0/variables_persist/test_generated_column.out
create mode 100644
regression-test/data/nereids_p0/variables_persist/test_mtmv.out
create mode 100644
regression-test/data/nereids_p0/variables_persist/test_sync_mv.out
create mode 100644
regression-test/data/nereids_p0/variables_persist/test_view_var_persist.out
create mode 100644
regression-test/data/nereids_p0/variables_persist/use_view_create_mv.out
create mode 100644
regression-test/suites/datatype_p0/agg_state/decimalv3/test_decimalv3.groovy
create mode 100644
regression-test/suites/external_table_p0/es/test_es_flatten_type.groovy
create mode 100644
regression-test/suites/external_table_p0/remote_doris/test_remote_doris_agg_table_select.groovy
create mode 100644
regression-test/suites/external_table_p0/remote_doris/test_remote_doris_unique_table_select.groovy
create mode 100644
regression-test/suites/external_table_p0/remote_doris/test_remote_doris_variant_select.groovy
create mode 100644
regression-test/suites/inverted_index_p0/test_pinyin_phrase.groovy
create mode 100644
regression-test/suites/job_p0/job_system_table/test_load_job_info_system_table.groovy
create mode 100644
regression-test/suites/nereids_p0/variables_persist/load.groovy
create mode 100644
regression-test/suites/nereids_p0/variables_persist/test_alias_function.groovy
create mode 100644
regression-test/suites/nereids_p0/variables_persist/test_array_agg_view.groovy
create mode 100644
regression-test/suites/nereids_p0/variables_persist/test_generated_column.groovy
create mode 100644
regression-test/suites/nereids_p0/variables_persist/test_mtmv.groovy
create mode 100644
regression-test/suites/nereids_p0/variables_persist/test_sync_mv.groovy
create mode 100644
regression-test/suites/nereids_p0/variables_persist/test_view_var_persist.groovy
create mode 100644
regression-test/suites/nereids_p0/variables_persist/use_view_create_mv.groovy
create mode 100644
regression-test/suites/schema_change/test_filecache_with_alter_table.groovy
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
