This is an automated email from the ASF dual-hosted git repository.
panxiaolei pushed a change to branch dev_rec4
in repository https://gitbox.apache.org/repos/asf/doris.git
from cb1d5055b12 fix recursive cte p0 case (#59402)
add e74ea4bbaeb [Enhancement][doris-future] Unify regr_sxx/syy/sxy on
AggregateFunctionRegrData (#59224)
add 42a136f26de [fix](txn) fix clean_txn_label racing with recycler in
versioned write mode (#59443)
add c294e376440 [Exec](shuffle) random shuffle firstly use local channel
to improve performance (#59431)
add 13ea84daaa3 [fix](core)be core when
BeConfDataDirReader::get_data_dir_by_file_path (#59204)
add c48244a69f1 [feat](seq mapping) uniq table supports multi-stream
merging through sequence mapping (#54936)
add 886d578d608 [Fix](Compaction) Fix cumulative compaction pick rowsets
to trim by max score after filtering (#59268)
add 23e7e76ca96 [chore](cloud) Add skeleton func for clone chain reader
(#59469)
add bf2669e5bd3 [Chore](bitmap) change BitmapValue CHECK to throw
exception (#59464)
add ef5a3b3458f [Fix](Recycler) Fix recycler OOM by limiting queued delete
tasks (#59331)
add 26fb9885f15 [memorygc](lrucache) do not prune memory if prune is
disabled (#59478)
add 53f8002663d [fix](column) Add back hash functions of ColumnComplex
(#59481)
add 5df1162d884 [test](plan) update tpcds shape check (#59434)
add 28b2d23ecfa [chore](cte) use a better way to get child in enforce
regulator (#59395)
add 9140b21848f [fix] Check rs meta size during cool down progress (#57368)
add 32ef364c52c [fix](block-rule) Skip SQL block rules check for EXPLAIN
statements (#59445)
add 9c36839a311 [Enhancement](parquet)update runtime filter when read next
parquet row group. (#59053)
add 44736cbf470 [opt](inverted index) optimize S3 operations for inverted
index (#59363)
add e9da494a6a5 [minor](log) Add logs for WorkThreadPool (#59503)
add d59dc20be1c [fix](fe) remove deprecated version hash variables to
reduce memory (#59458)
add 4e79e4aa4cd [feat](test) Support recycler progress for docker test
(#59480)
add 1cbe48767dd [enhance](meta-service)add bvar for fdb process status
(#59329)
add d86daef5a8f [Chore](query) add _query_ctx_map_delay_delete (#59262)
add 3ead2ebd16b [Exec] (performance) support stream agg topn (#59446)
add f4a33613d69 [performance][Exec] scanner merge block before projection
(#59492)
add b69e79d3091 [refactor](jni)refactor jni util for safe jni call (#56763)
add 5f9265695bd [Feature](Streaming Job) Extend streaming job to support
Postgres synchronization (#59461)
add 9d34c0416dd [opt](packed-file) Avoid unnecessary HEAD Object requests
when opening an S3 object (#59414)
add a1e482cca31 [opt](sort)use HybridSorter to choose between timsort and
pdqsort (#59207)
add 5b2cbcc7903 [Opt](function) opt of certain time field functions used
in conjunction with FROM_UNIXTIME. (#57941)
add fa40415f8ff [Fix](Variant) Fix variant compaction empty path handling
(#59544)
add d172147f55e [fix](temp-table) not clean temp table temporary until fix
mem leak (#59535)
add 6deea820196 [fix](analyzer) fix some fill up missing slot errors and
make some error hints happy (#58912)
add 7d83f416a1a [fix](cloud)Fix `create dynamic table` race with `insert
overwrite` (#59489)
add bf2e1c2dda9 [opt](distribution) support bucket shuffle for set
operation (#59006)
add 4a45bcbc1a5 [fix](doris compose) fix create storage vault fail (#59553)
add 38e7ffd1a7a [refactor](predicate) Normalize predicates generation
(#59187)
add 6ec35ec5078 [fix](packed-file) use timestamp-only cleanup for packed
slice index (#59369)
add a3252b7194f [Fix](Test) Fix tablet stats case (#59484)
add c9b1819864e [opt](multi-catalog) Optimize file split size. (#58858)
add 5e0c87f1e88 [improve](cloud) Report read/write conflict range (#59437)
add 2cfcc0ff6d2 [Enchancement](sort) do a little optimization for full
sort (#56944)
add e6fe5ccbb3a [opt](analyze) support iceberg external table in analyze
(#59473)
add 33436ac79a1 [fix](packed-file) enable file cache for packed file
(#59575)
add bf57e7545c8 [Feature](iceberg) Support Iceberg JDBC Catalog (#59502)
add e85f8393039 [fix](case) Fix `different_serialize_cloud` case (#59555)
add 21010b91bf8 [fix](topn-lazy-materialize) LazySlotPruning does not pass
nullable attribute of global_row_id when visiting project. (#58722)
add a8a92f90c19 [chore](spill) refactor lambda to function (#59584)
add 0395b50edca [Fix](Exception) Fix potential use-after-free because
`Exception::to_string` is not thread safe (#59558)
add 54d012e3b3b [chore](scan) remove unused code (#59565)
add 52a178a652e [fix](compaction) Check schema version before ordered data
compaction (#59570)
add 4a81f1b95c0 [refactor](predicates) Remove or predicates (#59581)
add 276b86ee624 Merge branch 'master' into dev_rec4
No new revisions were added by this update.
Summary of changes:
.github/workflows/build-extension.yml | 40 +-
be/src/agent/task_worker_pool.cpp | 2 +-
.../cloud/cloud_cumulative_compaction_policy.cpp | 31 +-
be/src/cloud/cloud_rowset_writer.cpp | 2 +-
be/src/cloud/pb_convert.cpp | 12 +
be/src/common/exception.cpp | 8 +
be/src/common/exception.h | 20 +-
be/src/exec/olap_utils.h | 18 +-
be/src/exprs/create_predicate_function.h | 10 +-
be/src/io/fs/benchmark/benchmark_factory.hpp | 2 +-
be/src/io/fs/hdfs_file_writer.cpp | 2 +-
be/src/io/fs/local_file_reader.cpp | 15 +
be/src/io/fs/local_file_reader.h | 1 +
be/src/io/fs/packed_file_manager.cpp | 34 +-
be/src/io/fs/packed_file_manager.h | 2 +
be/src/io/fs/packed_file_system.cpp | 10 +-
be/src/olap/accept_null_predicate.h | 3 +-
be/src/olap/bitmap_filter_predicate.h | 4 +-
be/src/olap/bloom_filter_predicate.h | 4 +-
be/src/olap/collection_statistics.cpp | 68 +-
be/src/olap/collection_statistics.h | 12 +-
be/src/olap/column_predicate.h | 9 +-
be/src/olap/compaction.cpp | 26 +-
be/src/olap/comparison_predicate.h | 5 +-
be/src/olap/cumulative_compaction_policy.cpp | 25 +-
be/src/olap/delete_handler.cpp | 71 +-
be/src/olap/in_list_predicate.h | 30 +-
be/src/olap/like_column_predicate.cpp | 4 +-
be/src/olap/like_column_predicate.h | 4 +-
be/src/olap/memtable.cpp | 47 +-
be/src/olap/memtable.h | 3 +
be/src/olap/null_predicate.cpp | 5 +-
be/src/olap/null_predicate.h | 3 +-
be/src/olap/predicate_creator.cpp | 65 +-
be/src/olap/predicate_creator.h | 148 +-
be/src/olap/push_handler.cpp | 4 +-
be/src/olap/push_handler.h | 1 +
be/src/olap/rowset/beta_rowset_reader.cpp | 4 +-
be/src/olap/rowset/rowset_meta.cpp | 2 +
be/src/olap/rowset/rowset_meta.h | 5 +-
.../segment_v2/variant/variant_column_reader.cpp | 5 +
be/src/olap/schema.h | 2 +-
be/src/olap/shared_predicate.h | 4 +-
be/src/olap/tablet.cpp | 10 +-
be/src/olap/tablet_meta.cpp | 10 +
be/src/olap/tablet_schema.cpp | 98 ++
be/src/olap/tablet_schema.h | 18 +
be/src/pipeline/exec/exchange_sink_operator.cpp | 12 +
be/src/pipeline/exec/exchange_sink_operator.h | 1 +
be/src/pipeline/exec/file_scan_operator.cpp | 67 +
be/src/pipeline/exec/file_scan_operator.h | 25 +
be/src/pipeline/exec/mock_scan_operator.h | 44 +-
be/src/pipeline/exec/olap_scan_operator.cpp | 24 +
be/src/pipeline/exec/olap_scan_operator.h | 25 +-
.../exec/partitioned_aggregation_sink_operator.cpp | 112 +-
.../exec/partitioned_aggregation_sink_operator.h | 2 +
.../exec/partitioned_hash_join_sink_operator.cpp | 294 ++--
.../exec/partitioned_hash_join_sink_operator.h | 7 +
be/src/pipeline/exec/scan_operator.cpp | 723 ++++----
be/src/pipeline/exec/scan_operator.h | 56 +-
be/src/pipeline/exec/set_probe_sink_operator.h | 7 +-
be/src/pipeline/exec/set_sink_operator.h | 7 +-
be/src/pipeline/exec/sort_sink_operator.cpp | 5 +-
be/src/pipeline/exec/spill_sort_sink_operator.cpp | 126 +-
be/src/pipeline/exec/spill_sort_sink_operator.h | 2 +
.../pipeline/exec/spill_sort_source_operator.cpp | 173 +-
be/src/pipeline/exec/spill_sort_source_operator.h | 3 +
.../exec/streaming_aggregation_operator.cpp | 268 ++-
.../pipeline/exec/streaming_aggregation_operator.h | 79 +-
be/src/pipeline/pipeline_fragment_context.cpp | 2 +
be/src/runtime/cdc_client_mgr.cpp | 20 +-
be/src/runtime/fragment_mgr.cpp | 4 +
be/src/runtime/fragment_mgr.h | 3 +
be/src/runtime/memory/lru_cache_policy.h | 6 +-
be/src/runtime/query_context.cpp | 8 +-
be/src/runtime/runtime_predicate.cpp | 8 +-
be/src/runtime/runtime_predicate.h | 4 +-
be/src/runtime/runtime_state.h | 5 +
.../runtime_filter_consumer_helper.h | 2 +
be/src/runtime_filter/runtime_filter_mgr.cpp | 24 -
be/src/runtime_filter/runtime_filter_mgr.h | 5 +-
be/src/service/doris_main.cpp | 2 +-
be/src/util/bitmap_value.h | 11 +-
be/src/util/doris_metrics.cpp | 4 +-
be/src/util/doris_metrics.h | 2 +-
be/src/util/jni-util.cpp | 556 ++----
be/src/util/jni-util.h | 1205 +++++++++++--
be/src/util/jvm_metrics.cpp | 477 +++---
be/src/util/jvm_metrics.h | 83 +-
be/src/util/work_thread_pool.hpp | 8 +-
.../aggregate_function_java_udaf.h | 210 ++-
.../aggregate_function_regr_union.cpp | 3 +
.../aggregate_function_regr_union.h | 91 +-
.../aggregate_functions/aggregate_function_sort.h | 5 +-
be/src/vec/columns/column.h | 11 +-
be/src/vec/columns/column_array.cpp | 6 +-
be/src/vec/columns/column_array.h | 2 +-
be/src/vec/columns/column_complex.h | 12 +
be/src/vec/columns/column_const.cpp | 2 +-
be/src/vec/columns/column_const.h | 2 +-
be/src/vec/columns/column_decimal.cpp | 6 +-
be/src/vec/columns/column_decimal.h | 13 +-
be/src/vec/columns/column_dummy.h | 2 +-
be/src/vec/columns/column_map.cpp | 6 +-
be/src/vec/columns/column_map.h | 2 +-
be/src/vec/columns/column_nullable.cpp | 4 +-
be/src/vec/columns/column_nullable.h | 2 +-
be/src/vec/columns/column_string.cpp | 6 +-
be/src/vec/columns/column_string.h | 2 +-
be/src/vec/columns/column_struct.cpp | 6 +-
be/src/vec/columns/column_struct.h | 2 +-
be/src/vec/columns/column_varbinary.cpp | 6 +-
be/src/vec/columns/column_varbinary.h | 2 +-
be/src/vec/columns/column_vector.cpp | 6 +-
be/src/vec/columns/column_vector.h | 2 +-
be/src/vec/common/sort/heap_sorter.cpp | 9 +-
be/src/vec/common/sort/heap_sorter.h | 4 +-
be/src/vec/common/sort/partition_sorter.cpp | 5 +-
be/src/vec/common/sort/sorter.cpp | 4 +-
be/src/vec/common/sort/sorter.h | 9 +-
be/src/vec/common/sort/topn_sorter.cpp | 2 +-
be/src/vec/core/hybrid_sorter.h | 205 +++
be/src/vec/core/sort_block.cpp | 7 +-
be/src/vec/core/sort_block.h | 16 +-
be/src/vec/exec/format/generic_reader.cpp | 294 ----
be/src/vec/exec/format/generic_reader.h | 19 -
.../exec/format/parquet/vparquet_group_reader.h | 9 +
be/src/vec/exec/format/parquet/vparquet_reader.cpp | 105 +-
be/src/vec/exec/format/parquet/vparquet_reader.h | 29 +-
be/src/vec/exec/format/table/hive_reader.cpp | 10 +-
be/src/vec/exec/format/table/hive_reader.h | 6 +-
be/src/vec/exec/format/table/hudi_reader.cpp | 10 +-
be/src/vec/exec/format/table/hudi_reader.h | 6 +-
be/src/vec/exec/format/table/iceberg_reader.cpp | 20 +-
be/src/vec/exec/format/table/iceberg_reader.h | 6 +-
be/src/vec/exec/format/table/paimon_reader.h | 10 +-
.../format/table/trino_connector_jni_reader.cpp | 37 +-
be/src/vec/exec/jni_connector.cpp | 170 +-
be/src/vec/exec/jni_connector.h | 24 +-
be/src/vec/exec/scan/file_scanner.cpp | 71 +-
be/src/vec/exec/scan/file_scanner.h | 3 +-
be/src/vec/exec/scan/olap_scanner.cpp | 40 +-
be/src/vec/exec/scan/scanner.cpp | 36 +-
be/src/vec/exec/scan/scanner.h | 12 +
be/src/vec/exec/vjdbc_connector.cpp | 339 ++--
be/src/vec/exec/vjdbc_connector.h | 38 +-
.../exprs/table_function/udf_table_function.cpp | 92 +-
.../vec/exprs/table_function/udf_table_function.h | 23 +-
be/src/vec/functions/date_time_transforms.h | 137 ++
be/src/vec/functions/function_java_udf.cpp | 61 +-
be/src/vec/functions/function_java_udf.h | 20 +-
.../vec/functions/function_time_value_to_field.cpp | 10 +
be/src/vec/olap/block_reader.cpp | 169 +-
be/src/vec/olap/block_reader.h | 15 +
be/src/vec/olap/vcollect_iterator.cpp | 3 +-
.../cloud_cumulative_compaction_policy_test.cpp | 122 ++
be/test/io/fs/remote_file_system_test.cpp | 1 -
be/test/olap/block_column_predicate_test.cpp | 74 +-
be/test/olap/collection_statistics_test.cpp | 31 +-
be/test/olap/cumulative_compaction_policy_test.cpp | 1801 +++++++++++++++++++-
be/test/olap/date_bloom_filter_test.cpp | 28 +-
be/test/olap/test_data/header_without_inc_rs.txt | 4 +-
.../operator/hashjoin_probe_operator_test.cpp | 3 +-
.../operator/scan_normalize_predicate_test.cpp | 117 +-
.../operator/streaming_agg_operator_test.cpp | 4 -
be/test/testutil/mock/mock_runtime_state.h | 2 +
be/test/util/jni_util_test.cpp | 682 ++++++++
be/test/vec/columns/column_const_test.cpp | 2 +-
be/test/vec/columns/column_varbinary_test.cpp | 7 +-
be/test/vec/columns/common_column_test.h | 9 +-
be/test/vec/core/column_complex_test.cpp | 20 +
.../vec/data_types/data_type_timestamptz_test.cpp | 3 +-
.../vec/exec/format/parquet/parquet_expr_test.cpp | 226 +--
.../vec/exec/format/parquet/parquet_read_lines.cpp | 3 +-
.../exec/format/parquet/parquet_reader_test.cpp | 23 +-
.../exec/format/table/hive/hive_reader_test.cpp | 3 +-
.../format/table/iceberg/iceberg_reader_test.cpp | 3 +-
be/test/vec/exec/sort/full_sort_test.cpp | 6 +-
be/test/vec/exec/sort/heap_sorter_test.cpp | 4 +-
be/test/vec/exec/sort/partition_sorter_test.cpp | 6 +-
be/test/vec/exec/sort/sort_test.cpp | 14 +-
be/test/vec/exec/sort/topn_sort_test.cpp | 4 +-
build.sh | 1 +
cloud/src/common/bvars.cpp | 14 +-
cloud/src/common/bvars.h | 14 +-
cloud/src/common/config.h | 3 +
cloud/src/common/metric.cpp | 189 +-
cloud/src/meta-service/meta_service_txn.cpp | 121 +-
cloud/src/meta-store/clone_chain_reader.cpp | 129 ++
cloud/src/meta-store/clone_chain_reader.h | 20 +
cloud/src/meta-store/txn_kv.cpp | 128 +-
cloud/src/meta-store/txn_kv.h | 4 +
cloud/src/recycler/meta_checker.cpp | 4 +-
cloud/src/recycler/obj_storage_client.cpp | 142 +-
cloud/test/CMakeLists.txt | 3 +-
cloud/test/meta_service_test.cpp | 410 +++++
cloud/test/metric_test.cpp | 137 +-
cloud/test/recycler_batch_delete_test.cpp | 403 +++++
docker/runtime/doris-compose/cluster.py | 1 +
docker/runtime/doris-compose/database.py | 1 +
.../scripts/create_preinstalled_scripts/run84.hql | 20 +
.../runtime_filter_dim_small/dim_small.parquet | Bin 0 -> 4230 bytes
.../runtime_filter_fact_big/fact_big.parquet | Bin 0 -> 129338 bytes
.../postgresql/init/01-create-schema.sql | 1 +
.../postgresql/postgresql-14.yaml.tpl | 8 +
.../apache/doris/job/cdc/DataSourceConfigKeys.java | 1 +
.../main/java/org/apache/doris/alter/Alter.java | 2 +-
.../org/apache/doris/alter/CloudRollupJobV2.java | 3 +-
.../apache/doris/alter/CloudSchemaChangeJobV2.java | 3 +-
.../doris/alter/MaterializedViewHandler.java | 6 +
.../java/org/apache/doris/alter/RollupJobV2.java | 2 +-
.../apache/doris/alter/SchemaChangeHandler.java | 192 ++-
.../org/apache/doris/alter/SchemaChangeJobV2.java | 10 +-
.../java/org/apache/doris/backup/RestoreJob.java | 3 +-
.../doris/catalog/BuiltinAggregateFunctions.java | 6 +
.../doris/catalog/BuiltinScalarFunctions.java | 8 +
.../main/java/org/apache/doris/catalog/Env.java | 33 +-
.../java/org/apache/doris/catalog/FunctionSet.java | 6 +
.../java/org/apache/doris/catalog/OlapTable.java | 24 +
.../java/org/apache/doris/catalog/Partition.java | 22 -
.../java/org/apache/doris/catalog/Replica.java | 11 -
.../main/java/org/apache/doris/catalog/Table.java | 12 -
.../org/apache/doris/catalog/TableProperty.java | 87 +
.../main/java/org/apache/doris/catalog/Tablet.java | 12 -
.../apache/doris/catalog/TemporaryTableMgr.java | 73 +-
.../doris/clone/DynamicPartitionScheduler.java | 74 +-
.../apache/doris/cloud/backup/CloudRestoreJob.java | 3 +-
.../cloud/datasource/CloudInternalCatalog.java | 18 +-
.../org/apache/doris/common/util/ColumnsUtil.java | 61 +
.../apache/doris/common/util/PropertyAnalyzer.java | 138 ++
.../doris/datasource/FederationBackendPolicy.java | 12 +-
.../apache/doris/datasource/FileQueryScanNode.java | 19 +-
.../org/apache/doris/datasource/FileScanNode.java | 10 +-
.../org/apache/doris/datasource/FileSplitter.java | 230 ++-
.../apache/doris/datasource/InternalCatalog.java | 60 +-
.../apache/doris/datasource/SplitGenerator.java | 2 +-
.../doris/datasource/hive/source/HiveScanNode.java | 78 +-
.../datasource/iceberg/IcebergExternalCatalog.java | 1 +
.../iceberg/IcebergExternalCatalogFactory.java | 2 +
.../iceberg/IcebergJdbcExternalCatalog.java | 23 +-
.../datasource/iceberg/source/IcebergScanNode.java | 81 +-
.../datasource/paimon/source/PaimonScanNode.java | 47 +-
.../metastore/IcebergJdbcMetaStoreProperties.java | 310 ++++
.../metastore/IcebergPropertiesFactory.java | 1 +
.../doris/datasource/tvf/source/TVFScanNode.java | 31 +-
.../apache/doris/job/common/DataSourceType.java | 3 +-
.../streaming/DataSourceConfigValidator.java | 4 +-
.../insert/streaming/StreamingInsertJob.java | 54 +-
.../streaming/StreamingJobSchedulerTask.java | 2 +-
.../insert/streaming/StreamingMultiTblTask.java | 12 +-
.../apache/doris/job/offset/jdbc/JdbcOffset.java | 8 +
.../job/offset/jdbc/JdbcSourceOffsetProvider.java | 53 +-
.../apache/doris/job/util/StreamingJobUtils.java | 66 +-
.../org/apache/doris/master/ReportHandler.java | 3 +-
.../org/apache/doris/mtmv/MTMVPartitionUtil.java | 2 +-
.../glue/translator/PhysicalPlanTranslator.java | 13 +-
.../glue/translator/RuntimeFilterTranslator.java | 2 +-
.../parser/LogicalPlanBuilderForEncryption.java | 19 +-
.../apache/doris/nereids/pattern/PlanPatterns.java | 70 +-
.../post/materialize/LazySlotPruning.java | 1 +
.../properties/ChildOutputPropertyDeriver.java | 52 +
.../properties/ChildrenPropertiesRegulator.java | 110 +-
.../nereids/properties/RequestPropertyDeriver.java | 5 +-
.../org/apache/doris/nereids/rules/RuleType.java | 1 -
.../AdjustAggregateNullableForEmptySet.java | 9 +
.../nereids/rules/analysis/BindExpression.java | 199 ++-
.../nereids/rules/analysis/CheckAfterRewrite.java | 8 +-
.../nereids/rules/analysis/CheckAnalysis.java | 93 +-
.../nereids/rules/analysis/FillUpMissingSlots.java | 292 ++--
.../rules/analysis/FillUpQualifyMissingSlot.java | 4 +-
.../nereids/rules/analysis/NormalizeAggregate.java | 25 +-
.../rules/expression/ExpressionOptimization.java | 2 +
.../rules/expression/ExpressionRuleType.java | 1 +
.../rules/SimplifyTimeFieldFromUnixtime.java | 151 ++
.../trees/expressions/functions/agg/AnyValue.java | 7 +-
.../trees/expressions/functions/agg/RegrSxx.java | 85 +
.../trees/expressions/functions/agg/RegrSxy.java | 85 +
.../trees/expressions/functions/agg/RegrSyy.java | 85 +
.../executable/DateTimeExtractAndTransform.java | 84 +
.../AnyValue.java => scalar/HourFromUnixtime.java} | 58 +-
.../MicrosecondFromUnixtime.java} | 58 +-
.../MinuteFromUnixtime.java} | 58 +-
.../SecondFromUnixtime.java} | 58 +-
.../visitor/AggregateFunctionVisitor.java | 15 +
.../expressions/visitor/ExpressionVisitors.java | 3 +
.../expressions/visitor/ScalarFunctionVisitor.java | 20 +
.../doris/nereids/trees/plans/algebra/Except.java | 6 +-
.../nereids/trees/plans/algebra/Intersect.java | 6 +-
.../doris/nereids/trees/plans/algebra/Join.java | 11 -
.../nereids/trees/plans/algebra/ShuffleType.java | 12 +-
.../trees/plans/commands/ExplainCommand.java | 3 +-
.../trees/plans/commands/info/CreateTableInfo.java | 5 +-
.../worker/LoadBalanceScanWorkerSelector.java | 4 +-
.../worker/job/UnassignedJobBuilder.java | 2 +-
.../job/UnassignedScanBucketOlapTableJob.java | 43 +-
.../nereids/trees/plans/logical/LogicalExcept.java | 3 +-
.../trees/plans/logical/LogicalIntersect.java | 3 +-
.../trees/plans/physical/AbstractPhysicalJoin.java | 3 +-
.../trees/plans/physical/PhysicalExcept.java | 3 +-
.../trees/plans/physical/PhysicalIntersect.java | 3 +-
.../trees/plans/physical/PhysicalSetOperation.java | 30 +
.../trees/plans/physical/PhysicalUnion.java | 11 +
.../org/apache/doris/nereids/util/JoinUtils.java | 3 +-
.../org/apache/doris/nereids/util/PlanUtils.java | 6 +
.../java/org/apache/doris/persist/EditLog.java | 22 +-
.../org/apache/doris/persist/gson/GsonUtils.java | 2 +
.../org/apache/doris/planner/DistributionMode.java | 57 +
.../org/apache/doris/planner/HashJoinNode.java | 34 -
.../org/apache/doris/planner/PlanFragment.java | 17 +-
.../org/apache/doris/planner/SetOperationNode.java | 14 +
.../java/org/apache/doris/qe/SessionVariable.java | 75 +
.../apache/doris/service/FrontendServiceImpl.java | 2 +-
.../apache/doris/statistics/AnalysisManager.java | 27 +-
.../doris/statistics/StatisticsAutoCollector.java | 9 +-
.../doris/statistics/util/StatisticsUtil.java | 15 +-
.../org/apache/doris/task/CreateReplicaTask.java | 23 +-
.../doris/alter/SchemaChangeHandlerTest.java | 155 ++
.../org/apache/doris/catalog/CreateTableTest.java | 37 +
.../apache/doris/common/PropertyAnalyzerTest.java | 95 ++
.../apache/doris/datasource/FileSplitterTest.java | 216 +++
.../paimon/source/PaimonScanNodeTest.java | 17 +
.../IcebergJdbcMetaStorePropertiesTest.java | 83 +
.../apache/doris/nereids/DistributeHintTest.java | 2 +-
.../doris/nereids/parser/EncryptSQLTest.java | 66 +-
.../ChildrenPropertiesRegulatorTest.java | 41 +-
.../rules/analysis/FillUpMissingSlotsTest.java | 71 +-
.../SimplifyTimeFieldFromUnixtimeTest.java | 86 +
.../org/apache/doris/nereids/util/TestHelper.java | 46 +
.../doris/planner/FederationBackendPolicyTest.java | 4 +-
.../java/org/apache/doris/task/AgentTaskTest.java | 2 +-
fs_brokers/cdc_client/build.sh | 2 +-
fs_brokers/cdc_client/pom.xml | 5 +
.../apache/doris/cdcclient/common/Constants.java | 2 +
.../org/apache/doris/cdcclient/common/Env.java | 81 +-
.../cdcclient/controller/ClientController.java | 16 +-
.../doris/cdcclient/model/rest/RestResponse.java | 2 +
.../cdcclient/service/PipelineCoordinator.java | 115 +-
.../doris/cdcclient/sink/DorisBatchStreamLoad.java | 3 +
.../deserialize/DebeziumJsonDeserializer.java | 43 +-
.../doris/cdcclient/source/factory/DataSource.java | 3 +-
.../source/factory/SourceReaderFactory.java | 4 +-
.../source/reader/JdbcIncrementalSourceReader.java | 730 ++++++++
.../cdcclient/source/reader/SourceReader.java | 31 +-
.../cdcclient/source/reader/SplitRecords.java | 21 +-
.../source/reader/mysql/MySqlSourceReader.java | 278 ++-
.../reader/postgres/PostgresSourceReader.java | 388 +++++
.../apache/doris/cdcclient/utils/ConfigUtil.java | 164 +-
.../source/PostgresConnectionPoolFactory.java | 58 +
gensrc/proto/olap_file.proto | 14 +
gensrc/thrift/AgentService.thrift | 1 +
gensrc/thrift/PaloInternalService.thrift | 4 +
gensrc/thrift/Types.thrift | 5 +
.../backup_restore/test_seq_map_backup_restore.out | 52 +
.../data/datatype_p0/date/test_from_unixtime.out | 70 +
.../iceberg/test_iceberg_jdbc_catalog.out | 42 +
.../jdbc/test_pg_jdbc_catalog.out | 2 +
.../cdc/test_streaming_mysql_job_exclude.out | 14 +-
...sql_job.out => test_streaming_postgres_job.out} | 0
.../cdc/test_streaming_postgres_job_all_type.out | 39 +
...de.out => test_streaming_postgres_job_priv.out} | 3 +-
.../agg_function/test_regr_sxx.out | 34 +
.../agg_function/test_regr_sxy.out | 34 +
.../agg_function/test_regr_syy.out | 34 +
.../test_having_with_aggregate_function.out | 4 +-
.../infer_set_operator_distinct.out | 154 +-
.../data/nereids_syntax_p0/analyze_agg.out | 190 +++
.../data/nereids_syntax_p0/analyze_repeat.out | 101 ++
.../bucket_shuffle_set_operation.out | 119 ++
.../test_seq_map_value_add.out} | 8 +-
.../test_seq_map_value_drop.out} | 9 +-
.../tpcds_sf100/noStatsRfPrune/query17.out | 2 +-
.../tpcds_sf100/noStatsRfPrune/query24.out | 2 +-
.../tpcds_sf100/noStatsRfPrune/query25.out | 2 +-
.../tpcds_sf100/noStatsRfPrune/query29.out | 2 +-
.../tpcds_sf100/noStatsRfPrune/query39.out | 22 +-
.../tpcds_sf100/noStatsRfPrune/query40.out | 2 +-
.../tpcds_sf100/noStatsRfPrune/query49.out | 6 +-
.../tpcds_sf100/noStatsRfPrune/query5.out | 13 +-
.../tpcds_sf100/noStatsRfPrune/query50.out | 2 +-
.../tpcds_sf100/noStatsRfPrune/query64.out | 4 +-
.../tpcds_sf100/noStatsRfPrune/query72.out | 4 +-
.../tpcds_sf100/noStatsRfPrune/query75.out | 6 +-
.../tpcds_sf100/noStatsRfPrune/query78.out | 6 +-
.../tpcds_sf100/noStatsRfPrune/query80.out | 6 +-
.../tpcds_sf100/noStatsRfPrune/query85.out | 2 +-
.../tpcds_sf100/noStatsRfPrune/query93.out | 2 +-
.../tpcds_sf100/no_stats_shape/query17.out | 2 +-
.../tpcds_sf100/no_stats_shape/query24.out | 2 +-
.../tpcds_sf100/no_stats_shape/query25.out | 2 +-
.../tpcds_sf100/no_stats_shape/query29.out | 2 +-
.../tpcds_sf100/no_stats_shape/query39.out | 22 +-
.../tpcds_sf100/no_stats_shape/query40.out | 2 +-
.../tpcds_sf100/no_stats_shape/query49.out | 6 +-
.../tpcds_sf100/no_stats_shape/query5.out | 13 +-
.../tpcds_sf100/no_stats_shape/query50.out | 2 +-
.../tpcds_sf100/no_stats_shape/query64.out | 4 +-
.../tpcds_sf100/no_stats_shape/query72.out | 4 +-
.../tpcds_sf100/no_stats_shape/query75.out | 6 +-
.../tpcds_sf100/no_stats_shape/query78.out | 6 +-
.../tpcds_sf100/no_stats_shape/query80.out | 6 +-
.../tpcds_sf100/no_stats_shape/query85.out | 2 +-
.../tpcds_sf100/no_stats_shape/query93.out | 2 +-
.../shape_check/tpcds_sf100/rf_prune/query14.out | 4 +-
.../shape_check/tpcds_sf100/rf_prune/query17.out | 4 +-
.../shape_check/tpcds_sf100/rf_prune/query18.out | 2 +-
.../shape_check/tpcds_sf100/rf_prune/query24.out | 2 +-
.../shape_check/tpcds_sf100/rf_prune/query25.out | 2 +-
.../shape_check/tpcds_sf100/rf_prune/query29.out | 2 +-
.../shape_check/tpcds_sf100/rf_prune/query35.out | 44 +-
.../shape_check/tpcds_sf100/rf_prune/query39.out | 22 +-
.../shape_check/tpcds_sf100/rf_prune/query40.out | 2 +-
.../shape_check/tpcds_sf100/rf_prune/query49.out | 6 +-
.../shape_check/tpcds_sf100/rf_prune/query5.out | 2 +-
.../shape_check/tpcds_sf100/rf_prune/query50.out | 2 +-
.../shape_check/tpcds_sf100/rf_prune/query54.out | 36 +-
.../shape_check/tpcds_sf100/rf_prune/query56.out | 22 +-
.../shape_check/tpcds_sf100/rf_prune/query60.out | 44 +-
.../shape_check/tpcds_sf100/rf_prune/query64.out | 2 +-
.../shape_check/tpcds_sf100/rf_prune/query72.out | 4 +-
.../shape_check/tpcds_sf100/rf_prune/query75.out | 99 +-
.../shape_check/tpcds_sf100/rf_prune/query78.out | 6 +-
.../shape_check/tpcds_sf100/rf_prune/query80.out | 6 +-
.../shape_check/tpcds_sf100/rf_prune/query85.out | 2 +-
.../shape_check/tpcds_sf100/rf_prune/query91.out | 12 +-
.../shape_check/tpcds_sf100/rf_prune/query93.out | 2 +-
.../data/shape_check/tpcds_sf100/shape/query14.out | 4 +-
.../data/shape_check/tpcds_sf100/shape/query17.out | 4 +-
.../data/shape_check/tpcds_sf100/shape/query18.out | 2 +-
.../data/shape_check/tpcds_sf100/shape/query24.out | 2 +-
.../data/shape_check/tpcds_sf100/shape/query25.out | 2 +-
.../data/shape_check/tpcds_sf100/shape/query29.out | 2 +-
.../data/shape_check/tpcds_sf100/shape/query35.out | 42 +-
.../data/shape_check/tpcds_sf100/shape/query39.out | 22 +-
.../data/shape_check/tpcds_sf100/shape/query40.out | 2 +-
.../data/shape_check/tpcds_sf100/shape/query49.out | 6 +-
.../data/shape_check/tpcds_sf100/shape/query5.out | 2 +-
.../data/shape_check/tpcds_sf100/shape/query50.out | 2 +-
.../data/shape_check/tpcds_sf100/shape/query54.out | 36 +-
.../data/shape_check/tpcds_sf100/shape/query56.out | 22 +-
.../data/shape_check/tpcds_sf100/shape/query60.out | 44 +-
.../data/shape_check/tpcds_sf100/shape/query64.out | 2 +-
.../data/shape_check/tpcds_sf100/shape/query72.out | 4 +-
.../data/shape_check/tpcds_sf100/shape/query75.out | 99 +-
.../data/shape_check/tpcds_sf100/shape/query78.out | 6 +-
.../data/shape_check/tpcds_sf100/shape/query80.out | 6 +-
.../data/shape_check/tpcds_sf100/shape/query85.out | 2 +-
.../data/shape_check/tpcds_sf100/shape/query91.out | 12 +-
.../data/shape_check/tpcds_sf100/shape/query93.out | 2 +-
.../tpcds_sf1000/bs_downgrade_shape/query54.out | 36 +-
.../data/shape_check/tpcds_sf1000/hint/query17.out | 2 +-
.../data/shape_check/tpcds_sf1000/hint/query25.out | 2 +-
.../data/shape_check/tpcds_sf1000/hint/query29.out | 2 +-
.../data/shape_check/tpcds_sf1000/hint/query39.out | 22 +-
.../data/shape_check/tpcds_sf1000/hint/query40.out | 2 +-
.../data/shape_check/tpcds_sf1000/hint/query49.out | 6 +-
.../data/shape_check/tpcds_sf1000/hint/query5.out | 13 +-
.../data/shape_check/tpcds_sf1000/hint/query50.out | 2 +-
.../data/shape_check/tpcds_sf1000/hint/query54.out | 36 +-
.../data/shape_check/tpcds_sf1000/hint/query64.out | 4 +-
.../data/shape_check/tpcds_sf1000/hint/query69.out | 2 +-
.../data/shape_check/tpcds_sf1000/hint/query72.out | 2 +-
.../data/shape_check/tpcds_sf1000/hint/query75.out | 99 +-
.../data/shape_check/tpcds_sf1000/hint/query78.out | 6 +-
.../data/shape_check/tpcds_sf1000/hint/query80.out | 6 +-
.../data/shape_check/tpcds_sf1000/hint/query81.out | 2 +-
.../data/shape_check/tpcds_sf1000/hint/query85.out | 2 +-
.../data/shape_check/tpcds_sf1000/hint/query93.out | 2 +-
.../shape_check/tpcds_sf1000/shape/query17.out | 2 +-
.../shape_check/tpcds_sf1000/shape/query24.out | 2 +-
.../shape_check/tpcds_sf1000/shape/query25.out | 2 +-
.../shape_check/tpcds_sf1000/shape/query29.out | 2 +-
.../shape_check/tpcds_sf1000/shape/query39.out | 22 +-
.../shape_check/tpcds_sf1000/shape/query40.out | 14 +-
.../shape_check/tpcds_sf1000/shape/query49.out | 6 +-
.../data/shape_check/tpcds_sf1000/shape/query5.out | 13 +-
.../shape_check/tpcds_sf1000/shape/query50.out | 2 +-
.../shape_check/tpcds_sf1000/shape/query54.out | 36 +-
.../shape_check/tpcds_sf1000/shape/query64.out | 4 +-
.../shape_check/tpcds_sf1000/shape/query69.out | 2 +-
.../shape_check/tpcds_sf1000/shape/query72.out | 30 +-
.../shape_check/tpcds_sf1000/shape/query75.out | 99 +-
.../shape_check/tpcds_sf1000/shape/query78.out | 14 +-
.../shape_check/tpcds_sf1000/shape/query80.out | 6 +-
.../shape_check/tpcds_sf1000/shape/query85.out | 2 +-
.../shape_check/tpcds_sf1000/shape/query93.out | 2 +-
.../runtime_filter/test_pushdown_setop.out | 32 +-
.../data/unique_seq_map_p0/test_unique_seq_map.out | 48 +
.../test_variant_compaction_empty_path_bug.out | 80 +
regression-test/framework/pom.xml | 5 +
.../org/apache/doris/regression/suite/Suite.groovy | 18 +-
.../doris/regression/suite/SuiteCluster.groovy | 4 +
regression-test/plugins/plugin_planner.groovy | 86 +
.../test_seq_map_backup_restore.groovy | 176 ++
.../test_ingest_seq_map_binlog.groovy | 114 ++
.../different_serialize.groovy} | 14 +-
...eate_partition_and_insert_overwrite_race.groovy | 92 +
.../datatype_p0/date/test_from_unixtime.groovy | 96 +-
.../suites/empty_relation/eliminate_empty.groovy | 4 +
.../hive/test_external_sql_block_rule.groovy | 130 +-
.../hive/test_hive_compress_type.groovy | 2 +-
.../hive/test_parquet_join_runtime_filter.groovy | 174 ++
.../iceberg/test_iceberg_jdbc_catalog.groovy | 316 ++++
.../iceberg/test_iceberg_sql_block_rule.groovy | 156 ++
.../paimon/test_paimon_sql_block_rule.groovy | 141 ++
.../test_inverted_index_collection_stats.groovy | 77 +
.../cdc/test_streaming_mysql_job_exclude.groovy | 104 +-
.../cdc/test_streaming_postgres_job.groovy | 171 ++
.../test_streaming_postgres_job_all_type.groovy | 143 ++
.../cdc/test_streaming_postgres_job_dup.groovy | 82 +
.../cdc/test_streaming_postgres_job_priv.groovy | 150 ++
.../agg_function/test_regr_sxx.groovy | 107 ++
.../agg_function/test_regr_sxy.groovy | 106 ++
.../agg_function/test_regr_syy.groovy | 107 ++
.../nereids_p0/aggregate/agg_error_msg.groovy | 8 +-
.../suites/nereids_p0/aggregate/aggregate.groovy | 2 +-
.../constant_propagation.groovy | 2 +-
.../test_having_with_aggregate_function.groovy | 13 +-
.../infer_set_operator_distinct.groovy | 3 +
.../suites/nereids_syntax_p0/analyze_agg.groovy | 116 +-
.../suites/nereids_syntax_p0/analyze_repeat.groovy | 178 ++
.../order_by_bind_priority.groovy | 4 +-
.../nereids_tpch_p0/tpch/push_topn_to_agg.groovy | 5 +-
.../grouping_sets/test_grouping_sets.groovy | 2 +-
.../suites/query_p0/runtimefilterV2/rfv2.groovy | 3 +
.../bucket_shuffle_set_operation.groovy | 130 ++
.../schema_change_p0/test_seq_map_value_add.groovy | 272 +++
.../test_seq_map_value_drop.groovy | 77 +
.../test_seq_map_value_modify.groovy | 43 +
.../test_seq_map_value_rename.groovy | 47 +
.../suites/shape_check/tpcds_sf100/load.groovy | 510 +++---
.../suites/shape_check/tpcds_sf1000/load.groovy | 501 +++---
.../sql_block_rule_p0/test_sql_block_rule.groovy | 6 +-
.../lazy_materialize/global_rowid_nullable.groovy | 105 ++
.../unique_seq_map_p0/test_unique_seq_map.groovy | 566 ++++++
.../ddl/orders_seq_map_create.sql | 20 +
.../unique_seq_map_p2/ddl/orders_seq_map_load.sql | 6 +
.../suites/unique_seq_map_p2/three/load.groovy | 66 +
.../test_variant_compaction_empty_path_bug.groovy | 142 ++
538 files changed, 21430 insertions(+), 6173 deletions(-)
create mode 100644 be/src/vec/core/hybrid_sorter.h
delete mode 100644 be/src/vec/exec/format/generic_reader.cpp
create mode 100644 be/test/util/jni_util_test.cpp
create mode 100644 cloud/test/recycler_batch_delete_test.cpp
create mode 100644
docker/thirdparties/docker-compose/hive/scripts/create_preinstalled_scripts/run84.hql
create mode 100644
docker/thirdparties/docker-compose/hive/scripts/preinstalled_data/parquet_table/runtime_filter_dim_small/dim_small.parquet
create mode 100644
docker/thirdparties/docker-compose/hive/scripts/preinstalled_data/parquet_table/runtime_filter_fact_big/fact_big.parquet
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/common/util/ColumnsUtil.java
copy
regression-test/suites/nereids_rules_p0/fill_up_missing_slots/test_having_with_aggregate_function.groovy
=>
fe/fe-core/src/main/java/org/apache/doris/datasource/iceberg/IcebergJdbcExternalCatalog.java
(64%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/property/metastore/IcebergJdbcMetaStoreProperties.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/expression/rules/SimplifyTimeFieldFromUnixtime.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/agg/RegrSxx.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/agg/RegrSxy.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/agg/RegrSyy.java
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/{agg/AnyValue.java
=> scalar/HourFromUnixtime.java} (55%)
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/{agg/AnyValue.java
=> scalar/MicrosecondFromUnixtime.java} (55%)
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/{agg/AnyValue.java
=> scalar/MinuteFromUnixtime.java} (55%)
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/{agg/AnyValue.java
=> scalar/SecondFromUnixtime.java} (55%)
copy
fs_brokers/cdc_client/src/main/java/org/apache/doris/cdcclient/source/factory/DataSource.java
=>
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/algebra/Except.java
(87%)
copy
fs_brokers/cdc_client/src/main/java/org/apache/doris/cdcclient/source/factory/DataSource.java
=>
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/algebra/Intersect.java
(86%)
copy
fs_brokers/cdc_client/src/main/java/org/apache/doris/cdcclient/source/factory/DataSource.java
=>
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/algebra/ShuffleType.java
(80%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/planner/DistributionMode.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/FileSplitterTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/property/metastore/IcebergJdbcMetaStorePropertiesTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/rules/expression/SimplifyTimeFieldFromUnixtimeTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/util/TestHelper.java
create mode 100644
fs_brokers/cdc_client/src/main/java/org/apache/doris/cdcclient/source/reader/JdbcIncrementalSourceReader.java
create mode 100644
fs_brokers/cdc_client/src/main/java/org/apache/doris/cdcclient/source/reader/postgres/PostgresSourceReader.java
create mode 100644
fs_brokers/cdc_client/src/main/java/org/apache/flink/cdc/connectors/postgres/source/PostgresConnectionPoolFactory.java
create mode 100644
regression-test/data/backup_restore/test_seq_map_backup_restore.out
create mode 100644
regression-test/data/external_table_p0/iceberg/test_iceberg_jdbc_catalog.out
copy
regression-test/data/job_p0/streaming_job/cdc/{test_streaming_mysql_job.out =>
test_streaming_postgres_job.out} (100%)
create mode 100644
regression-test/data/job_p0/streaming_job/cdc/test_streaming_postgres_job_all_type.out
copy
regression-test/data/job_p0/streaming_job/cdc/{test_streaming_mysql_job_exclude.out
=> test_streaming_postgres_job_priv.out} (91%)
create mode 100644
regression-test/data/nereids_function_p0/agg_function/test_regr_sxx.out
create mode 100644
regression-test/data/nereids_function_p0/agg_function/test_regr_sxy.out
create mode 100644
regression-test/data/nereids_function_p0/agg_function/test_regr_syy.out
create mode 100644 regression-test/data/nereids_syntax_p0/analyze_repeat.out
create mode 100644
regression-test/data/query_p0/set_operations/bucket_shuffle_set_operation.out
copy
regression-test/data/{job_p0/streaming_job/cdc/test_streaming_mysql_job_exclude.out
=> schema_change_p0/test_seq_map_value_add.out} (58%)
copy
regression-test/data/{job_p0/streaming_job/cdc/test_streaming_mysql_job_exclude.out
=> schema_change_p0/test_seq_map_value_drop.out} (62%)
create mode 100644
regression-test/data/unique_seq_map_p0/test_unique_seq_map.out
create mode 100644
regression-test/data/variant_p0/test_variant_compaction_empty_path_bug.out
create mode 100644
regression-test/suites/backup_restore/test_seq_map_backup_restore.groovy
create mode 100644
regression-test/suites/ccr_syncer_p0/test_ingest_seq_map_binlog.groovy
rename
regression-test/suites/cloud_p0/{diffrent_serialize/diffrent_serialize.groovy
=> different_serialize/different_serialize.groovy} (81%)
create mode 100644
regression-test/suites/cloud_p0/partition/test_create_partition_and_insert_overwrite_race.groovy
create mode 100644
regression-test/suites/external_table_p0/hive/test_parquet_join_runtime_filter.groovy
create mode 100644
regression-test/suites/external_table_p0/iceberg/test_iceberg_jdbc_catalog.groovy
create mode 100644
regression-test/suites/external_table_p0/iceberg/test_iceberg_sql_block_rule.groovy
create mode 100644
regression-test/suites/external_table_p0/paimon/test_paimon_sql_block_rule.groovy
create mode 100644
regression-test/suites/inverted_index_p0/test_inverted_index_collection_stats.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/test_streaming_postgres_job.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/test_streaming_postgres_job_all_type.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/test_streaming_postgres_job_dup.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/cdc/test_streaming_postgres_job_priv.groovy
create mode 100644
regression-test/suites/nereids_function_p0/agg_function/test_regr_sxx.groovy
create mode 100644
regression-test/suites/nereids_function_p0/agg_function/test_regr_sxy.groovy
create mode 100644
regression-test/suites/nereids_function_p0/agg_function/test_regr_syy.groovy
create mode 100644
regression-test/suites/nereids_syntax_p0/analyze_repeat.groovy
create mode 100644
regression-test/suites/query_p0/set_operations/bucket_shuffle_set_operation.groovy
create mode 100644
regression-test/suites/schema_change_p0/test_seq_map_value_add.groovy
create mode 100644
regression-test/suites/schema_change_p0/test_seq_map_value_drop.groovy
create mode 100644
regression-test/suites/schema_change_p0/test_seq_map_value_modify.groovy
create mode 100644
regression-test/suites/schema_change_p0/test_seq_map_value_rename.groovy
create mode 100644
regression-test/suites/topn_optimize/lazy_materialize/global_rowid_nullable.groovy
create mode 100644
regression-test/suites/unique_seq_map_p0/test_unique_seq_map.groovy
create mode 100644
regression-test/suites/unique_seq_map_p2/ddl/orders_seq_map_create.sql
create mode 100644
regression-test/suites/unique_seq_map_p2/ddl/orders_seq_map_load.sql
create mode 100644 regression-test/suites/unique_seq_map_p2/three/load.groovy
create mode 100644
regression-test/suites/variant_p0/test_variant_compaction_empty_path_bug.groovy
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
