This is an automated email from the ASF dual-hosted git repository.
924060929 pushed a change to branch fe_local_shuffle_rebase3
in repository https://gitbox.apache.org/repos/asf/doris.git
discard 9ccb7f30b5f [fix](local shuffle) address /review: TVFScan leaf output
+ Bug 21 timeout
discard 784476ead97 [fix](local shuffle) BE test: post-rename type fixes
(verified by local compile)
discard 9f33ce47e1b [fix](local shuffle) remove serial-without-LE validation
discard a900f9b6c80 [fix](local shuffle) serial validation throw to warn;
null-safe force_passthrough
discard fdd3c400381 [opt](local shuffle) single topological sweep for pipeline
num_tasks
discard d9b6ef638b6 [fix](local shuffle) address review comments on PR #63366
discard e778fee303a [fix](build) macOS: python UDF boost/process via compat
shim; clang-format + license header
discard 133762c5c88 [fix](local shuffle) convert remaining ExchangeType refs
to TLocalPartitionType after rebase
discard 083be352f85 [fix](local shuffle) fall back to LOCAL hash for serial
source in PARTITIONED join/intersect
discard f274f123fef [test](local shuffle) add DORIS-26103 regression: UNION
ALL + PartitionTopN + INTERSECT
discard 9330c3ad714 [test](local shuffle) regression tests for
DORIS-26100/26101 global hash require
discard c2a86e952a2 [fix](local shuffle) Intersect/Except:
requireGlobalExecutionHash instead of autoRequireHash
discard 3aafb3c17d4 [fix](local shuffle) PARTITIONED hash join:
requireGlobalExecutionHash instead of requireHash
discard 23701ff83e0 [test](local shuffle) update
LocalShuffleNodeCoverageTest.testRepeatNode for noRequire fix
discard dde70be7a23 [test](local shuffle) cover RepeatNode noRequire +
return-child-distribution behaviors
discard eac6dcd0045 [fix](local shuffle) RepeatNode: stop forwarding hash
require below repeat
discard caacdb944a4 [fix](local shuffle) Route to NereidsCoordinator based on
distributedPlans
discard 680b10b2682 [doc](local shuffle) DANGER ZONE on sender_count to
prevent repeated mistakes
discard 7c9f4961369 [revert](local shuffle) Roll back the sender_count
std::max patch
discard db4bf139300 [fix](local shuffle) Mirror BE partition_exprs and
sender_count for FE-planned LE
discard 3cf5d30598f [test](local shuffle) Switch order-sensitive checks to
order_qt_*
discard b4ad8863c99 [fix](local shuffle) Skip LocalExchange under
RecursiveCteNode and mark it serial (DORIS-25865)
discard ee114aea7cd [fix](local shuffle) Restore LoadStatistic fileNum
tracking under FE local-shuffle planner
discard 428eeb977ee [test](local shuffle) Drop stats-sensitive shape
assertions from test_multilevel_join_agg_local_shuffle
discard 41e2492989f [test](local shuffle) Rewrite LocalExchangePlannerTest
with PlanShape DSL
discard 2493edcd2e8 [refactor](local shuffle) Move local exchange planning
from BE to FE
add 4e0dad7a78a [fix](broker) Fix broker OOM caused by file system netty
thread pool leak (issue #64138) (#64224)
add 1526741ebc8 [fix](cloud) Refresh base tablet before schema change V1
(#64312)
add d9a53860d2c [refactor](fe) Remove FE session variables sent to BE but
unused by BE (#64285)
add c0abfa4083f [fix](mtmv) Refresh MTMV after excluded trigger tables
change (#64041)
add 3228a69fd23 [fix](fe) Fix NereidsCoordinator not created in proxy flow
due to missing parsedStatement on StatementContext (#64363)
add 8c9e95238e8 [refactor](be) Update column nullable semantics (#64407)
add 04bf5f6217b [Imporve](p0) Add doc example p0 (#64282)
add a20a0df0652 [chore](skill) Add nullable handling AI review rules
(#64442)
add a53679b4dce [fix](load) fix empty statistics for forwarded INSERT
(#64439)
add 7e524a100c5 [fix](load) fix load_to_single_tablet routing for auto
partition (#64356)
add 059f56dcf27 [fix](fe) Reject multi-column NGRAM_BF indexes (#64343)
add d3267dab250 [fix](fe) Detect Doris-compatible MySQL JDBC targets
(#64389)
add 4a99226a1c5 [feat](dynamic table) support table stream part 3:
docking olap table stream with binlog (#63850)
add c33e1b3cfd7 [fix](delta writer) Fix shared delta writer state lifetime
(#64349)
add 85f3e1bc3ee [fix](nereids) bind file column placeholders for copy into
select (#64395)
add c0497eb0cf9 [improvement](fe) Short-circuit catalog/db/table privilege
check when global privilege is granted (#63838)
add c7874e47f30 [improvement](fe) Add configurable interval for catalog
recycle bin daemon thread (#63311)
add c6ba5357add [Fix](ut) Include UDF and OLAP BE tests (#64448)
add 4dda859061c [opt](csv reader) optimize nullable string deserialization
in CSV/text load hot path (#64476)
add 1a23a77d941 [fix](ddl) reject invalid IPv4 default value at CREATE
TABLE time (#62906)
add 255cbd37e57 [refactor](local shuffle) Move local exchange planning
from BE to FE
add ea36b9b6f27 [test](local shuffle) Rewrite LocalExchangePlannerTest
with PlanShape DSL
add d360904ba7f [test](local shuffle) Drop stats-sensitive shape
assertions from test_multilevel_join_agg_local_shuffle
add 8f83192f42a [fix](local shuffle) Restore LoadStatistic fileNum
tracking under FE local-shuffle planner
add 727d3122f1e [fix](local shuffle) Skip LocalExchange under
RecursiveCteNode and mark it serial (DORIS-25865)
add d5a7b9f30ff [test](local shuffle) Switch order-sensitive checks to
order_qt_*
add cc7cf680d48 [fix](local shuffle) Mirror BE partition_exprs and
sender_count for FE-planned LE
add 151ff1d1778 [revert](local shuffle) Roll back the sender_count
std::max patch
add ef43f96b5fd [doc](local shuffle) DANGER ZONE on sender_count to
prevent repeated mistakes
add f7748e3324f [fix](local shuffle) Route to NereidsCoordinator based on
distributedPlans
add 23d59442ca8 [fix](local shuffle) RepeatNode: stop forwarding hash
require below repeat
add 76b535df6c2 [test](local shuffle) cover RepeatNode noRequire +
return-child-distribution behaviors
add b7de8783739 [test](local shuffle) update
LocalShuffleNodeCoverageTest.testRepeatNode for noRequire fix
add 7ad0d52e3e6 [fix](local shuffle) PARTITIONED hash join:
requireGlobalExecutionHash instead of requireHash
add 31ab99ab14a [fix](local shuffle) Intersect/Except:
requireGlobalExecutionHash instead of autoRequireHash
add db2d37a6097 [test](local shuffle) regression tests for
DORIS-26100/26101 global hash require
add 47421053e50 [test](local shuffle) add DORIS-26103 regression: UNION
ALL + PartitionTopN + INTERSECT
add eaa608631ee [fix](local shuffle) fall back to LOCAL hash for serial
source in PARTITIONED join/intersect
add 79645fd6bc3 [fix](local shuffle) convert remaining ExchangeType refs
to TLocalPartitionType after rebase
add 818dbab57ff [fix](build) macOS: python UDF boost/process via compat
shim; clang-format + license header
add 7ce9d4a2c4b [fix](local shuffle) address review comments on PR #63366
add a97d3347789 [opt](local shuffle) single topological sweep for pipeline
num_tasks
add 57a36a58112 [fix](local shuffle) serial validation throw to warn;
null-safe force_passthrough
add 3630071a131 [fix](local shuffle) remove serial-without-LE validation
add 9e03688df6a [fix](local shuffle) BE test: post-rename type fixes
(verified by local compile)
add 8db568b5100 [fix](local shuffle) address /review: TVFScan leaf output
+ Bug 21 timeout
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 (9ccb7f30b5f)
\
N -- N -- N refs/heads/fe_local_shuffle_rebase3 (8db568b5100)
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:
.claude/skills/code-review/SKILL.md | 9 +
be/src/cloud/cloud_schema_change_job.cpp | 3 +-
be/src/cloud/cloud_tablet.cpp | 12 +
be/src/cloud/pb_convert.cpp | 24 +
be/src/core/block/block.cpp | 5 +-
be/src/core/column/column.h | 4 +-
be/src/core/column/column_const.h | 3 +-
be/src/core/column/column_nullable.h | 1 -
be/src/exec/common/hash_table/hash_map_context.h | 8 +-
be/src/exec/common/join_utils.h | 2 +-
be/src/exec/common/util.hpp | 8 +-
be/src/exec/common/variant_util.cpp | 15 +-
be/src/exec/operator/hashjoin_build_sink.cpp | 27 +-
be/src/exec/operator/hashjoin_probe_operator.cpp | 22 +-
.../operator/join/process_hash_table_probe_impl.h | 4 +-
.../operator/nested_loop_join_probe_operator.cpp | 179 ++---
be/src/exec/operator/olap_scan_operator.cpp | 45 +-
be/src/exec/operator/operator.cpp | 2 +-
be/src/exec/operator/schema_scan_operator.cpp | 4 +-
be/src/exec/operator/table_function_operator.cpp | 6 +-
be/src/exec/scan/file_scanner.cpp | 2 +-
be/src/exec/scan/olap_scanner.cpp | 122 ++-
be/src/exec/scan/olap_scanner.h | 8 +
be/src/exec/scan/parallel_scanner_builder.cpp | 5 +-
be/src/exec/sink/vrow_distribution.cpp | 3 +
be/src/exec/sink/vtablet_block_convertor.cpp | 1 +
.../sink/writer/iceberg/partition_transformers.h | 32 +-
.../sink/writer/iceberg/viceberg_table_writer.cpp | 2 +-
be/src/exec/sink/writer/vtablet_writer_v2.cpp | 13 +-
be/src/exprs/aggregate/aggregate_function_count.h | 2 +-
.../aggregate/aggregate_function_foreachv2.cpp | 2 +-
.../aggregate_function_group_array_set_op.h | 2 +-
be/src/exprs/aggregate/aggregate_function_map.h | 8 +-
be/src/exprs/aggregate/aggregate_function_null.h | 2 +-
.../exprs/aggregate/aggregate_function_null_v2.h | 2 +-
.../aggregate/aggregate_function_percentile.h | 4 +-
.../exprs/aggregate/aggregate_function_retention.h | 2 +-
be/src/exprs/aggregate/aggregate_function_topn.h | 2 +-
be/src/exprs/aggregate/aggregate_function_window.h | 4 +-
be/src/exprs/bloom_filter_func_adaptor.h | 8 +-
.../function/array/function_array_aggregation.cpp | 10 +-
.../exprs/function/array/function_array_apply.cpp | 2 +-
.../function/array/function_array_constructor.cpp | 2 +-
.../exprs/function/array/function_array_count.cpp | 5 +-
.../exprs/function/array/function_array_distance.h | 6 +-
.../exprs/function/array/function_array_distinct.h | 9 +-
.../exprs/function/array/function_array_element.h | 20 +-
.../function/array/function_array_enumerate.cpp | 3 +-
.../array/function_array_enumerate_uniq.cpp | 17 +-
.../array/function_array_first_or_last_index.cpp | 3 +-
be/src/exprs/function/array/function_array_index.h | 20 +-
.../exprs/function/array/function_array_mapped.h | 4 +-
.../function/array/function_array_pushback.cpp | 5 +-
.../function/array/function_array_pushfront.cpp | 3 +-
.../exprs/function/array/function_array_remove.h | 22 +-
.../exprs/function/array/function_array_split.cpp | 9 +-
.../exprs/function/array/function_array_utils.cpp | 14 +-
.../array/function_array_with_constant.cpp | 2 +-
.../exprs/function/array/varray_match_function.cpp | 12 +-
.../exprs/function/complex_hash_map_dictionary.cpp | 2 +-
.../exprs/function/complex_hash_map_dictionary.h | 2 +-
be/src/exprs/function/dictionary.cpp | 2 +-
be/src/exprs/function/dictionary_util.h | 5 +-
be/src/exprs/function/function_collection_in.h | 10 +-
be/src/exprs/function/function_ip.h | 12 +-
be/src/exprs/function/function_jsonb.cpp | 110 ++-
be/src/exprs/function/function_map.cpp | 20 +-
be/src/exprs/function/function_variant_element.cpp | 2 +-
.../function/functions_multi_string_position.cpp | 72 +-
.../function/functions_multi_string_search.cpp | 14 +-
be/src/exprs/function/if.cpp | 5 +-
be/src/exprs/function/in.h | 11 +-
be/src/exprs/function/ip_address_dictionary.cpp | 8 +-
be/src/exprs/hybrid_set.h | 6 +-
.../lambda_function/varray_filter_function.cpp | 4 +-
.../exprs/lambda_function/varray_map_function.cpp | 5 +-
.../exprs/lambda_function/varray_sort_function.cpp | 2 +-
be/src/exprs/minmax_predicate.h | 2 +-
be/src/exprs/table_function/vexplode_map.cpp | 2 +-
be/src/exprs/table_function/vexplode_numbers.cpp | 2 +-
be/src/exprs/vcase_expr.h | 4 +-
be/src/exprs/vcondition_expr.cpp | 5 +-
be/src/exprs/vdirect_in_predicate.h | 8 +-
be/src/format/column_type_convert.h | 16 +-
be/src/format/csv/csv_reader.cpp | 56 +-
be/src/format/csv/csv_reader.h | 5 +
be/src/format/jni/jni_data_bridge.cpp | 10 +-
be/src/format/json/new_json_reader.cpp | 10 +-
be/src/format/orc/vorc_reader.cpp | 12 +-
be/src/format/parquet/parquet_column_convert.h | 12 +-
be/src/format/parquet/vparquet_column_reader.cpp | 10 +-
be/src/format/parquet/vparquet_column_reader.h | 2 +-
be/src/format/table/equality_delete.cpp | 13 +-
be/src/format/text/text_reader.cpp | 26 +-
be/src/format/transformer/vorc_transformer.cpp | 6 +-
be/src/load/delta_writer/delta_writer_v2.cpp | 21 +-
be/src/load/delta_writer/delta_writer_v2.h | 10 +-
be/src/runtime/runtime_state.h | 4 -
be/src/storage/binlog.h | 9 +-
.../storage/iterator/binlog_block_reader_utils.h | 112 +++
be/src/storage/iterator/block_reader.cpp | 341 ++++++++-
be/src/storage/iterator/block_reader.h | 40 +-
be/src/storage/iterator/olap_data_convertor.cpp | 4 +-
be/src/storage/iterator/vcollect_iterator.cpp | 28 +-
be/src/storage/iterator/vcollect_iterator.h | 11 +-
be/src/storage/iterator/vertical_block_reader.cpp | 2 +-
be/src/storage/iterator/vgeneric_iterators.cpp | 14 +-
be/src/storage/iterator/vgeneric_iterators.h | 17 +-
be/src/storage/iterators.h | 1 +
be/src/storage/predicate/bloom_filter_predicate.h | 2 +-
be/src/storage/predicate/comparison_predicate.h | 6 +-
be/src/storage/predicate/in_list_predicate.h | 4 +-
be/src/storage/predicate/like_column_predicate.cpp | 2 +-
be/src/storage/predicate/like_column_predicate.h | 2 +-
be/src/storage/rowset/beta_rowset_reader.cpp | 16 +-
be/src/storage/rowset/beta_rowset_reader.h | 5 +-
be/src/storage/rowset/rowset_reader_context.h | 1 +
be/src/storage/schema_change/schema_change.cpp | 116 +--
be/src/storage/segment/column_reader.cpp | 36 +-
.../storage/segment/historical_row_retriever.cpp | 10 +-
.../storage/segment/row_binlog_segment_writer.cpp | 23 +-
be/src/storage/segment/segment.cpp | 35 +
be/src/storage/segment/segment.h | 8 +
be/src/storage/segment/segment_iterator.cpp | 22 +-
.../variant/binary_column_extract_iterator.h | 2 +-
.../segment/variant/hierarchical_data_iterator.cpp | 10 +-
.../segment/variant/hierarchical_data_iterator.h | 2 +-
.../segment/variant/variant_column_reader.cpp | 23 +-
be/src/storage/tablet/tablet_reader.cpp | 1 +
be/src/storage/tablet/tablet_reader.h | 7 +
be/src/storage/tablet/tablet_schema.cpp | 14 +
be/src/storage/tablet/tablet_schema.h | 4 +
be/src/storage/utils.h | 2 +
be/test/CMakeLists.txt | 2 +
be/test/cloud/cloud_schema_change_job_test.cpp | 78 ++
be/test/core/column/column_const_test.cpp | 35 +-
be/test/exec/scan/vgeneric_iterators_test.cpp | 43 ++
be/test/exec/sink/vtablet_writer_v2_test.cpp | 218 ++++++
be/test/exprs/function/function_jsonb_test.cpp | 46 ++
.../delta_writer/delta_writer_v2_pool_test.cpp | 13 +-
.../iterator/binlog_block_reader_utils_test.cpp | 66 ++
.../iterator/block_reader_min_delta_test.cpp | 138 ++++
.../predicate/block_column_predicate_test.cpp | 68 ++
be/test/udf/python/python_server_test.cpp | 21 +-
be/test/udf/python/python_udf_runtime_test.cpp | 9 +-
.../org/apache/doris/analysis/IPv4Literal.java | 34 +-
.../main/java/org/apache/doris/common/Config.java | 24 +-
.../jdbc/client/JdbcMySQLConnectorClient.java | 15 +-
.../jdbc/client/JdbcMySQLConnectorClientTest.java | 41 +
.../apache/doris/alter/SchemaChangeHandler.java | 2 -
.../org/apache/doris/catalog/BinlogConfig.java | 4 +
.../apache/doris/catalog/CatalogRecycleBin.java | 3 +-
.../java/org/apache/doris/catalog/Database.java | 5 +
.../main/java/org/apache/doris/catalog/Env.java | 13 +-
.../java/org/apache/doris/catalog/EnvFactory.java | 2 +-
.../main/java/org/apache/doris/catalog/MTMV.java | 47 +-
.../java/org/apache/doris/catalog/OlapTable.java | 30 +-
.../org/apache/doris/catalog/OlapTableWrapper.java | 15 +
.../java/org/apache/doris/catalog/Partition.java | 21 +-
.../doris/catalog/RowBinlogTableWrapper.java | 23 +
.../java/org/apache/doris/catalog/TableIf.java | 6 +
.../org/apache/doris/catalog/TableProperty.java | 13 -
.../doris/catalog/stream/BaseTableStream.java | 38 +-
.../doris/catalog/stream/OlapTableStream.java | 100 ++-
.../catalog/stream/OlapTableStreamWrapper.java | 38 +
.../doris/catalog/stream/TableStreamManager.java | 196 ++++-
.../cloud/alter/CloudSchemaChangeHandler.java | 3 -
.../doris/cloud/catalog/CloudEnvFactory.java | 2 +-
.../apache/doris/cloud/qe/CloudCoordinator.java | 5 +
.../transaction/CloudGlobalTransactionMgr.java | 5 +
.../apache/doris/common/util/PropertyAnalyzer.java | 31 +-
.../apache/doris/datasource/InternalCatalog.java | 18 +-
.../datasource/jdbc/client/JdbcMySQLClient.java | 15 +-
.../apache/doris/job/extensions/mtmv/MTMVTask.java | 5 +
.../org/apache/doris/journal/JournalEntity.java | 6 +
.../mysql/privilege/CatalogAccessController.java | 27 +-
.../glue/translator/PhysicalPlanTranslator.java | 38 +-
.../doris/nereids/jobs/executor/Rewriter.java | 15 +-
.../doris/nereids/rules/analysis/BindRelation.java | 160 +++-
.../LogicalOlapScanToPhysicalOlapScan.java | 4 +-
.../rewrite/NormalizeOlapTableStreamScan.java | 191 ++++-
.../nereids/rules/rewrite/PruneOlapScanTablet.java | 5 +
.../trees/plans/commands/info/CopyFromDesc.java | 33 +-
.../trees/plans/commands/info/CopyIntoInfo.java | 105 ++-
.../trees/plans/commands/info/IndexDefinition.java | 5 +-
.../commands/info/ModifyTablePropertiesOp.java | 16 -
.../commands/insert/InsertIntoTableCommand.java | 21 +-
.../trees/plans/logical/LogicalOlapScan.java | 122 ++-
.../plans/logical/LogicalOlapTableStreamScan.java | 196 +++--
.../trees/plans/physical/PhysicalOlapScan.java | 36 +-
.../java/org/apache/doris/persist/EditLog.java | 10 +
.../org/apache/doris/persist/OperationType.java | 2 +
.../doris/persist/TableStreamCleanupInfo.java | 107 +++
.../org/apache/doris/planner/OlapScanNode.java | 120 ++-
.../main/java/org/apache/doris/qe/Coordinator.java | 107 +++
.../org/apache/doris/qe/NereidsCoordinator.java | 2 +
.../java/org/apache/doris/qe/SessionVariable.java | 140 +---
.../java/org/apache/doris/qe/StmtExecutor.java | 10 +
.../main/java/org/apache/doris/qe/VariableMgr.java | 8 +-
.../apache/doris/service/FrontendServiceImpl.java | 62 +-
.../transaction/AutoPartitionCacheManager.java | 32 +-
.../doris/transaction/DatabaseTransactionMgr.java | 50 +-
.../doris/transaction/GlobalTransactionMgr.java | 5 +
.../transaction/GlobalTransactionMgrIface.java | 2 +
.../doris/transaction/PartitionCommitInfo.java | 18 +-
.../main/java/org/apache/doris/tso/TSOService.java | 26 +-
.../java/org/apache/doris/tso/TSOTimestamp.java | 14 +
.../doris/catalog/CreateTableStreamTest.java | 14 +-
.../apache/doris/catalog/DropTableStreamTest.java | 6 +-
.../stream/TableStreamManagerCleanupTest.java | 208 +++++
.../jdbc/client/JdbcMySQLClientTest.java | 37 +
.../java/org/apache/doris/mtmv/MTMVTaskTest.java | 30 +
.../test/java/org/apache/doris/mtmv/MTMVTest.java | 105 +++
.../privilege/CatalogAccessControllerTest.java | 258 +++++++
.../doris/nereids/parser/NereidsParserTest.java | 77 ++
.../trees/expressions/literal/IPV4LiteralTest.java | 100 +++
.../trees/plans/ExplainTableStreamPlanTest.java | 231 +++++-
.../trees/plans/commands/IndexDefinitionTest.java | 15 +
.../InsertIntoTableCommandTableStreamTest.java | 210 ++++-
.../org/apache/doris/qe/SessionVariablesTest.java | 12 -
.../java/org/apache/doris/qe/StmtExecutorTest.java | 38 +
.../apache/doris/qe/WaitForChangeVisibleTest.java | 204 +++++
.../transaction/AutoPartitionCacheManagerTest.java | 61 ++
.../transaction/DatabaseTransactionMgrTest.java | 35 +-
.../TableStreamOffsetTransactionTest.java | 15 +-
.../java/org/apache/doris/tso/TSOServiceTest.java | 116 ++-
.../org/apache/doris/broker/hdfs/BrokerConfig.java | 9 +-
.../apache/doris/broker/hdfs/BrokerFileSystem.java | 48 +-
.../doris/broker/hdfs/ClientContextManager.java | 88 +--
.../doris/broker/hdfs/FileSystemManager.java | 313 ++++----
gensrc/proto/olap_file.proto | 12 +
gensrc/thrift/FrontendService.thrift | 4 +
gensrc/thrift/PaloInternalService.thrift | 6 +-
gensrc/thrift/PlanNodes.thrift | 11 +
.../doc_ai_distance_functions_test.out} | 10 +-
.../sql-functions/doc_array_functions_test.out | 145 ++++
.../sql-functions/doc_bitmap_functions_test.out | 13 +
.../sql-functions/doc_json_functions_test.out | 64 ++
.../sql-functions/doc_numeric_functions_test.out} | 11 +-
.../sql-functions/doc_string_functions_test.out | 187 +++++
.../data/mtmv_p0/test_create_mtmv_with_view.out | 3 +-
.../mtmv_p0/test_excluded_trigger_table_mtmv.out | 6 +
.../test_stream_consumption_schema.out | 20 +-
.../schema_table/test_stream_info_schema.out | 2 +-
.../data/query_p0/system/test_table_properties.out | 9 +-
.../data/row_binlog_p0/test_row_binlog_basic.out | 3 +-
.../test_olap_table_stream_history_consumption.out | 20 +-
.../cloud_p0/conf/regression-conf-custom.groovy | 2 +
.../pipeline/nonConcurrent/conf/fe.conf | 3 +-
...c_compaction_cross_v1_stale_base_refresh.groovy | 158 ++++
.../doc_ai_distance_functions_test.groovy | 23 +-
.../sql-functions/doc_array_functions_test.groovy | 400 ++++++++++
.../doc_bitmap_functions_test.groovy} | 36 +-
.../sql-functions/doc_json_functions_test.groovy | 165 ++++
.../doc_numeric_functions_test.groovy | 26 +-
.../sql-functions/doc_string_functions_test.groovy | 457 +++++++++++
.../index_p0/test_ngram_bloomfilter_index.groovy | 37 +
.../suites/load_p0/copy_into/test_copy_into.groovy | 65 ++
.../test_excluded_trigger_table_mtmv.groovy | 6 +-
.../test_stream_consumption_schema.groovy | 20 +-
.../schema_table/test_stream_info_schema.groovy | 27 +-
.../test_binlog_changes_syntax.groovy | 641 ++++++++++++++++
.../row_binlog_p0/test_binlog_compaction.groovy | 12 +-
.../row_binlog_p0/test_row_binlog_basic.groovy | 14 +-
.../test_row_binlog_multi_segment.groovy | 3 +-
.../test_row_binlog_publish_conflict.groovy | 3 +-
.../test_row_binlog_schema_change.groovy | 3 +-
.../table_stream_p0/test_min_delta_stream.groovy | 842 +++++++++++++++++++++
...st_olap_table_stream_history_consumption.groovy | 63 +-
.../test_olap_table_stream_history_query.groovy | 16 +-
regression-test/suites/tso_p0/test_tso_api.groovy | 3 +-
.../tso_p0/test_tso_rowset_commit_tso.groovy | 8 +-
272 files changed, 9520 insertions(+), 1692 deletions(-)
create mode 100644 be/src/storage/iterator/binlog_block_reader_utils.h
create mode 100644 be/test/storage/iterator/binlog_block_reader_utils_test.cpp
create mode 100644 be/test/storage/iterator/block_reader_min_delta_test.cpp
create mode 100644
fe/fe-connector/fe-connector-jdbc/src/test/java/org/apache/doris/connector/jdbc/client/JdbcMySQLConnectorClientTest.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/persist/TableStreamCleanupInfo.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/catalog/stream/TableStreamManagerCleanupTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/jdbc/client/JdbcMySQLClientTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/mysql/privilege/CatalogAccessControllerTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/expressions/literal/IPV4LiteralTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/qe/WaitForChangeVisibleTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/transaction/AutoPartitionCacheManagerTest.java
copy regression-test/data/{ann_index_p0/ivf_pq_recall.out =>
doc/sql-manual/sql-functions/doc_ai_distance_functions_test.out} (53%)
create mode 100644
regression-test/data/doc/sql-manual/sql-functions/doc_array_functions_test.out
create mode 100644
regression-test/data/doc/sql-manual/sql-functions/doc_bitmap_functions_test.out
create mode 100644
regression-test/data/doc/sql-manual/sql-functions/doc_json_functions_test.out
copy regression-test/data/{correctness_p0/test_cast_null.out =>
doc/sql-manual/sql-functions/doc_numeric_functions_test.out} (59%)
create mode 100644
regression-test/data/doc/sql-manual/sql-functions/doc_string_functions_test.out
create mode 100644
regression-test/suites/cloud_p1/schema_change/compaction_optimization/test_sc_compaction_cross_v1_stale_base_refresh.groovy
copy be/src/common/check.cpp =>
regression-test/suites/doc/sql-manual/sql-functions/doc_ai_distance_functions_test.groovy
(64%)
create mode 100644
regression-test/suites/doc/sql-manual/sql-functions/doc_array_functions_test.groovy
copy regression-test/suites/{nereids_syntax_p0/timestamp.groovy =>
doc/sql-manual/sql-functions/doc_bitmap_functions_test.groovy} (53%)
create mode 100644
regression-test/suites/doc/sql-manual/sql-functions/doc_json_functions_test.groovy
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/shape/UnaryExpression.java
=>
regression-test/suites/doc/sql-manual/sql-functions/doc_numeric_functions_test.groovy
(68%)
create mode 100644
regression-test/suites/doc/sql-manual/sql-functions/doc_string_functions_test.groovy
create mode 100644
regression-test/suites/row_binlog_p0/test_binlog_changes_syntax.groovy
create mode 100644
regression-test/suites/table_stream_p0/test_min_delta_stream.groovy
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
