This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a change to branch auto-pick-61895-branch-4.1
in repository https://gitbox.apache.org/repos/asf/doris.git
discard fa0b65e454d [Refactor](variant) Promote enable_doc_mode from
column-level to type-level (#61895)
add 8a2212fc9a8 [Feature](cte) support recursive cte fe part (#61283)
add 37b33dfd0d2 branch-4.1: [feat](http) Add sync and export cloud meta
API #60739 (#61572)
add 54d492c59ae branch-4.1: [Enhancement](mmhash) Support mmhash3_u64_v2
#61846 (#61925)
add 132b50b370e branch-4.1: [fix](docker): Fix Hive3 docker OSS
configuration to use Jindo fs #61822 (#61927)
add 39b8b2833cf [emhancement](compaction) disable compaction pause on high
memory by default (#61937)
add f985b998149 branch-4.1: [feat](cloud) drop instance should recycle the
ancestors #61882 (#61933)
add 24d67c8291d branch-4.1: [fix](fe) Fix Paimon JDBC driver registration
for JNI scans (#61513) (#61923)
add 6dce768caab branch-4.1: [env](compiler) Reduce template instantiations
in predicate_creator.h for faster compilation #61858 (#61934)
add 2ccd3cbd02a [fix](regression) Use in-network MinIO endpoint for paimon
JDBC seed (#61932)
add c49e88bf829 branch-4.1: pick some group commit prs(#60652)(#61555)
(#61953)
add d90507793b5 branch-4.1: [fix](datetime) Replace legacy from_date_str
with cast function (#61944)
add fa9e7f57620 branch-4.1:[test](mtmv) Inject stats to external table to
make external table case stable (#59721) (#61936)
add ada60be45b2 [fix](parquet) Don't decompress dict page when dict page
is empty (#6… (#61857)
add 2059fcf4f8c branch-4.1: [Opt](cloud) Add segment prefetcher #59482
#60870 (#61421)
add 5ded66dc406 branch-4.1: [fix](auto-partition) Register auto-partition
tables with retention_count in DynamicPartitionScheduler on restart #61954
(#61972)
add fe860299e7c branch-4.1: [Feature](streamjob) Streaming job support
cdc_stream TVF #61826 (#61970)
add d90ac33b91d [Improvement](scan) Update scanner limit controller
(#61617) (#61962)
add b387fb96de7 branch-4.1: [pick] Cherry-pick #60520 #60239 #60310
(#61921)
add d53f6f23633 [opt](s3) Skip S3 listing for deterministic file paths
using HEAD requests (#60414) (#61776)
add 1217886d675 branch-4.1: [Improvement](function) support window funnel
v2 #61566 (#61935)
add 49f280996da [Refactor](variant) Promote enable_doc_mode from
column-level to type-level (#61895) (#61950)
add ce38996f934 branch-4.1: [test](fe) Refine manual REST catalog test
fixtures #61948 (#61977)
add 9e8790f80c1 branch-4.1: [fix](build) Fix JindoFS jar packaging #61940
(#61978)
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 (fa0b65e454d)
\
N -- N -- N refs/heads/auto-pick-61895-branch-4.1 (9e8790f80c1)
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_cluster_info.cpp | 201 ++++
be/src/cloud/cloud_cluster_info.h | 78 +-
be/src/cloud/cloud_meta_mgr.cpp | 39 +-
be/src/cloud/cloud_meta_mgr.h | 6 +
be/src/cloud/cloud_tablet.h | 20 +
be/src/cloud/cloud_tablet_mgr.cpp | 9 +-
be/src/cloud/config.cpp | 11 +
be/src/cloud/config.h | 11 +
be/src/common/config.cpp | 28 +-
be/src/common/config.h | 19 +
be/src/common/status.h | 11 +
be/src/core/data_type/data_type_date.cpp | 16 +
be/src/core/data_type/data_type_date.h | 11 +-
.../data_type/data_type_date_or_datetime_v2.cpp | 31 +
.../core/data_type/data_type_date_or_datetime_v2.h | 25 +-
be/src/core/data_type/data_type_date_time.cpp | 16 +
be/src/core/data_type/data_type_date_time.h | 11 +-
be/src/core/data_type/data_type_timestamptz.cpp | 4 +-
.../data_type_date_or_datetime_serde.cpp | 72 +-
.../data_type_serde/data_type_datetimev2_serde.cpp | 27 +-
.../data_type_serde/data_type_datev2_serde.cpp | 25 +-
.../core/data_type_serde/data_type_time_serde.cpp | 26 +-
.../data_type_timestamptz_serde.cpp | 12 +-
be/src/core/memcmp_small.h | 12 +-
be/src/core/value/ip_address_cidr.h | 2 +-
be/src/core/value/timestamptz_value.cpp | 25 +-
be/src/core/value/timestamptz_value.h | 2 +
be/src/core/value/vdatetime_value.cpp | 48 -
be/src/core/value/vdatetime_value.h | 17 -
be/src/exec/common/ipv6_to_binary.h | 2 +-
be/src/exec/es/es_scroll_parser.cpp | 29 +-
be/src/exec/operator/olap_scan_operator.cpp | 2 +
be/src/exec/operator/olap_scan_operator.h | 1 +
be/src/exec/operator/scan_operator.cpp | 13 +-
be/src/exec/operator/scan_operator.h | 4 +
.../exec/runtime_filter/runtime_filter_wrapper.cpp | 13 +-
be/src/exec/scan/scanner.cpp | 2 +
be/src/exec/scan/scanner_context.cpp | 44 +-
be/src/exec/scan/scanner_context.h | 8 +-
be/src/exec/scan/scanner_scheduler.cpp | 32 +-
.../sink/writer/iceberg/partition_transformers.h | 10 +-
.../aggregate_function_simple_factory.cpp | 2 +
.../aggregate/aggregate_function_window_funnel.cpp | 3 +-
.../aggregate/aggregate_function_window_funnel.h | 2 +-
...cpp => aggregate_function_window_funnel_v2.cpp} | 28 +-
.../aggregate_function_window_funnel_v2.h | 613 ++++++++++
be/src/exprs/function/cast/cast_base.h | 19 +
.../cast/cast_to_date_or_datetime_impl.hpp | 103 +-
.../function/cast/cast_to_datetimev2_impl.hpp | 100 +-
be/src/exprs/function/cast/cast_to_datev2_impl.hpp | 42 +-
be/src/exprs/function/cast/cast_to_time_impl.hpp | 51 +-
be/src/exprs/function/cast/cast_to_timestamptz.h | 14 +-
.../function/cast/cast_to_timestamptz_impl.hpp | 83 ++
be/src/exprs/function/function_hash.cpp | 9 +-
be/src/exprs/function/url/find_symbols.h | 2 +-
be/src/format/parquet/byte_array_dict_decoder.cpp | 12 +-
be/src/format/parquet/byte_array_dict_decoder.h | 3 +-
be/src/format/parquet/decoder.h | 3 +-
be/src/format/parquet/fix_length_dict_decoder.hpp | 13 +-
.../parquet/vparquet_column_chunk_reader.cpp | 20 +-
.../format/parquet/vparquet_column_chunk_reader.h | 2 +-
be/src/format/parquet/vparquet_column_reader.cpp | 2 +-
be/src/format/parquet/vparquet_column_reader.h | 6 +-
be/src/format/parquet/vparquet_group_reader.cpp | 23 +-
be/src/format/parquet/vparquet_group_reader.h | 2 +-
be/src/format/parquet/vparquet_page_reader.h | 1 +
be/src/format/table/paimon_cpp_reader.cpp | 9 +-
be/src/format/table/paimon_jni_reader.cpp | 11 +-
.../schema_processlist_scanner.cpp | 6 +-
be/src/information_schema/schema_scanner.cpp | 5 +-
be/src/io/cache/block_file_cache.cpp | 3 +
be/src/io/cache/cached_remote_file_reader.cpp | 139 ++-
be/src/io/cache/cached_remote_file_reader.h | 15 +-
be/src/io/fs/s3_file_reader.cpp | 3 +
be/src/runtime/exec_env.h | 3 +
be/src/runtime/exec_env_init.cpp | 17 +
be/src/runtime/runtime_state.cpp | 11 +-
be/src/service/doris_main.cpp | 4 +
be/src/storage/delete/delete_handler.cpp | 1 +
be/src/storage/index/ordinal_page_index.h | 3 +-
be/src/storage/olap_common.h | 1 +
be/src/storage/predicate/predicate_creator.cpp | 5 +
be/src/storage/predicate/predicate_creator.h | 252 +----
.../predicate/predicate_creator_comparison.cpp | 153 +++
.../predicate/predicate_creator_in_list_in.cpp | 166 +++
.../predicate/predicate_creator_in_list_not_in.cpp | 166 +++
be/src/storage/segment/column_reader.cpp | 124 +++
be/src/storage/segment/column_reader.h | 40 +
be/src/storage/segment/page_io.cpp | 4 +
be/src/storage/segment/segment_iterator.cpp | 94 ++
be/src/storage/segment/segment_iterator.h | 2 +
be/src/storage/segment/segment_prefetcher.cpp | 262 +++++
be/src/storage/segment/segment_prefetcher.h | 154 +++
.../segment/variant/hierarchical_data_iterator.cpp | 33 +
.../segment/variant/hierarchical_data_iterator.h | 5 +
.../segment/variant/variant_column_reader.cpp | 10 +
.../segment/variant/variant_column_reader.h | 5 +
be/src/storage/tablet_info.cpp | 32 +-
be/src/storage/task/engine_batch_load_task.h | 6 +-
be/src/storage/task/engine_clone_task.h | 4 +-
be/src/util/concurrency_stats.cpp | 130 +++
be/src/util/concurrency_stats.h | 127 +++
be/src/util/date_func.cpp | 2 +-
be/src/util/io_helper.cpp | 46 +-
be/src/util/io_helper.h | 21 +-
be/test/cloud/cloud_cluster_info_test.cpp | 280 +++++
.../data_type_serde/data_type_serde_arrow_test.cpp | 7 +-
.../data_type_serde_datelike_batch_test.cpp | 454 ++++++++
.../utils/arrow_column_to_doris_column_test.cpp | 30 +-
be/test/core/value/vdatetime_value_test.cpp | 49 +-
be/test/exec/scan/scanner_context_test.cpp | 29 +-
.../parquet_scanner/test_string_null.zst.parquet | Bin 0 -> 925 bytes
.../exprs/aggregate/vec_window_funnel_v2_test.cpp | 1167 ++++++++++++++++++++
be/test/exprs/bloom_filter_func_test.cpp | 7 +-
.../function/cast/cast_to_string_api_test.cpp | 29 +-
be/test/exprs/function/function_test_util.cpp | 27 +-
be/test/exprs/minmax_predicate_test.cpp | 16 +-
be/test/exprs/vexpr_test.cpp | 65 +-
.../format/orc/orc_convert_to_orc_literal_test.cpp | 64 +-
.../byte_array_dict_decoder_empty_dict_test.cpp | 53 +
.../parquet/byte_array_dict_decoder_test.cpp | 4 +-
.../fix_length_dict_decoder_empty_dict_test.cpp | 59 +
.../parquet/fix_length_dict_decoder_test.cpp | 4 +-
be/test/format/parquet/parquet_reader_test.cpp | 537 ++++++++-
.../delta_writer/delta_writer_cluster_key_test.cpp | 8 +-
be/test/load/delta_writer/delta_writer_test.cpp | 49 +-
be/test/storage/segment/segment_cache_test.cpp | 8 +-
be/test/storage/tablet/tablet_cooldown_test.cpp | 8 +-
build.sh | 25 +-
cloud/src/common/bvars.cpp | 45 +
cloud/src/common/bvars.h | 27 +-
cloud/src/meta-service/meta_service.h | 11 +
cloud/src/meta-service/meta_service_resource.cpp | 260 ++++-
cloud/src/meta-service/meta_service_txn.cpp | 126 +++
cloud/src/recycler/recycler.cpp | 40 +
cloud/src/recycler/recycler.h | 28 +-
cloud/src/recycler/recycler_operation_log.cpp | 90 +-
cloud/src/recycler/recycler_snapshot.cpp | 8 +-
cloud/src/snapshot/snapshot_manager.cpp | 96 ++
cloud/src/snapshot/snapshot_manager.h | 8 +
cloud/test/CMakeLists.txt | 1 +
cloud/test/compaction_rw_separation_test.cpp | 181 +++
cloud/test/meta_service_test.cpp | 17 +
cloud/test/recycler_operation_log_test.cpp | 478 ++++++++
.../docker-compose/hive/hadoop-hive-3x.env.tpl | 4 +-
.../hive/scripts/prepare-hive-data.sh | 5 +-
.../kerberos/entrypoint-hive-master.sh | 5 +-
.../docker-compose/kerberos/hadoop-hive.env.tpl | 3 +-
docker/thirdparties/jindofs-helpers.sh | 122 ++
docker/thirdparties/run-thirdparties-docker.sh | 15 +-
.../common/classloader/JniScannerClassLoader.java | 9 +
.../apache/doris/common/jdbc/JdbcDriverUtils.java | 114 ++
.../apache/doris/paimon/PaimonJdbcDriverUtils.java | 59 +
.../org/apache/doris/paimon/PaimonJniScanner.java | 2 +-
.../doris/paimon/PaimonJdbcDriverUtilsTest.java | 139 +++
.../main/java/org/apache/doris/common/Config.java | 28 +
.../apache/doris/job/cdc/DataSourceConfigKeys.java | 1 +
.../antlr4/org/apache/doris/nereids/DorisLexer.g4 | 1 +
.../antlr4/org/apache/doris/nereids/DorisParser.g4 | 3 +-
.../org/apache/doris/analysis/DescriptorTable.java | 5 +
.../doris/catalog/BuiltinAggregateFunctions.java | 4 +-
.../doris/catalog/BuiltinScalarFunctions.java | 2 +
.../doris/catalog/RecursiveCteTempTable.java} | 22 +-
.../java/org/apache/doris/catalog/TableIf.java | 19 +-
.../doris/clone/DynamicPartitionScheduler.java | 4 +-
.../doris/cloud/persist/CloudMetaSyncPoint.java | 69 ++
.../apache/doris/cloud/rpc/MetaServiceClient.java | 5 +
.../apache/doris/cloud/rpc/MetaServiceProxy.java | 5 +
.../transaction/CloudGlobalTransactionMgr.java | 16 +
.../java/org/apache/doris/common/util/S3Util.java | 232 ++++
.../datasource/paimon/source/PaimonScanNode.java | 27 +
.../metastore/PaimonJdbcMetaStoreProperties.java | 18 +
.../org/apache/doris/fs/obj/AzureObjStorage.java | 99 +-
.../java/org/apache/doris/fs/obj/S3ObjStorage.java | 108 ++
.../httpv2/rest/manager/MetaBackupAction.java | 329 ++++++
.../insert/streaming/AbstractStreamingTask.java | 11 +
.../insert/streaming/StreamingInsertJob.java | 50 +-
.../insert/streaming/StreamingInsertTask.java | 11 +-
.../insert/streaming/StreamingMultiTblTask.java | 2 +
.../doris/job/offset/SourceOffsetProvider.java | 42 +-
.../job/offset/SourceOffsetProviderFactory.java | 2 +
.../job/offset/jdbc/JdbcSourceOffsetProvider.java | 42 +-
.../offset/jdbc/JdbcTvfSourceOffsetProvider.java | 425 +++++++
.../job/offset/s3/S3SourceOffsetProvider.java | 3 +-
.../org/apache/doris/journal/JournalEntity.java | 6 +
.../org/apache/doris/load/GroupCommitManager.java | 30 +-
.../org/apache/doris/nereids/CascadesContext.java | 41 +-
.../glue/translator/PhysicalPlanTranslator.java | 105 +-
.../doris/nereids/parser/LogicalPlanBuilder.java | 10 +-
.../apache/doris/nereids/pattern/MemoPatterns.java | 24 +
.../processor/post/RuntimeFilterPruner.java | 9 +
.../processor/pre/PullUpSubqueryAliasToCTE.java | 16 +-
.../properties/ChildOutputPropertyDeriver.java | 20 +
.../nereids/properties/RequestPropertyDeriver.java | 11 +
.../org/apache/doris/nereids/rules/RuleSet.java | 6 +
.../org/apache/doris/nereids/rules/RuleType.java | 3 +
.../doris/nereids/rules/analysis/AnalyzeCTE.java | 169 ++-
.../doris/nereids/rules/analysis/BindRelation.java | 36 +-
.../nereids/rules/analysis/CollectRelation.java | 11 +-
.../nereids/rules/analysis/SubExprAnalyzer.java | 4 +-
.../nereids/rules/analysis/UserAuthentication.java | 30 +-
...eChildToPhysicalRecursiveCteRecursiveChild.java | 37 +
...RecursiveCteScanToPhysicalRecursiveCteScan.java | 42 +
.../LogicalRecursiveCteToPhysicalRecursiveCte.java | 39 +
.../nereids/rules/rewrite/AdjustNullable.java | 48 +
.../doris/nereids/rules/rewrite/CTEInline.java | 44 +-
.../doris/nereids/rules/rewrite/ColumnPruning.java | 55 +
.../doris/nereids/stats/StatsCalculator.java | 109 ++
.../trees/copier/LogicalPlanDeepCopier.java | 26 +
.../expressions/functions/agg/WindowFunnel.java | 2 +-
.../agg/{WindowFunnel.java => WindowFunnelV2.java} | 33 +-
.../expressions/functions/scalar/ElementAt.java | 7 +-
.../functions/scalar/MurmurHash3U64V2.java | 75 ++
.../visitor/AggregateFunctionVisitor.java | 5 +
.../expressions/visitor/ScalarFunctionVisitor.java | 5 +
.../apache/doris/nereids/trees/plans/PlanType.java | 6 +
.../nereids/trees/plans/algebra/RecursiveCte.java | 24 +-
.../AdminCreateClusterSnapshotCommand.java | 18 +-
.../commands/AdminDropClusterSnapshotCommand.java | 18 +-
.../AdminSetAutoClusterSnapshotCommand.java | 18 +-
...dminSetClusterSnapshotFeatureSwitchCommand.java | 18 +-
.../trees/plans/commands/AlterJobCommand.java | 16 +
.../plans/commands/UpdateMvByPartitionCommand.java | 3 +-
.../worker/job/UnassignedJobBuilder.java | 13 +
.../worker/job/UnassignedRecursiveCteScanJob.java | 65 ++
.../nereids/trees/plans/logical/LogicalCTE.java | 27 +-
.../trees/plans/logical/LogicalRecursiveCte.java | 284 +++++
.../logical/LogicalRecursiveCteRecursiveChild.java | 117 ++
.../plans/logical/LogicalRecursiveCteScan.java | 73 ++
.../trees/plans/logical/LogicalSubQueryAlias.java | 22 +
.../trees/plans/physical/PhysicalRecursiveCte.java | 292 +++++
.../PhysicalRecursiveCteRecursiveChild.java | 121 ++
.../plans/physical/PhysicalRecursiveCteScan.java | 85 ++
.../nereids/trees/plans/visitor/PlanVisitor.java | 22 +
.../trees/plans/visitor/RelationVisitor.java | 10 +
.../apache/doris/nereids/types/AggStateType.java | 1 +
.../java/org/apache/doris/persist/EditLog.java | 10 +
.../org/apache/doris/persist/OperationType.java | 1 +
.../org/apache/doris/planner/RecursiveCteNode.java | 87 ++
.../apache/doris/planner/RecursiveCteScanNode.java | 123 +++
.../java/org/apache/doris/planner/ScanNode.java | 4 +
.../main/java/org/apache/doris/qe/Coordinator.java | 38 +
.../java/org/apache/doris/qe/SessionVariable.java | 8 +
.../doris/qe/runtime/ThriftPlansBuilder.java | 231 +++-
.../apache/doris/statistics/StatisticalType.java | 2 +
.../CdcStreamTableValuedFunction.java | 35 +-
.../doris/catalog/DynamicPartitionTableTest.java | 31 +
.../org/apache/doris/common/util/S3UtilTest.java | 208 ++++
.../paimon/source/PaimonScanNodeTest.java | 94 ++
.../metastore/IcebergDlfRestCatalogTest.java | 40 +-
.../PaimonJdbcMetaStorePropertiesTest.java | 37 +
.../nereids/postprocess/RuntimeFilterTest.java | 29 +
.../nereids/rules/analysis/AnalyzeCTETest.java | 219 ++++
.../analysis/CheckExpressionLegalityTest.java | 27 +
.../rules/analysis/UserAuthenticationTest.java | 396 +++++++
.../doris/nereids/rules/rewrite/CTEInlineTest.java | 84 ++
.../nereids/rules/rewrite/ColumnPruningTest.java | 30 +
.../AdminCreateClusterSnapshotCommandTest.java | 102 +-
.../AdminDropClusterSnapshotCommandTest.java | 99 +-
.../AdminSetAutoClusterSnapshotCommandTest.java | 103 +-
...SetClusterSnapshotFeatureSwitchCommandTest.java | 99 +-
.../cdcclient/controller/ClientController.java | 2 +-
.../cdcclient/service/PipelineCoordinator.java | 95 +-
.../source/reader/mysql/MySqlSourceReader.java | 17 +
.../reader/postgres/PostgresSourceReader.java | 4 +
.../src/main/resources/application.properties | 3 +-
gensrc/proto/cloud.proto | 30 +
gensrc/thrift/PlanNodes.thrift | 3 +
.../test_hudi_olap_rewrite_mtmv.out} | 0
.../tvf/test_streaming_job_cdc_stream_mysql.out | 11 +
.../tvf/test_streaming_job_cdc_stream_postgres.out | 11 +
...g_job_cdc_stream_postgres_latest_alter_cred.out | 11 +
...eaming_job_cdc_stream_postgres_pause_resume.out | 13 +
.../data/nereids_p0/aggregate/window_funnel.out | 2 +-
.../data/nereids_p0/aggregate/window_funnel_v2.out | 88 ++
.../test_aggregate_window_functions.out | 10 +-
.../hash_functions/test_hash_function.out | 71 ++
.../data/rec_cte_p0/rec_cte/rec_cte.out | 953 ++++++++++++++++
.../rec_cte_from_ck_doc/rec_cte_from_ck_doc.out | 29 +
.../rec_cte_from_duckdb_doc.out | 30 +
.../rec_cte_from_mysql_doc.out | 42 +
.../test_compaction_cluster_takeover.groovy | 264 +++++
.../test_compaction_rw_separation.groovy | 158 +++
.../test_compaction_rw_separation_disabled.groovy | 151 +++
.../test_compaction_rw_separation_force.groovy | 161 +++
.../paimon/test_paimon_jdbc_catalog.groovy | 116 +-
.../hudi/test_hudi_olap_rewrite_mtmv.groovy | 83 +-
.../tvf/test_streaming_job_cdc_stream_mysql.groovy | 128 +++
.../test_streaming_job_cdc_stream_postgres.groovy | 131 +++
...ob_cdc_stream_postgres_latest_alter_cred.groovy | 249 +++++
...ing_job_cdc_stream_postgres_pause_resume.groovy | 238 ++++
.../nereids_p0/aggregate/window_funnel_v2.groovy | 492 +++++++++
.../test_auto_partition_retention_restart.groovy | 94 ++
.../hash_functions/test_hash_function.groovy | 67 ++
.../suites/rec_cte_p0/rec_cte/rec_cte.groovy | 271 +++++
.../rec_cte_from_ck_doc/rec_cte_from_ck_doc.groovy | 144 +++
.../rec_cte_from_duckdb_doc.groovy | 185 ++++
.../rec_cte_from_mysql_doc.groovy | 140 +++
.../column_attribute_null_test.groovy | 94 ++
.../recursive_cte/complex_rec_cte_test.groovy | 478 ++++++++
.../create_and_insert_select_test.groovy | 140 +++
.../suites/recursive_cte/mtmv_and_cte_test.groovy | 88 ++
.../suites/recursive_cte/mv_and_cte_test.groovy | 88 ++
.../suites/recursive_cte/no_data_test.groovy | 77 ++
.../recursive_cte/recursive_100_number_test.groovy | 106 ++
.../recursive_cte_exception_test.groovy | 216 ++++
.../same_data_type_recursive_test.groovy | 430 ++++++++
307 files changed, 20127 insertions(+), 1199 deletions(-)
create mode 100644 be/src/cloud/cloud_cluster_info.cpp
copy be/src/exprs/aggregate/{aggregate_function_window_funnel.cpp =>
aggregate_function_window_funnel_v2.cpp} (58%)
create mode 100644 be/src/exprs/aggregate/aggregate_function_window_funnel_v2.h
create mode 100644 be/src/exprs/function/cast/cast_to_timestamptz_impl.hpp
create mode 100644 be/src/storage/predicate/predicate_creator_comparison.cpp
create mode 100644 be/src/storage/predicate/predicate_creator_in_list_in.cpp
create mode 100644
be/src/storage/predicate/predicate_creator_in_list_not_in.cpp
create mode 100644 be/src/storage/segment/segment_prefetcher.cpp
create mode 100644 be/src/storage/segment/segment_prefetcher.h
create mode 100644 be/src/util/concurrency_stats.cpp
create mode 100644 be/src/util/concurrency_stats.h
create mode 100644 be/test/cloud/cloud_cluster_info_test.cpp
create mode 100644
be/test/core/data_type_serde/data_type_serde_datelike_batch_test.cpp
create mode 100644
be/test/exec/test_data/parquet_scanner/test_string_null.zst.parquet
create mode 100644 be/test/exprs/aggregate/vec_window_funnel_v2_test.cpp
create mode 100644
be/test/format/parquet/byte_array_dict_decoder_empty_dict_test.cpp
create mode 100644
be/test/format/parquet/fix_length_dict_decoder_empty_dict_test.cpp
create mode 100644 cloud/test/compaction_rw_separation_test.cpp
create mode 100644 docker/thirdparties/jindofs-helpers.sh
create mode 100644
fe/be-java-extensions/java-common/src/main/java/org/apache/doris/common/jdbc/JdbcDriverUtils.java
create mode 100644
fe/be-java-extensions/paimon-scanner/src/main/java/org/apache/doris/paimon/PaimonJdbcDriverUtils.java
create mode 100644
fe/be-java-extensions/paimon-scanner/src/test/java/org/apache/doris/paimon/PaimonJdbcDriverUtilsTest.java
copy
fe/{be-java-extensions/java-common/src/main/java/org/apache/doris/common/classloader/JniScannerClassLoader.java
=> fe-core/src/main/java/org/apache/doris/catalog/RecursiveCteTempTable.java}
(62%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/cloud/persist/CloudMetaSyncPoint.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/httpv2/rest/manager/MetaBackupAction.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/job/offset/jdbc/JdbcTvfSourceOffsetProvider.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/implementation/LogicalRecursiveCteRecursiveChildToPhysicalRecursiveCteRecursiveChild.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/implementation/LogicalRecursiveCteScanToPhysicalRecursiveCteScan.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/implementation/LogicalRecursiveCteToPhysicalRecursiveCte.java
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/agg/{WindowFunnel.java
=> WindowFunnelV2.java} (74%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/MurmurHash3U64V2.java
copy be/src/cloud/cloud_cluster_info.h =>
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/algebra/RecursiveCte.java
(62%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/distribute/worker/job/UnassignedRecursiveCteScanJob.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/logical/LogicalRecursiveCte.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/logical/LogicalRecursiveCteRecursiveChild.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/logical/LogicalRecursiveCteScan.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/physical/PhysicalRecursiveCte.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/physical/PhysicalRecursiveCteRecursiveChild.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/physical/PhysicalRecursiveCteScan.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/planner/RecursiveCteNode.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/planner/RecursiveCteScanNode.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/rules/analysis/UserAuthenticationTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/rules/rewrite/CTEInlineTest.java
copy regression-test/data/external_table_p2/hudi/{test_hudi_rewrite_mtmv.out
=> hudi_mtmv/test_hudi_olap_rewrite_mtmv.out} (100%)
create mode 100644
regression-test/data/job_p0/streaming_job/cdc/tvf/test_streaming_job_cdc_stream_mysql.out
create mode 100644
regression-test/data/job_p0/streaming_job/cdc/tvf/test_streaming_job_cdc_stream_postgres.out
create mode 100644
regression-test/data/job_p0/streaming_job/cdc/tvf/test_streaming_job_cdc_stream_postgres_latest_alter_cred.out
create mode 100644
regression-test/data/job_p0/streaming_job/cdc/tvf/test_streaming_job_cdc_stream_postgres_pause_resume.out
create mode 100644
regression-test/data/nereids_p0/aggregate/window_funnel_v2.out
create mode 100644 regression-test/data/rec_cte_p0/rec_cte/rec_cte.out
create mode 100644
regression-test/data/rec_cte_p0/rec_cte_from_ck_doc/rec_cte_from_ck_doc.out
create mode 100644
regression-test/data/rec_cte_p0/rec_cte_from_duckdb_doc/rec_cte_from_duckdb_doc.out
create mode 100644
regression-test/data/rec_cte_p0/rec_cte_from_mysql_doc/rec_cte_from_mysql_doc.out
create mode 100644
regression-test/suites/cloud_p0/compaction_rw_separation/test_compaction_cluster_takeover.groovy
create mode 100644
regression-test/suites/cloud_p0/compaction_rw_separation/test_compaction_rw_separation.groovy
create mode 100644
regression-test/suites/cloud_p0/compaction_rw_separation/test_compaction_rw_separation_disabled.groovy
create mode 100644
regression-test/suites/cloud_p0/compaction_rw_separation/test_compaction_rw_separation_force.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/tvf/test_streaming_job_cdc_stream_mysql.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/tvf/test_streaming_job_cdc_stream_postgres.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/tvf/test_streaming_job_cdc_stream_postgres_latest_alter_cred.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/tvf/test_streaming_job_cdc_stream_postgres_pause_resume.groovy
create mode 100644
regression-test/suites/nereids_p0/aggregate/window_funnel_v2.groovy
create mode 100644
regression-test/suites/partition_p0/auto_partition/test_auto_partition_retention_restart.groovy
create mode 100644 regression-test/suites/rec_cte_p0/rec_cte/rec_cte.groovy
create mode 100644
regression-test/suites/rec_cte_p0/rec_cte_from_ck_doc/rec_cte_from_ck_doc.groovy
create mode 100644
regression-test/suites/rec_cte_p0/rec_cte_from_duckdb_doc/rec_cte_from_duckdb_doc.groovy
create mode 100644
regression-test/suites/rec_cte_p0/rec_cte_from_mysql_doc/rec_cte_from_mysql_doc.groovy
create mode 100644
regression-test/suites/recursive_cte/column_attribute_null_test.groovy
create mode 100644
regression-test/suites/recursive_cte/complex_rec_cte_test.groovy
create mode 100644
regression-test/suites/recursive_cte/create_and_insert_select_test.groovy
create mode 100644
regression-test/suites/recursive_cte/mtmv_and_cte_test.groovy
create mode 100644 regression-test/suites/recursive_cte/mv_and_cte_test.groovy
create mode 100644 regression-test/suites/recursive_cte/no_data_test.groovy
create mode 100644
regression-test/suites/recursive_cte/recursive_100_number_test.groovy
create mode 100644
regression-test/suites/recursive_cte/recursive_cte_exception_test.groovy
create mode 100644
regression-test/suites/recursive_cte/same_data_type_recursive_test.groovy
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
