This is an automated email from the ASF dual-hosted git repository.
lihaopeng pushed a change to branch topn-lazy-materialize-poc
in repository https://gitbox.apache.org/repos/asf/doris.git
discard e90b908e32b add rt for only one materialization node
discard 6ac2662c4fe fmt
discard acc7e7ac28f shape-update
discard f0b013ead65 only one materializeNode
discard 53f0b23a6ec skip sync mv
discard bbacc54db0f fix right join nullable
discard 43743bc8980 add log to debug the id mapping null
discard 13fc5a61462 fix rebase error
discard 1305a0d60fa fix the ut
discard d456035a75d turn off lazy materialization for defer_materialization
cases
discard b28da831ed2 fix the block column not match bug
discard 2a316531e4e fix alias issue
discard a25b8fcb63a shape update
discard bb4325d1fbb fix missing unused key col
discard 1fdf01f5d43 fix the p0 failed by BE
discard 38b1fc084ec fix wg null pointer
discard c7d8f55956c fix the ut compile
discard 7e1981391cd apply licesen
discard 3f1d9abe7f0 diable key lazy materialize in mor/agg key
discard 72d9ec8103e fix char padding not remove bug
discard eff00628b39 fix typo
discard a9d6b545937 translate_fix
discard e7f4222db7c topn filter ut
discard 7d98eeed8d7 fix test failed
discard d05493ac577 fix compile error
discard 3485f6e695c do code format
discard 0c4dfb08a3f fe
discard bfd694b2086 Support topn-lazy-materialize
add a930cac64cc [Fix](cloud-mow) avoid calc delete bitmap tasks on same
(txn_id, tablet_id) being executed concurrently (#50847)
add c90fc89a60f [Exec](performance) use distinct stream agg in not stream
agg case (#47460)
add 6dfd1528c76 [Improment]Add workload group checker (#50782)
add bb5258d960b [chore](test) add some debug info (#50932)
add e112afb62a8 [Chore](build) add macro undef check and remove
dynamic_annotations/stringprintf (#50857)
add 3d3c626ce44 [improve](group commit)Print file size when replaying wal
(#50688)
add 7d4cfa024dc [improve](cloud-mow)Add white list for delete bitmap
update lock version (#50173)
add 4e6ff1737d1 [fix](compile) fix be compile error (#50841)
add ef4cf6337f4 [fix](Nereids) we should also push down expr in join's
mark conjuncts (#50886)
add e3f222f3583 [fix](nereids)use analyzed plan instead of rewritten plan
in CreateMaterializedViewCommand (#49297)
add e0a83f72ce9 [fix](nereids)create alias function should fail when meet
unsupported expr (#49698)
add e7a3e78b97c [fix](nereids)prune assert_true slots in subquery
unnesting (#50256)
add 727161bfd18 [feat](oss) support oss-hdfs root policy (#50678)
add 86fcb313660 [fix](function) fix xpath_string to support xpath_query
with string functions (#50946)
add 0f4bde56aa9 [refactor](nereids)move PhysicalWindow child request
property deriving from LogicalWindowToPhysicalWindow to RequestPropertyDeriver
(#50891)
add 7c49f4f1251 [feature](inverted index) Support the IS NOT NULL
condition in expr via inverted indexes (#50748)
add ba2d01123ec [Fix](Variant) fix array with predicate push down (#50934)
add 7b259d3badf [Fix](ShortCircuit) fix crash when enable
`skip_delete_sign` (#50941)
add adda6282246 [chore](Nereids) remove some useless code (#50953)
add e31100359d1 [fix](expr) fix expr set result column id even when state
is not ok (#50938)
add e8717f2587b [fix](core) Fix the core issue caused by extra fields when
casting a string to a struct. (#50851)
add 4da1c8ab194 [opt](mtmv) optimize mtmv rewrite performance (#49514)
add 1262d7c3e1a [test](mtmv)Verifying master-slave consistency after
schema change (#50880)
add f6bfb0430c4 [Enhancement] config rf wait time in cloud mode (#47579)
add c647dd597a4 [chore](build) speed up generated-source.sh (#50980)
add af64ad9e728 [Fix](cloud-mow) Full compaction should only update delete
bitmap of its output rowset (#50974)
add 5ee113fab4e [enhancement] Optimize the retry policy of backend request
meta service (#50957)
add 53b7f146bfc [bug](cloud) Fix npe when show cluster load statistic
(#50866)
add a71ccc1948e [Opt](compaction) Add config
`enable_mow_compaction_correctness_check_fail` for debug (#50966)
add 1af10e87ba0 [fix](jsonb) Avoid crashing caused by invalid path (#50978)
add 504bce2c014 [Chore](case) add some prepare fail test case (#50944)
add dc88e558a2e [bug](function) fix array_map coredump when no rows
(#50913)
add c1ef8c22d53 [Feature](Compaction)Improve Compaction Profiling and
Logging (#50950)
add 0cab080a3f5 [Enhancement] (nereids) implement cancelBuildIndexCommand
in nereids (#49631)
add 01725e5ebf5 [improvement](nereids)abstract function for limit and
offset (#50988)
add 3a154a2425d [fix](nereids) fix create view use null literal (#49881)
add 2eee6d7c8a0 [feat](hive) add catalog level schema cache property
(#50958)
add 34e4bec7fce [fix](arrow-flight-sql) Separate arrow-flight-sql
connection and mysql connection (#50939)
add 1da99867a13 [ut](numbers) add ut for casting to numbers (#50962)
add 82703feff77 [fix](ut) Fix fe ut `RemoteFileSystemTest` crash (#51014)
add bba3d358189 [fix](mv) refresh failed while open
enable_single_replica_insert (#50986)
add 09107db8ca0 ut Fix DiskUtilsTest runs failed on mac (#50981)
add 15f410ee5e7 [Fix](mac) Fix macos compile about BYTE_ORDER and
BASE_HAS_ATOMIC64 and USE_UNWIND (#50997)
add 84d9ab00f03 [fix](meta) replace partition should not get table version
in cloud mode (#50888)
add 4b14a1b83ca Update Slack link of README.md (#50952)
add 1b54ec83ed2 [Fix](compaction) Failed compaction tablets should sleep
before being selected again (#50672)
add 5aa3832f492 [Bug](intersect) fix wrong result of intersect with null
literal (#50951)
add 4cf67f551b6 Support topn-lazy-materialize
add 31f75034e0d fe
add c96e51b8971 do code format
add 38ca05a3e08 fix compile error
add 68dce1427c9 fix test failed
add cf9f524be89 topn filter ut
add 030ae2a4272 translate_fix
add 91e2e1fffe9 fix typo
add 18af38d31de fix char padding not remove bug
add 37e7dc1efee diable key lazy materialize in mor/agg key
add 615d70d40d9 apply licesen
add 96bbaeac14e fix the ut compile
add 1b5bc366a69 fix wg null pointer
add 3d7b244648b fix the p0 failed by BE
add a12fdbd958c fix missing unused key col
add fee04853601 shape update
add 41675ad3d59 fix alias issue
add 26bdac4ba2b fix the block column not match bug
add 9f47ea8fe84 turn off lazy materialization for defer_materialization
cases
add 950d273f2a1 fix the ut
add 2f87388b105 fix rebase error
add 910a64933b3 add log to debug the id mapping null
add 163452c8765 fix right join nullable
add 695d8825110 skip sync mv
add ec46ebe5715 only one materializeNode
add 0cd8b5aa0e7 shape-update
add 845c814f1e2 fmt
add 25dc035b198 add rt for only one materialization node
add c4636042a49 Revert "add log to debug the id mapping null"
add 1bbeff20c43 add query id to print
add e8106c45506 clickbench conf revise
add 9d0536707ff fix materialize node local shuffle
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 (e90b908e32b)
\
N -- N -- N refs/heads/topn-lazy-materialize-poc (9d0536707ff)
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:
README.md | 4 +-
be/CMakeLists.txt | 2 +-
be/src/cloud/cloud_base_compaction.cpp | 38 +-
be/src/cloud/cloud_compaction_action.cpp | 8 +
be/src/cloud/cloud_cumulative_compaction.cpp | 51 +-
.../cloud/cloud_engine_calc_delete_bitmap_task.cpp | 5 +
be/src/cloud/cloud_full_compaction.cpp | 24 +-
be/src/cloud/cloud_meta_mgr.cpp | 10 +-
be/src/cloud/cloud_storage_engine.cpp | 15 +-
be/src/cloud/cloud_tablet.cpp | 68 +-
be/src/cloud/cloud_tablet.h | 39 +
be/src/cloud/cloud_tablet_mgr.cpp | 9 +-
be/src/cloud/cloud_tablet_mgr.h | 3 +
be/src/cloud/config.cpp | 5 +-
be/src/cloud/config.h | 3 +
be/src/common/config.cpp | 3 +
be/src/common/config.h | 3 +
be/src/common/stack_trace.cpp | 4 +-
be/src/common/status.h | 1 +
be/src/glibc-compatibility/CMakeLists.txt | 13 +-
be/src/gutil/CMakeLists.txt | 2 -
be/src/gutil/atomic_refcount.h | 2 +-
be/src/gutil/atomicops-internals-gcc.h | 2 -
be/src/gutil/basictypes.h | 24 -
be/src/gutil/dynamic_annotations.c | 129 ---
be/src/gutil/dynamic_annotations.h | 662 -------------
be/src/gutil/ref_counted.h | 9 -
be/src/gutil/stringprintf.cc | 135 ---
be/src/gutil/stringprintf.h | 46 -
be/src/gutil/strings/numbers.cc | 387 --------
be/src/gutil/strings/numbers.h | 184 ----
be/src/http/action/compaction_action.cpp | 10 +
be/src/index-tools/index_tool.cpp | 11 +-
be/src/olap/base_compaction.cpp | 45 +-
be/src/olap/base_tablet.cpp | 2 +
be/src/olap/compaction.cpp | 7 +-
be/src/olap/cumulative_compaction.cpp | 53 +-
be/src/olap/full_compaction.cpp | 33 +-
be/src/olap/id_manager.h | 3 +-
be/src/olap/olap_server.cpp | 4 +
be/src/olap/rowset/segment_v2/segment.h | 7 +-
be/src/olap/rowset/segment_v2/segment_iterator.cpp | 23 +
be/src/olap/selection_vector.h | 165 ---
be/src/olap/tablet.cpp | 20 +-
be/src/olap/tablet.h | 28 +
be/src/olap/wal/wal_table.cpp | 12 +-
.../exec/materialization_sink_operator.cpp | 11 +-
be/src/pipeline/pipeline_fragment_context.cpp | 5 +-
be/src/runtime/fragment_mgr.cpp | 3 +
be/src/service/point_query_executor.cpp | 8 +-
be/src/util/bitmap.cpp | 20 -
be/src/util/bitmap.h | 7 -
be/src/util/byte_stream_split.cpp | 2 +-
be/src/util/cgroup_util.cpp | 38 +-
be/src/util/coding.h | 16 +-
be/src/util/cpu_info.cpp | 35 +-
be/src/util/easy_json.cc | 2 +-
be/src/util/easy_json.h | 12 +-
be/src/util/errno.cpp | 6 -
be/src/util/faststring.h | 2 +-
be/src/util/jsonb_document.h | 8 +
be/src/util/perf_counters.cpp | 13 +-
be/src/util/thread.cpp | 49 +-
be/src/util/threadpool.cpp | 3 -
be/src/vec/common/arena.h | 7 +-
be/src/vec/common/arena_with_free_lists.h | 5 +-
be/src/vec/common/demangle.cpp | 2 +-
be/src/vec/common/int_exp.h | 160 +--
be/src/vec/core/types.h | 6 +-
be/src/vec/data_types/data_type_number_base.cpp | 2 +-
be/src/vec/data_types/data_type_number_base.h | 3 +-
be/src/vec/data_types/number_traits.h | 26 +-
.../data_types/serde/data_type_struct_serde.cpp | 10 +
.../exec/format/parquet/vparquet_group_reader.cpp | 1 -
.../exprs/lambda_function/varray_map_function.cpp | 6 +-
be/src/vec/exprs/vcast_expr.cpp | 2 +
be/src/vec/exprs/vexpr.cpp | 4 +-
be/src/vec/exprs/vexpr_context.cpp | 3 +-
be/src/vec/functions/function_string.h | 50 +-
be/src/vec/functions/is_not_null.cpp | 63 +-
.../functions/{is_not_null.cpp => is_not_null.h} | 34 +-
be/src/vec/functions/is_null.cpp | 58 +-
be/src/vec/functions/{is_null.cpp => is_null.h} | 27 +-
be/src/vec/io/io_helper.h | 1 +
be/src/vec/runtime/vdata_stream_mgr.cpp | 7 +-
be/test/CMakeLists.txt | 3 +
be/test/cloud/cloud_compaction_test.cpp | 195 ++++
be/test/olap/ordered_data_compaction_test.cpp | 1 -
be/test/olap/primary_key_index_test.cpp | 1 -
be/test/vec/function/cast/cast_test.h | 46 +-
be/test/vec/function/cast/cast_to_decimal.cpp | 1047 ++++++++++++++++++++
be/test/vec/function/cast/cast_to_float_double.cpp | 784 +++++++++++++++
be/test/vec/function/cast/cast_to_integer.cpp | 741 ++++++++++++++
be/test/vec/function/cast/cast_to_time_test.cpp | 5 +-
be/test/vec/function/function_is_null_test.cpp | 237 +++++
be/test/vec/function/function_test_util.cpp | 61 +-
be/test/vec/function/function_test_util.h | 27 +-
be/test/vec/olap/vertical_compaction_test.cpp | 1 -
cloud/src/common/config.h | 7 +-
cloud/src/common/configbase.cpp | 9 +-
cloud/src/common/configbase.h | 3 +
cloud/src/meta-service/CMakeLists.txt | 1 +
.../meta-service/delete_bitmap_lock_white_list.cpp | 84 ++
.../meta-service/delete_bitmap_lock_white_list.h | 36 +-
cloud/src/meta-service/meta_service.cpp | 153 ++-
cloud/src/meta-service/meta_service.h | 24 +-
cloud/src/meta-service/meta_service_job.cpp | 36 +-
cloud/test/meta_service_http_test.cpp | 114 +++
cloud/test/meta_service_job_test.cpp | 825 +++++++++++++--
cloud/test/recycler_test.cpp | 2 +-
.../apache/doris/common/jni/vec/VectorColumn.java | 8 +-
.../main/java/org/apache/doris/common/Config.java | 33 +-
.../org/apache/doris/common/io/DiskUtilsTest.java | 2 +-
.../antlr4/org/apache/doris/nereids/DorisParser.g4 | 10 +-
.../apache/doris/alter/SchemaChangeHandler.java | 60 ++
.../doris/catalog/BuiltinScalarFunctions.java | 2 -
.../main/java/org/apache/doris/catalog/Env.java | 29 +-
.../transaction/CloudGlobalTransactionMgr.java | 3 +
.../java/org/apache/doris/common/FeConstants.java | 2 -
.../common/proc/ClusterLoadStatisticProcDir.java | 5 +-
.../doris/common/profile/SummaryProfile.java | 18 +-
.../org/apache/doris/common/util/LocationPath.java | 48 +-
.../apache/doris/datasource/ExternalCatalog.java | 32 +-
.../doris/datasource/ExternalMetaCacheMgr.java | 35 +-
.../doris/datasource/ExternalSchemaCache.java | 8 +-
.../doris/datasource/hive/HMSExternalCatalog.java | 5 -
.../doris/datasource/hive/HiveMetaStoreCache.java | 9 +-
.../datasource/property/PropertyConverter.java | 5 +-
.../org/apache/doris/mtmv/MTMVRelationManager.java | 24 +-
.../org/apache/doris/mtmv/MTMVRewriteUtil.java | 45 +-
.../org/apache/doris/mysql/AcceptListener.java | 6 +-
.../org/apache/doris/nereids/CascadesContext.java | 5 +
.../org/apache/doris/nereids/NereidsPlanner.java | 88 +-
.../java/org/apache/doris/nereids/PlannerHook.java | 12 +
.../org/apache/doris/nereids/StatementContext.java | 43 +-
.../doris/nereids/analyzer/UnboundFunction.java | 7 +-
.../doris/nereids/jobs/executor/Analyzer.java | 12 +-
.../doris/nereids/jobs/executor/Rewriter.java | 4 +
.../jobs/executor/TablePartitionCollector.java | 46 +
.../apache/doris/nereids/memo/StructInfoMap.java | 4 +
.../doris/nereids/parser/LogicalPlanBuilder.java | 11 +
.../nereids/properties/RequestPropertyDeriver.java | 37 +
.../org/apache/doris/nereids/rules/RuleType.java | 1 +
.../nereids/rules/analysis/BindExpression.java | 66 +-
.../rules/analysis/EliminateLogicalSelectHint.java | 2 -
.../nereids/rules/analysis/ExpressionAnalyzer.java | 10 -
.../nereids/rules/analysis/SubExprAnalyzer.java | 9 +-
.../nereids/rules/analysis/SubqueryToApply.java | 67 +-
.../mv/AbstractMaterializedViewRule.java | 223 ++---
.../rules/exploration/mv/HyperGraphComparator.java | 41 +-
.../mv/InitMaterializationContextHook.java | 17 +-
.../exploration/mv/MaterializationContext.java | 37 +-
...terializedViewAggregateOnNoneAggregateRule.java | 12 +-
.../rules/exploration/mv/PartitionCompensator.java | 199 ++++
.../nereids/rules/exploration/mv/StructInfo.java | 121 +--
...ogicalOlapTableSinkToPhysicalOlapTableSink.java | 3 +-
.../LogicalWindowToPhysicalWindow.java | 60 +-
.../nereids/rules/rewrite/EliminateMarkJoin.java | 68 --
.../nereids/rules/rewrite/NormalizeToSlot.java | 5 -
.../rules/rewrite/PruneFileScanPartition.java | 1 -
.../nereids/rules/rewrite/PullUpPredicates.java | 14 +-
.../rules/rewrite/PushDownAliasIntoUnionAll.java | 85 --
.../PushDownExpressionsInHashCondition.java | 59 +-
.../rules/rewrite/QueryPartitionCollector.java | 95 ++
.../nereids/trees/copier/ExpressionDeepCopier.java | 2 +-
.../nereids/trees/expressions/ScalarSubquery.java | 22 +-
.../apache/doris/nereids/trees/plans/PlanType.java | 1 +
.../plans/commands/CancelBuildIndexCommand.java | 106 ++
.../plans/commands/CreateFunctionCommand.java | 82 ++
.../commands/CreateMaterializedViewCommand.java | 44 +-
.../plans/commands/DropWorkloadGroupCommand.java | 29 +-
.../nereids/trees/plans/commands/ShowCommand.java | 25 +
.../trees/plans/commands/ShowLoadCommand.java | 11 +-
.../trees/plans/commands/ShowResourcesCommand.java | 10 +-
.../trees/plans/commands/info/BaseViewInfo.java | 14 +-
.../nereids/trees/plans/logical/LogicalJoin.java | 17 +-
.../trees/plans/visitor/CommandVisitor.java | 5 +
.../plans/visitor/ExpressionLineageReplacer.java | 27 +-
.../apache/doris/planner/MaterializationNode.java | 5 +
.../java/org/apache/doris/qe/ConnectContext.java | 2 +-
.../{ConnectScheduler.java => ConnectPoolMgr.java} | 82 +-
.../java/org/apache/doris/qe/ConnectScheduler.java | 174 ++--
.../java/org/apache/doris/qe/SessionVariable.java | 9 +
.../workloadgroup/BindWgToComputeGroupThread.java | 122 ---
.../workloadgroup/WorkloadGroupChecker.java | 50 +
.../resource/workloadgroup/WorkloadGroupMgr.java | 155 ++-
.../java/org/apache/doris/service/ExecuteEnv.java | 2 +-
.../arrowflight/DorisFlightSqlProducer.java | 49 +-
.../service/arrowflight/DorisFlightSqlService.java | 12 +-
.../sessions/FlightSessionsManager.java | 7 +
.../sessions/FlightSessionsWithTokenManager.java | 22 +-
.../sessions/FlightSqlConnectContext.java | 15 +-
.../sessions/FlightSqlConnectPoolMgr.java | 74 ++
.../arrowflight/tokens/FlightTokenManagerImpl.java | 18 +-
.../apache/doris/catalog/CreateEncryptKeyTest.java | 2 +-
.../apache/doris/catalog/CreateFunctionTest.java | 1 +
.../apache/doris/common/util/LocationPathTest.java | 74 ++
.../org/apache/doris/mtmv/MTMVRewriteUtilTest.java | 41 +-
.../apache/doris/mysql/ConnectionExceedTest.java | 31 +-
.../doris/nereids/memo/StructInfoMapTest.java | 10 +-
.../doris/nereids/mv/IdStatisticsMapTest.java | 3 +-
.../nereids/mv/MtmvCacheNewConnectContextTest.java | 6 +-
.../doris/nereids/mv/MvTableIdIsLongTest.java | 4 +-
.../nereids/mv/OptimizeGetAvailableMvsTest.java | 271 +++++
.../properties/RequestPropertyDeriverTest.java | 104 ++
.../rules/analysis/AnalyzeWhereSubqueryTest.java | 1 +
.../rules/analysis/FillUpMissingSlotsTest.java | 7 +
.../exploration/mv/PartitionCompensatorTest.java | 187 ++++
.../rules/rewrite/OperativeColumnDeriveTest.java | 2 +
.../PushDownExpressionsInHashConditionTest.java | 83 ++
.../commands/CancelBuildIndexCommandTest.java | 87 ++
.../plans/commands/KillConnectionCommandTest.java | 2 +-
.../trees/plans/commands/ShowLoadCommandTest.java | 22 +
.../org/apache/doris/nereids/util/PlanChecker.java | 12 +-
.../apache/doris/utframe/TestWithFeService.java | 3 +-
fe/pom.xml | 2 +-
generated-source.sh | 2 +-
.../create_view_nereids_fix_null.out | Bin 0 -> 153 bytes
.../hive/test_hive_meta_cache.out | Bin 858 -> 1649 bytes
.../cloud/test_cloud_concurrent_calc_dbm_task.out | Bin 0 -> 267 bytes
.../test_cloud_full_compaction_multi_segments.out} | Bin 204 -> 168 bytes
.../mtmv_p0/test_base_replace_on_commit_mtmv.out | Bin 342 -> 349 bytes
.../data/mtmv_p0/test_modify_data_mtmv.out | Bin 0 -> 136 bytes
.../subquery/correlated_scalar_subquery.out | Bin 693 -> 736 bytes
.../infer_predicate/pull_up_predicate_literal.out | Bin 78088 -> 102268 bytes
.../partition_mv_rewrite.out | Bin 2856 -> 4048 bytes
.../unioin_rewrite_grace_big.out} | Bin 2856 -> 3997 bytes
.../data/point_query_p0/test_point_query.out | Bin 9896 -> 9920 bytes
.../set_operations/set_with_null/set_with_null.out | Bin 0 -> 123 bytes
.../array_functions/test_array_map_function.out | Bin 2417 -> 2522 bytes
.../cast_function/test_cast_struct.out | Bin 496 -> 513 bytes
.../string_functions/test_xpath_string.out | Bin 1850 -> 2048 bytes
.../data/variant_p0/array_with_predicate.out | Bin 0 -> 261 bytes
.../org/apache/doris/regression/suite/Suite.groovy | 35 +
.../pipeline/cloud_p0/conf/fe_custom.conf | 2 +-
regression-test/pipeline/cloud_p0/deploy.sh | 2 -
regression-test/pipeline/common/doris-utils.sh | 10 -
regression-test/pipeline/p0/conf/fe.conf | 2 +-
regression-test/pipeline/vault_p0/deploy.sh | 2 -
regression-test/plugins/plugin_compaction.groovy | 2 +-
.../compaction/test_full_compaction_status.groovy | 153 +++
.../create_view_nereids_fix_null.groovy | 57 ++
.../suites/ddl_p0/test_alias_function.groovy | 7 +
.../hive/test_hive_meta_cache.groovy | 67 ++
.../test_cloud_concurrent_calc_dbm_task.groovy | 165 +++
...est_cloud_full_compaction_multi_segments.groovy | 181 ++++
.../inverted_index_p0/test_is_null_expr.groovy | 67 ++
.../load_p0/routine_load/test_routine_load.groovy | 16 +-
.../test_base_add_col_multi_level_mtmv.groovy | 30 +-
..._base_alter_col_comment_multi_level_mtmv.groovy | 24 +-
...est_base_alter_col_type_multi_level_mtmv.groovy | 23 +-
.../test_base_comment_multi_level_mtmv.groovy | 23 +-
.../test_base_drop_col_multi_level_mtmv.groovy | 25 +-
.../mtmv_p0/test_base_drop_multi_level_mtmv.groovy | 30 +-
.../test_base_recreate_on_commit_mtmv.groovy | 30 +-
.../test_base_rename_col_multi_level_mtmv.groovy | 24 +-
.../test_base_rename_multi_level_mtmv.groovy | 24 +-
.../test_base_rename_mv_multi_level_mtmv.groovy | 36 +-
.../mtmv_p0/test_base_rename_on_commit_mtmv.groovy | 55 +-
.../test_base_rename_p_mv_multi_level_mtmv.groovy | 26 +-
.../test_base_replace_multi_level_mtmv.groovy | 63 +-
.../test_base_replace_mv_multi_level_mtmv.groovy | 84 +-
.../test_base_replace_on_commit_mtmv.groovy | 45 +-
.../suites/mtmv_p0/test_column_type_mtmv.groovy | 30 +-
.../suites/mtmv_p0/test_modify_data_mtmv.groovy | 14 +-
.../mtmv_p0/test_paimon_olap_rewrite_mtmv.groovy | 2 +-
.../suites/mtmv_p0/test_paimon_rewrite_mtmv.groovy | 2 +-
.../suites/mtmv_p0/test_recreate_table_mtmv.groovy | 37 +-
.../authorization/column_authorization.groovy | 10 +
.../subquery/correlated_scalar_subquery.groovy | 18 +-
.../mv/availability/grace_period.groovy | 4 +-
.../partition_mv_rewrite.groovy | 293 +++---
.../rewrite_duration_exceeded.groovy | 156 +++
.../unioin_rewrite_grace_big.groovy} | 310 +++---
.../suites/point_query_p0/test_point_query.groovy | 7 +
.../set_with_cancel/set_with_cancel.groovy | 249 +++++
.../set_with_null/set_with_null.groovy | 59 +-
.../array_functions/test_array_map_function.groovy | 25 +
.../cast_function/test_cast_struct.groovy | 3 +
.../conditional_functions/test_assert_true.groovy | 79 --
.../conditional_functions/test_json_parse.groovy | 21 +
.../string_functions/test_xpath_string.groovy | 12 +
.../suites/variant_p0/array_with_predicate.groovy | 37 +
.../variant_p0/test_variant_is_null_expr.groovy | 77 ++
samples/arrow-flight-sql/java/pom.xml | 4 +-
thirdparty/vars.sh | 8 +-
tools/clickbench-tools/conf/doris-cluster.conf | 6 +-
287 files changed, 9921 insertions(+), 4328 deletions(-)
delete mode 100644 be/src/gutil/basictypes.h
delete mode 100644 be/src/gutil/dynamic_annotations.c
delete mode 100644 be/src/gutil/dynamic_annotations.h
delete mode 100644 be/src/gutil/stringprintf.cc
delete mode 100644 be/src/gutil/stringprintf.h
delete mode 100644 be/src/olap/selection_vector.h
copy be/src/vec/functions/{is_not_null.cpp => is_not_null.h} (70%)
copy be/src/vec/functions/{is_null.cpp => is_null.h} (71%)
create mode 100644 be/test/cloud/cloud_compaction_test.cpp
create mode 100644 be/test/vec/function/cast/cast_to_decimal.cpp
create mode 100644 be/test/vec/function/cast/cast_to_float_double.cpp
create mode 100644 be/test/vec/function/cast/cast_to_integer.cpp
create mode 100644 be/test/vec/function/function_is_null_test.cpp
create mode 100644 cloud/src/meta-service/delete_bitmap_lock_white_list.cpp
rename be/src/util/debug/sanitizer_scopes.h =>
cloud/src/meta-service/delete_bitmap_lock_white_list.h (55%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/jobs/executor/TablePartitionCollector.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/exploration/mv/PartitionCompensator.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/EliminateMarkJoin.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/PushDownAliasIntoUnionAll.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/QueryPartitionCollector.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/CancelBuildIndexCommand.java
copy fe/fe-core/src/main/java/org/apache/doris/qe/{ConnectScheduler.java =>
ConnectPoolMgr.java} (61%)
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/resource/workloadgroup/BindWgToComputeGroupThread.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/resource/workloadgroup/WorkloadGroupChecker.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/service/arrowflight/sessions/FlightSqlConnectPoolMgr.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/mv/OptimizeGetAvailableMvsTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/rules/exploration/mv/PartitionCompensatorTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/plans/commands/CancelBuildIndexCommandTest.java
create mode 100644
regression-test/data/ddl_p0/create_view_nereids/create_view_nereids_fix_null.out
create mode 100644
regression-test/data/fault_injection_p0/cloud/test_cloud_concurrent_calc_dbm_task.out
rename
regression-test/data/{query_p0/sql_functions/conditional_functions/test_assert_true.out
=> fault_injection_p0/cloud/test_cloud_full_compaction_multi_segments.out}
(53%)
create mode 100644 regression-test/data/mtmv_p0/test_modify_data_mtmv.out
copy regression-test/data/nereids_rules_p0/mv/{ =>
partition_union_rewrite}/partition_mv_rewrite.out (68%)
rename regression-test/data/nereids_rules_p0/mv/{partition_mv_rewrite.out =>
union_rewrite_grace_big/unioin_rewrite_grace_big.out} (69%)
create mode 100644
regression-test/data/query_p0/set_operations/set_with_null/set_with_null.out
create mode 100644 regression-test/data/variant_p0/array_with_predicate.out
create mode 100644
regression-test/suites/compaction/test_full_compaction_status.groovy
create mode 100644
regression-test/suites/ddl_p0/create_view_nereids/create_view_nereids_fix_null.groovy
create mode 100644
regression-test/suites/fault_injection_p0/cloud/test_cloud_concurrent_calc_dbm_task.groovy
create mode 100644
regression-test/suites/fault_injection_p0/cloud/test_cloud_full_compaction_multi_segments.groovy
create mode 100644
regression-test/suites/inverted_index_p0/test_is_null_expr.groovy
copy regression-test/suites/nereids_rules_p0/mv/{ =>
partition_union_rewrite}/partition_mv_rewrite.groovy (68%)
create mode 100644
regression-test/suites/nereids_rules_p0/mv/rewrite_duration_exceeded/rewrite_duration_exceeded.groovy
rename regression-test/suites/nereids_rules_p0/mv/{partition_mv_rewrite.groovy
=> union_rewrite_grace_big/unioin_rewrite_grace_big.groovy} (67%)
create mode 100644
regression-test/suites/query_p0/set_operations/set_with_cancel/set_with_cancel.groovy
rename be/test/olap/selection_vector_test.cpp =>
regression-test/suites/query_p0/set_operations/set_with_null/set_with_null.groovy
(50%)
delete mode 100644
regression-test/suites/query_p0/sql_functions/conditional_functions/test_assert_true.groovy
create mode 100644
regression-test/suites/variant_p0/array_with_predicate.groovy
create mode 100644
regression-test/suites/variant_p0/test_variant_is_null_expr.groovy
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
