This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a change to branch branch-4.0-preview
in repository https://gitbox.apache.org/repos/asf/doris.git
from d5d1d292217 [fix](nereids) do not push RF into nested cte (#33769)
new c17b08a7ac8 [fix](plsql) Fix handle select that fe can do without be
(#33363)
new 43f3852dece [Chore](descriptors) remove unused codes for descriptors
(#33408)
new 515deeb2854 [testcase](hive)add exception test for hive txn (#33278)
new 73445ca65d8 [Bug](materialized-view) forbid create mv with value
column before key column (#33436)
new 5453589a84d [Chore](build) add cloud directory to build-support script
(#33468)
new 5b9374b1a25 [Enhancement](auto-partition) support all intervals for
date_trunc in auto partition (#33439)
new 84268044a1e [fix](compaction) fix single replica compaction input
rowsets (#33053)
new 71407db62c4 [enhancement](exception) enble exception logic in pipeline
execute thread (#33437)
new 914d84e9ab5 [case](regression) Add backup restore with NGRAM bloom
filter (#33479)
new 62fda718403 [fix](compress) data decompress failed while max_len
equals 8M (#33456)
new 4609c71b33e [fix](catalog) fix resource is not reopen when rename
catalog (#33432)
new fbfeb699c1c [chore](test) remove some outdated datetime test case
(#33476)
new 54161cdaa44 [fix](debug point) fix gcc compile (#33451)
new cfc7f418c30 [fix](test) remove distribute node of shape in some
regression test (#33463)
new 39fa347885d [fix](nereids) SemiJoinSemiJoinTransposeProject rule
didn't handle mark join correctly (#33401)
new be92451814d [fix](mtmv)add logs for mv_infos() (#33485)
new 8efb658545e [fix](nereids) do not transpose semi join agg when mark
join (#32475)
new 9c28ff81ae6 [Fix](inverted index) fix build index error status when
batch_next (#33532)
new 1c74b83ccd0 [improve](fold) support complex type for constant folding
(#32867)
new dcf7dbcc8c9 [fix](nereids) translate rf target expression using
targetSlot #33531
new 2fa55baf0ec [pipelineX](fix) Fix data pooling judgement for bucket
join (#33533)
new 500d0e48348 [fix](routine-load) fix consumer hang when kafka exception
causing can not query (#33492)
new 973f76810ef [fix](timeout) query timeout was not correctly set
(#33444)
new 5b56c67bfdb [Fix](Nereids) fix leading hint should have all tables in
one query block (#33517)
new 6bb0386953e [pipelineX](broadcast) Set dependency ready if a limited
exchange returns EOS (#33525)
new ce7ee50cd53 [fix](feservice) remove connect context (#33583)
new 0d8112993be [Fix](timezone) fix miss of expected rounding of Date type
with timezone #33553
new 1a10d2a9c69 [case](regression) Add backup restore test for hdfs repo
(#33581)
new 39c43d21b4a [fix](schema change) follow fe set sc fail replicas as bad
(#33569)
new 99f8bd7721a [fix](merge-iterator) Fix mem leak when get next batch
failed (#33627)
new 59f011ff10f [Fix](compaction) Fix single compaction to get all local
versions (#33480)
new ef6f6f17778 [fix](nereids) ExtractAndNormalizeWindowExpression should
only normalize alias in output (#33527)
new e09739a0d10 [fix](catalog) Remove unexpected cleanup when reading jdbc
data (#33529)
new 878e52b16c0 [fix](test) fix some unstable p2 test cases (#33637)
new db4f97872c8 [fix](auto bucket) Fix hit not support alter
estimate_partition_size (#33670)
new f0eb359b233 [fix](nereids) Use correct PREAGGREGATION in
agg(filter(scan)) (#33454)
new 8ef2cbaae46 [case](regression) Add backup temp partition case (#33646)
new c67ee74be9b [fix](fe) Fix finalizeCommand `sendAndFlush`
NullPointerException (#33420)
new 147aa8a6c0f [fix](testcase) fix miss used global variables in index
testcases (#33293)
new f15b441f224 [fix](routine-load) fix data lost when FE leader change
(#33678)
new d79d0a179c8 [fix](analyze) avoid
java.util.ConcurrentModificationException (#33674)
new ed39f687caa [Bug](runtime-filter) make need_local_merge unrelated with
broadcast and support merge on bitmap_filter (#33636)
new 4485856f592 [FIX](cast)fix full/right out join for cast array (#33475)
new 1fd44a2eb4f [fix](nereids)InSubquery's withChildren method lost
typeCoercionExpr (#33692)
new ab2b62ed81e [fix](Nereids) could not query variant that not from table
(#33704)
new 14d028bb53f [runtime filter](fix) Fix wrong results caused by
IN_OR_BLOOM filter (#33701)
new 377c6c43976 [fix](cloud) Fix some regression case due to #33347
(#33727)
new f9b59111869 [Fix](executor)Fix routine load failed when can not find
group (#33596)
new f414471a08b [fix](move-memtable) close wait on all sinks (#33710)
new 677c4e59218 [test](xor) add test for xor #33731
new a229380045b [fix](move-memtable) ignore single replica load when move
memtable (#32845)
new 940ac3d121a [fix](chore) update some CHECK to CHECK_EQ, to print more
details while CHECK failed (#33709)
new aebf6be9353 [FIX](load)fix load with split-by-string (#33713)
new c322a63269a [Fix](Json type) forbit schema change adding JSON columns
with none null default value (#33686)
new 903e1da0ce1 [fix](test) remove array_intersect case since its result
is not stable (#33742)
new 988ab27abbb [fix](inverted index) normal process query for null
condition when index is missing (#33663)
new 48d888e4cbc [fix](regression test) fix test_schema_change_fail (#33753)
new a05480414a2 [fix](Nereids) dphyper support evaluate join that has one
side condition (#33702)
new a40dc9a3bf0 [Fix](Variant Type) forbit distribution info contains
variant columns (#33707)
new bba895dcf18 [fix](inverted index) fix incorrect case test_index_delete
(#33609)
new 98bee750785 [fix](planner) create view statement should forbid mv
rewrite (#33784)
new 9341cbb4a81 [Fix](Variant) VariantRootColumnIterator::read_by_rowids
with wrong null map size (#33734)
new 35f6bb78d4c [fix](Nereids): add whole tree rewriter when root is not
CTEAnchor (#33591)
new 79aacfe897b [Fix](nereids) fix bind order by expression logic (#33843)
new a72b027aabc [Fix](planner) fix create view star except and modify cast
to sql (#33726)
new 9a1c99ebe14 [bugfix](paimon) Create paimon catalog with hadoop user
(#33833)
new 3688433fcbd [Fix](inverted index) fix wrong need read data opt when
encounters columnA > columnB predicate (#33855)
new 528af700638 [fix](multi-table-load) fix single stream multi table load
cannot finish (#33816)
new c6117cb7a56 [Fix](clean trash) Fix clean trash use agent task (#33912)
new 70f21d92cef [fix](arrow_flight_sql) Fix ArrowSchema column alias
(#33490)
new 83ff0f483de [fix](collation) add back id 33 collation for bi
compatible (#33787)
new eb5e777166a [fix](test)fix auto partition date file not exists (#33827)
new 2846c4326af [fix](stream-load) fix query id is zero in stream load
log (#33954)
new 62db0318651 [Fix](Jdbc-Hive) fix the order of partition keys (#33963)
new 4ba55b93e54 [FIX]fix cidr func with const param (#33968)
new 63449689014 [fix](jni-connector) avoid core dump if init connector
failed (#34007)
new 3f9e1a2160f [bug](fold) fix fold date/datetime error as null (#33845)
new f50bed1bd62 [fix](merge-cloud) Fix incorrect num_expired in
`recycle_rowsets()` (#34022)
new c56f1106bb5 [fix](merge-cloud) Remove expired loadJob when
replayEndLoadJob (#34020)
new 6e1a7acd6e6 [behavior change](fe) Change `ShowProcessStmt` output
column format (#33975)
new 7a8ac207967 [fix](group commit) Fix the timeout to wait wal finished
when schema change (#34021)
new 4c56762a7b8 [bug](test) fix test case failed with fuuzy fold constatnt
to false (#34052)
new 16998e039e6 [fix](routine-load) fix routine load lag is negative
(#33846)
new c293dd23cee [bugfix](core) close method should check if the pointer is
nullptr (#34067)
The 84 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
be/src/agent/agent_server.cpp | 3 +
be/src/agent/task_worker_pool.cpp | 9 +
be/src/agent/task_worker_pool.h | 2 +
be/src/exprs/runtime_filter.cpp | 15 +-
be/src/http/action/stream_load.cpp | 3 +
be/src/http/http_common.h | 1 +
be/src/io/fs/multi_table_pipe.cpp | 22 +-
be/src/io/fs/stream_load_pipe.cpp | 9 +
be/src/io/fs/stream_load_pipe.h | 4 +
be/src/olap/memtable.h | 2 +-
be/src/olap/olap_server.cpp | 2 +-
be/src/olap/rowset/segment_v2/column_reader.cpp | 5 +-
be/src/olap/rowset/segment_v2/column_writer.cpp | 38 +-
.../inverted_index/query/disjunction_query.cpp | 48 +-
.../inverted_index/query/disjunction_query.h | 7 +-
.../rowset/segment_v2/inverted_index_reader.cpp | 22 +-
.../olap/rowset/segment_v2/inverted_index_reader.h | 2 +
be/src/olap/rowset/segment_v2/segment_iterator.cpp | 11 +-
be/src/olap/rowset/segment_v2/segment_writer.cpp | 6 +-
.../rowset/segment_v2/vertical_segment_writer.cpp | 6 +-
be/src/olap/schema_change.cpp | 11 +-
be/src/olap/single_replica_compaction.cpp | 65 +-
be/src/olap/single_replica_compaction.h | 3 +-
be/src/olap/skiplist.h | 462 -----------
be/src/olap/tablet.cpp | 35 +-
be/src/olap/tablet.h | 5 +-
be/src/olap/task/index_builder.cpp | 6 +
be/src/pipeline/exec/exchange_sink_buffer.cpp | 2 +
be/src/pipeline/exec/exchange_sink_buffer.h | 9 +-
be/src/pipeline/exec/exchange_sink_operator.cpp | 4 +-
be/src/pipeline/exec/hashjoin_probe_operator.cpp | 4 +-
.../exec/nested_loop_join_build_operator.cpp | 5 -
be/src/pipeline/exec/scan_operator.cpp | 5 +-
be/src/pipeline/exec/scan_operator.h | 8 +-
be/src/pipeline/task_scheduler.cpp | 4 +
be/src/runtime/descriptor_helper.h | 10 +-
be/src/runtime/descriptors.cpp | 132 +---
be/src/runtime/descriptors.h | 161 +---
be/src/runtime/fold_constant_executor.cpp | 61 +-
be/src/runtime/group_commit_mgr.cpp | 27 +-
.../runtime/routine_load/data_consumer_group.cpp | 3 +-
be/src/runtime/runtime_state.cpp | 7 +-
.../runtime/stream_load/stream_load_executor.cpp | 6 +-
be/src/service/backend_service.cpp | 9 -
be/src/service/backend_service.h | 4 -
be/src/util/arrow/row_batch.cpp | 4 +-
be/src/util/block_compression.cpp | 16 +-
be/src/util/debug_points.h | 8 +-
be/src/vec/exec/jni_connector.cpp | 5 +-
be/src/vec/exec/join/vhash_join_node.cpp | 7 +-
be/src/vec/exec/scan/vscan_node.cpp | 43 +-
be/src/vec/exprs/vexpr.h | 1 +
be/src/vec/exprs/vslot_ref.cpp | 10 +-
be/src/vec/exprs/vslot_ref.h | 2 +
be/src/vec/functions/function_cast.h | 2 +-
be/src/vec/functions/function_ip.h | 127 ++-
be/src/vec/olap/vgeneric_iterators.cpp | 4 +-
be/src/vec/olap/vgeneric_iterators.h | 24 +-
be/src/vec/runtime/vdatetime_value.cpp | 20 +
be/src/vec/runtime/vdatetime_value.h | 13 +
be/src/vec/sink/load_stream_map_pool.cpp | 16 +-
be/src/vec/sink/writer/vtablet_writer_v2.cpp | 8 +-
be/test/olap/single_compaction_test.cpp | 147 ++++
be/test/olap/skiplist_test.cpp | 423 ----------
be/test/olap/tablet_test.cpp | 36 +
be/test/testutil/desc_tbl_builder.cpp | 7 +-
be/test/vec/exec/parquet/parquet_thrift_test.cpp | 2 +-
be/test/vec/exprs/vexpr_test.cpp | 2 +-
build-support/check-format.sh | 2 +-
build-support/clang-format.sh | 2 +-
cloud/src/recycler/recycler.cpp | 2 +-
cloud/src/recycler/s3_accessor.cpp | 3 +-
.../org/apache/doris/jdbc/DefaultJdbcExecutor.java | 2 -
.../java/org/apache/doris/catalog/ScalarType.java | 6 +-
.../java/org/apache/doris/alter/AlterHandler.java | 1 +
.../java/org/apache/doris/alter/AlterJobV2.java | 5 +
.../doris/alter/MaterializedViewHandler.java | 16 +-
.../java/org/apache/doris/alter/RollupJobV2.java | 27 +-
.../org/apache/doris/alter/SchemaChangeJobV2.java | 27 +-
.../java/org/apache/doris/analysis/CastExpr.java | 7 +-
.../java/org/apache/doris/analysis/ColumnDef.java | 12 +-
.../java/org/apache/doris/analysis/MapLiteral.java | 2 +-
.../analysis/ModifyTablePropertiesClause.java | 2 +
.../apache/doris/analysis/NativeInsertStmt.java | 7 +-
.../apache/doris/analysis/PartitionExprUtil.java | 4 +
.../java/org/apache/doris/analysis/SelectStmt.java | 7 +-
.../apache/doris/analysis/SetOperationStmt.java | 7 +
.../apache/doris/analysis/ShowProcesslistStmt.java | 19 +-
.../org/apache/doris/analysis/SlotDescriptor.java | 2 +-
.../java/org/apache/doris/analysis/SlotRef.java | 1 +
.../org/apache/doris/analysis/TupleDescriptor.java | 33 +-
.../main/java/org/apache/doris/catalog/Env.java | 31 +-
.../main/java/org/apache/doris/catalog/MTMV.java | 19 +
.../org/apache/doris/datasource/CatalogMgr.java | 4 +
.../apache/doris/datasource/InternalCatalog.java | 6 +
.../doris/datasource/hive/HMSTransaction.java | 91 +--
.../doris/datasource/hive/HiveMetadataOps.java | 14 +-
.../org/apache/doris/datasource/hive/HiveUtil.java | 65 +-
.../hive/PostgreSQLJdbcHMSCachedClient.java | 4 +-
.../datasource/hive/ThriftHMSCachedClient.java | 76 +-
.../datasource/paimon/PaimonExternalCatalog.java | 16 +-
.../main/java/org/apache/doris/fs/FileSystem.java | 9 +
.../org/apache/doris/fs/LocalDfsFileSystem.java | 245 ++++++
.../java/org/apache/doris/fs/LocalFileSystem.java | 76 --
.../apache/doris/fs/remote/dfs/DFSFileSystem.java | 45 ++
.../doris/httpv2/controller/SessionController.java | 19 +-
.../src/main/java/org/apache/doris/load/Load.java | 6 +-
.../apache/doris/load/loadv2/LoadLoadingTask.java | 2 +-
.../org/apache/doris/load/loadv2/LoadManager.java | 12 +
.../doris/load/loadv2/LoadingTaskPlanner.java | 10 +-
.../load/routineload/KafkaRoutineLoadJob.java | 15 +-
.../doris/load/routineload/KafkaTaskInfo.java | 52 +-
.../doris/load/routineload/RoutineLoadJob.java | 8 +-
.../glue/translator/ExpressionTranslator.java | 6 +-
.../glue/translator/RuntimeFilterTranslator.java | 33 +-
.../org/apache/doris/nereids/hint/LeadingHint.java | 59 +-
.../nereids/jobs/rewrite/CostBasedRewriteJob.java | 18 +-
.../nereids/rules/analysis/BindExpression.java | 4 +-
.../nereids/rules/analysis/ExpressionAnalyzer.java | 8 +-
.../doris/nereids/rules/analysis/LeadingJoin.java | 2 +-
.../join/SemiJoinSemiJoinTransposeProject.java | 13 +-
.../expression/rules/FoldConstantRuleOnBE.java | 416 +++++++++-
.../ExtractAndNormalizeWindowExpression.java | 5 +-
.../rules/rewrite/TransposeSemiJoinAgg.java | 1 +
.../rules/rewrite/TransposeSemiJoinAggProject.java | 1 +
.../mv/SelectMaterializedIndexWithAggregate.java | 16 +-
.../nereids/trees/expressions/InSubquery.java | 2 +-
.../expressions/functions/scalar/Tokenize.java | 10 +-
.../trees/expressions/literal/MapLiteral.java | 5 +-
.../trees/expressions/literal/StructLiteral.java | 5 +-
.../doris/nereids/trees/plans/PreAggStatus.java | 1 +
.../plans/commands/info/ColumnDefinition.java | 4 +
.../trees/plans/logical/LogicalOlapScan.java | 12 +
.../org/apache/doris/planner/OlapScanNode.java | 12 +-
.../java/org/apache/doris/planner/ScanNode.java | 7 +-
.../apache/doris/planner/StreamLoadPlanner.java | 28 +-
.../src/main/java/org/apache/doris/plsql/Stmt.java | 2 +-
.../doris/plsql/executor/PlsqlQueryExecutor.java | 1 +
.../apache/doris/plsql/executor/PlsqlResult.java | 3 +-
.../apache/doris/plsql/executor/QueryResult.java | 4 +
.../java/org/apache/doris/qe/ConnectContext.java | 29 +-
.../java/org/apache/doris/qe/ConnectProcessor.java | 21 +-
.../java/org/apache/doris/qe/ConnectScheduler.java | 4 +-
.../main/java/org/apache/doris/qe/Coordinator.java | 13 +-
.../java/org/apache/doris/qe/ResultReceiver.java | 41 +-
.../java/org/apache/doris/qe/SessionVariable.java | 8 +
.../java/org/apache/doris/qe/ShowExecutor.java | 28 +-
.../java/org/apache/doris/qe/StmtExecutor.java | 21 +
.../resource/workloadgroup/WorkloadGroupMgr.java | 17 +-
.../apache/doris/rewrite/FoldConstantsRule.java | 1 +
.../java/org/apache/doris/service/FeServer.java | 2 +
.../apache/doris/service/FrontendServiceImpl.java | 4 +-
.../apache/doris/statistics/AnalysisManager.java | 8 +-
.../doris/tablefunction/MetadataGenerator.java | 37 +
.../tablefunction/MvInfosTableValuedFunction.java | 16 +
.../java/org/apache/doris/task/AgentBatchTask.java | 10 +
.../java/org/apache/doris/task/CleanTrashTask.java | 25 +-
.../analysis/CreateTableAsSelectStmtTest.java | 4 +-
.../org/apache/doris/analysis/MapLiteralTest.java | 12 +-
.../apache/doris/analysis/StructLiteralTest.java | 4 +-
.../org/apache/doris/common/GenericPoolTest.java | 5 -
.../doris/datasource/HMSCachedClientTest.java | 328 ++++++++
.../doris/datasource/hive/HmsCommitTest.java | 374 ++++++---
.../jobs/joinorder/hypergraph/OtherJoinTest.java | 18 +
.../join/SemiJoinSemiJoinTransposeProjectTest.java | 24 +
.../rules/rewrite/mv/SelectRollupIndexTest.java | 34 +-
.../nereids/trees/expressions/LiteralTest.java | 265 +++++++
.../doris/nereids/util/HyperGraphBuilder.java | 5 +-
.../doris/planner/TableFunctionPlanTest.java | 18 +-
.../org/apache/doris/qe/ConnectContextTest.java | 4 +-
.../org/apache/doris/service/FlightSqlJDBC.java | 1 -
.../apache/doris/utframe/MockedBackendFactory.java | 5 -
gensrc/proto/descriptors.proto | 8 +-
gensrc/thrift/AgentService.thrift | 3 +
gensrc/thrift/BackendService.thrift | 2 -
gensrc/thrift/Descriptors.thrift | 8 +-
gensrc/thrift/Exprs.thrift | 1 +
gensrc/thrift/PaloInternalService.thrift | 1 +
gensrc/thrift/Types.thrift | 1 +
.../data/correctness_p0/test_bit_function.out | 17 +
.../datetimev1/test_datetimev1_calc.out | 18 -
.../data/datatype_p0/datetimev2/only_date.csv | 2 +
.../datatype_p0/datetimev2/test_invalid_hour.out | 1 -
.../data/datatype_p0/datetimev2/test_timezone.out | 3 -
.../datatype_p0/datetimev2/test_tz_streamload.out | 4 +
.../jdbc/test_mysql_jdbc_catalog.out | 6 +
.../fault_injection_p0/test_build_index_fault.out | 6 +
.../test_no_index_null_fault_injection.out} | 0
.../data/insert_p0/insert_group_commit_into.out | 32 +-
.../test_index_no_need_read_data.out | 74 ++
.../stream_load/test_array_split_string.csv | 1 +
.../stream_load/test_array_with_func_load.out} | 13 +-
.../explain/test_scan_preaggregation_explain.out} | 14 +-
.../data/nereids_p0/hint/fix_leading.out | 25 +
.../data/nereids_p0/hint/multi_leading.out | 4 +-
.../filter_push_down/push_filter_through.out | 546 +++++--------
.../transposeJoin/transposeSemiJoinAgg.out | 8 +
.../nereids_syntax_p0/order_by_bind_priority.out | 22 +
.../rf_prune/query10.out | 12 +-
.../nereids_tpcds_shape_sf100_p0/shape/query10.out | 12 +-
.../runtime_filter/test_pushdown_setop.out | 35 +-
.../data/plsql_p0/test_plsql_variable.out | 6 +
...nnel_account_consume_history_reconciliation.csv | 200 +++++
.../data/query_p0/join/dwd_oa_customer.csv | 200 +++++
regression-test/data/query_p0/join/tb_media.csv | 10 +
.../query_p0/join/tb_reconciliation_detail.csv | 200 +++++
.../join/tb_reconciliation_media_order.csv | 200 +++++
.../query_p0/join/test_join_with_cast_array.out | 194 +++++
.../ip_functions/test_ipv4_cidr_to_range.out | 30 +
.../test_ipv6_cidr_to_range_function.out | 33 +
.../sql/select_from_value.out} | 13 +-
.../data/variant_p0/topn_opt_read_by_rowids.out | 14 +
.../create_view_star_except_and_cast_to_sql.out | 11 +
.../backup_restore/test_backup_restore.groovy | 9 +-
...st_backup_restore_backup_temp_partition.groovy} | 58 +-
.../test_backup_restore_ngram_bloom_filter.groovy | 168 ++++
...groovy => test_backup_restore_with_hdfs.groovy} | 19 +-
.../auth/test_grant_revoke_cluster_role.groovy | 38 +-
.../auth/test_grant_revoke_cluster_to_user.groovy | 28 +-
.../suites/correctness_p0/test_bit_function.groovy | 9 +
.../suites/correctness_p0/test_mv_case.groovy | 32 +
.../datetimev1/test_datetimev1_calc.groovy | 10 +-
.../datetimev2/test_invalid_hour.groovy | 10 +-
.../datatype_p0/datetimev2/test_timezone.groovy | 5 +-
.../datetimev2/test_tz_streamload.groovy | 24 +
.../decimalv3/test_decimal256_index.groovy | 3 +
.../external_table_p0/hive/test_hive_other.groovy | 4 +-
.../jdbc/test_mysql_jdbc_catalog.groovy | 20 +-
.../hive/test_select_count_optimize.groovy | 42 +-
.../test_admin_clean_trash.groovy | 687 ++++++++++++++++
.../test_build_index_fault.groovy | 24 +-
.../test_no_index_null_fault_injection.groovy | 65 ++
.../insert_p0/insert_group_commit_into.groovy | 66 +-
.../test_index_no_need_read_data.groovy | 871 ++++++++++++++++++++-
.../suites/inverted_index_p0/test_show_data.groovy | 27 +-
.../stream_load/test_array_with_func_load.groovy | 56 ++
.../test_stream_load_move_memtable.groovy | 9 +
regression-test/suites/mv_p0/unique/unique.groovy | 6 +
.../nereids_function_p0/agg_function/agg.groovy | 131 ++--
.../nereids_p0/aggregate/agg_window_project.groovy | 2 +
.../test_scan_preaggregation_explain.groovy | 49 ++
.../suites/nereids_p0/hint/fix_leading.groovy | 4 +
.../suites/nereids_p0/hint/multi_leading.groovy | 8 +-
.../nereids_p0/subquery/test_subquery.groovy | 1 +
.../suites/nereids_p0/test_mv_select.groovy | 4 +
.../push_filter_inside_join.groovy | 1 +
.../filter_push_down/push_filter_through.groovy | 16 +-
.../transposeJoin/transposeSemiJoinAgg.groovy | 16 +
.../order_by_bind_priority.groovy | 36 +
.../test_auto_range_partition.groovy | 41 +-
.../doris_dbgen_conf/two_stream_load_conflict.yaml | 4 +
.../auto_partition/sql/multi_thread_load.groovy | 22 +-
.../suites/plsql_p0/test_plsql_variable.groovy | 27 +
.../query_p0/explain/test_pushdown_explain.groovy | 14 +
.../query_p0/join/test_join_with_cast_array.groovy | 291 +++++++
.../ip_functions/test_ipv4_cidr_to_range.groovy | 3 +
.../test_ipv6_cidr_to_range_function.groovy | 6 +-
.../test_unique_model_schema_key_change.groovy | 14 +-
.../test_schema_change_fail.groovy | 94 +++
.../suites/show_p0/test_show_processlist.groovy | 40 +
regression-test/suites/variant_p0/load.groovy | 12 +
.../suites/variant_p0/sql/select_from_value.sql | 1 +
.../variant_p0/topn_opt_read_by_rowids.groovy | 104 +++
.../suites/variant_p0/with_index/load.groovy | 5 +-
.../create_view_star_except_and_cast_to_sql.groovy | 45 ++
thirdparty/patches/librdkafka-1.9.2.patch | 31 +
266 files changed, 7749 insertions(+), 2830 deletions(-)
delete mode 100644 be/src/olap/skiplist.h
create mode 100644 be/test/olap/single_compaction_test.cpp
delete mode 100644 be/test/olap/skiplist_test.cpp
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/fs/LocalDfsFileSystem.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/fs/LocalFileSystem.java
copy regression-test/suites/query_p0/explain/test_pushdown_explain.groovy =>
fe/fe-core/src/main/java/org/apache/doris/task/CleanTrashTask.java (59%)
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/HMSCachedClientTest.java
create mode 100644 regression-test/data/datatype_p0/datetimev2/only_date.csv
copy regression-test/data/{inverted_index_p0/test_compound.out =>
fault_injection_p0/test_no_index_null_fault_injection.out} (100%)
create mode 100644
regression-test/data/load_p0/stream_load/test_array_split_string.csv
copy regression-test/data/{plsql_p0/test_plsql_variable.out =>
load_p0/stream_load/test_array_with_func_load.out} (57%)
copy regression-test/data/{plsql_p0/test_plsql_variable.out =>
nereids_p0/explain/test_scan_preaggregation_explain.out} (58%)
create mode 100644
regression-test/data/query_p0/join/dwd_channel_account_consume_history_reconciliation.csv
create mode 100644 regression-test/data/query_p0/join/dwd_oa_customer.csv
create mode 100644 regression-test/data/query_p0/join/tb_media.csv
create mode 100644
regression-test/data/query_p0/join/tb_reconciliation_detail.csv
create mode 100644
regression-test/data/query_p0/join/tb_reconciliation_media_order.csv
create mode 100644
regression-test/data/query_p0/join/test_join_with_cast_array.out
copy regression-test/data/{plsql_p0/test_plsql_variable.out =>
variant_p0/sql/select_from_value.out} (57%)
create mode 100644 regression-test/data/variant_p0/topn_opt_read_by_rowids.out
create mode 100644
regression-test/data/view_p0/create_view_star_except_and_cast_to_sql.out
copy regression-test/suites/backup_restore/{test_backup_restore.groovy =>
test_backup_restore_backup_temp_partition.groovy} (62%)
create mode 100644
regression-test/suites/backup_restore/test_backup_restore_ngram_bloom_filter.groovy
copy regression-test/suites/backup_restore/{test_backup_restore.groovy =>
test_backup_restore_with_hdfs.groovy} (84%)
create mode 100644
regression-test/suites/fault_injection_p0/test_admin_clean_trash.groovy
create mode 100644
regression-test/suites/fault_injection_p0/test_no_index_null_fault_injection.groovy
create mode 100644
regression-test/suites/load_p0/stream_load/test_array_with_func_load.groovy
create mode 100644
regression-test/suites/nereids_p0/explain/test_scan_preaggregation_explain.groovy
create mode 100644
regression-test/suites/query_p0/join/test_join_with_cast_array.groovy
create mode 100644
regression-test/suites/schema_change_p2/test_schema_change_fail.groovy
create mode 100644 regression-test/suites/show_p0/test_show_processlist.groovy
create mode 100644 regression-test/suites/variant_p0/sql/select_from_value.sql
create mode 100644
regression-test/suites/variant_p0/topn_opt_read_by_rowids.groovy
create mode 100644
regression-test/suites/view_p0/create_view_star_except_and_cast_to_sql.groovy
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]