Revert "branch-2.1: [bug](auto partition) Fix be crash with single replica insert" (#48926)

Reverts apache/doris#48536 BE core after this PR， revert it。 *** Check failure stack trace: *** @ 0x564fa82e5606 google::LogMessage::SendToLog() @ 0x564fa82e2050 google::LogMessage::Flush() @ 0x564fa82e5e49 google::LogMessageFatal::~LogMessageFatal() @ 0x564fa9dcb44a (unknown) @ 0x564fa8a19e05 google::protobuf::internal::LogMessage::Finish() @ 0x564f9e68d49e google::protobuf::Map<>::at<>() @ 0x564f9e68b805 doris::TabletsChannel::_commit_txn() @ 0x564f9e68b20b doris::TabletsChannel::close() @ 0x564f9e591fee doris::LoadChannel::_handle_eos() @ 0x564f9e591ca2 doris::LoadChannel::add_batch() @ 0x564f9e58c300 doris::LoadChannelMgr::add_batch() @ 0x564f9e702bb1 std::_Function_handler<>::_M_invoke() @ 0x564f9e71d3db doris::WorkThreadPool<>::work_thread() @ 0x564fab0ad760 execute_native_thread_routine @ 0x7efd907a8ac3 (unknown) @ 0x7efd9083a850 (unknown) @ (nil) (unknown)
2025-03-11 17:44:34 +08:00
parent 2c358a1464
commit bc3e93a8a9
9 changed files with 10 additions and 375 deletions
--- a/be/src/runtime/tablets_channel.cpp
+++ b/be/src/runtime/tablets_channel.cpp
@ -357,6 +357,8 @@ Status TabletsChannel::close(LoadChannel* parent, const PTabletWriterAddBlockReq
        // 5. commit all writers

        for (auto* writer : need_wait_writers) {
+            PSlaveTabletNodes slave_nodes;
+
            // close may return failed, but no need to handle it here.
            // tablet_vec will only contains success tablet, and then let FE judge it.
            _commit_txn(writer, req, res);
@ -393,15 +395,9 @@ Status TabletsChannel::close(LoadChannel* parent, const PTabletWriterAddBlockReq

 void TabletsChannel::_commit_txn(DeltaWriter* writer, const PTabletWriterAddBlockRequest& req,
                                 PTabletWriterAddBlockResult* res) {
-    PSlaveTabletNodes slave_nodes;
-    if (_write_single_replica) {
-        auto& nodes_map = req.slave_tablet_nodes();
-        auto it = nodes_map.find(writer->tablet_id());
-        if (it != nodes_map.end()) {
-            slave_nodes = it->second;
-        }
-    }
-    Status st = writer->commit_txn(slave_nodes);
+    Status st = writer->commit_txn(_write_single_replica
+                                           ? req.slave_tablet_nodes().at(writer->tablet_id())
+                                           : PSlaveTabletNodes {});
    if (st.ok()) [[likely]] {
        auto* tablet_vec = res->mutable_tablet_vec();
        PTabletInfo* tablet_info = tablet_vec->Add();
--- a/be/src/vec/sink/vrow_distribution.cpp
+++ b/be/src/vec/sink/vrow_distribution.cpp
@ -94,7 +94,6 @@ Status VRowDistribution::automatic_create_partition() {
    request.__set_db_id(_vpartition->db_id());
    request.__set_table_id(_vpartition->table_id());
    request.__set_partitionValues(_partitions_need_create);
-    request.__set_write_single_replica(_write_single_replica);

    VLOG_NOTICE << "automatic partition rpc begin request " << request;
    TNetworkAddress master_addr = ExecEnv::GetInstance()->master_info()->network_address;
@ -128,7 +127,6 @@ static TCreatePartitionResult cast_as_create_result(TReplacePartitionResult& arg
    result.nodes = std::move(arg.nodes);
    result.partitions = std::move(arg.partitions);
    result.tablets = std::move(arg.tablets);
-    result.slave_tablets = std::move(arg.slave_tablets);
    return result;
 }

@ -140,7 +138,6 @@ Status VRowDistribution::_replace_overwriting_partition() {
    request.__set_overwrite_group_id(_vpartition->get_overwrite_group_id());
    request.__set_db_id(_vpartition->db_id());
    request.__set_table_id(_vpartition->table_id());
-    request.__set_write_single_replica(_write_single_replica);

    // only request for partitions not recorded for replacement
    std::set<int64_t> id_deduper;
--- a/be/src/vec/sink/vrow_distribution.h
+++ b/be/src/vec/sink/vrow_distribution.h
@ -79,7 +79,6 @@ public:
        const VExprContextSPtrs* vec_output_expr_ctxs = nullptr;
        std::shared_ptr<OlapTableSchemaParam> schema;
        void* caller = nullptr;
-        bool write_single_replica = false;
        CreatePartitionCallback create_partition_callback;
    };
    friend class VTabletWriter;
@ -101,7 +100,6 @@ public:
        _vec_output_expr_ctxs = ctx.vec_output_expr_ctxs;
        _schema = ctx.schema;
        _caller = ctx.caller;
-        _write_single_replica = ctx.write_single_replica;
        _create_partition_callback = ctx.create_partition_callback;
    }

@ -221,7 +219,6 @@ private:
    CreatePartitionCallback _create_partition_callback = nullptr;
    void* _caller = nullptr;
    std::shared_ptr<OlapTableSchemaParam> _schema;
-    bool _write_single_replica = false;

    // reuse for find_tablet. save partitions found by find_tablets
    std::vector<VOlapTablePartition*> _partitions;
--- a/be/src/vec/sink/writer/vtablet_writer.cpp
+++ b/be/src/vec/sink/writer/vtablet_writer.cpp
@ -125,7 +125,7 @@ Status IndexChannel::init(RuntimeState* state, const std::vector<TTabletWithPart
                    _has_inc_node = true;
                }
                LOG(INFO) << "init new node for instance " << _parent->_sender_id
-                          << ", node id:" << replica_node_id << ", incremantal:" << incremental;
+                          << ", incremantal:" << incremental;
            } else {
                channel = it->second;
            }
@ -973,8 +973,7 @@ void VNodeChannel::mark_close(bool hang_wait) {
        DCHECK(_pending_blocks.back().second->eos());
        _close_time_ms = UnixMillis();
        LOG(INFO) << channel_info()
-                  << " mark closed, left pending batch size: " << _pending_blocks.size()
-                  << " hang_wait: " << hang_wait;
+                  << " mark closed, left pending batch size: " << _pending_blocks.size();
    }

    _eos_is_produced = true;
@ -1102,8 +1101,7 @@ Status VTabletWriter::on_partitions_created(TCreatePartitionResult* result) {
    auto* new_locations = _pool->add(new std::vector<TTabletLocation>(result->tablets));
    _location->add_locations(*new_locations);
    if (_write_single_replica) {
-        auto* slave_locations = _pool->add(new std::vector<TTabletLocation>(result->slave_tablets));
-        _slave_location->add_locations(*slave_locations);
+        _slave_location->add_locations(*new_locations);
    }

    // update new node info
@ -1131,7 +1129,6 @@ Status VTabletWriter::_init_row_distribution() {
                            .vec_output_expr_ctxs = &_vec_output_expr_ctxs,
                            .schema = _schema,
                            .caller = this,
-                            .write_single_replica = _write_single_replica,
                            .create_partition_callback = &vectorized::on_partitions_created});

    return _row_distribution.open(_output_row_desc);
--- a/fe/fe-core/src/main/java/org/apache/doris/service/FrontendServiceImpl.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/service/FrontendServiceImpl.java
@ -261,7 +261,6 @@ import com.google.common.base.Strings;
 import com.google.common.collect.Lists;
 import com.google.common.collect.Maps;
 import com.google.common.collect.Multimap;
-import com.google.common.collect.Sets;
 import org.apache.commons.collections.CollectionUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.apache.logging.log4j.LogManager;
@ -269,7 +268,6 @@ import org.apache.logging.log4j.Logger;
 import org.apache.thrift.TException;

 import java.io.IOException;
-import java.security.SecureRandom;
 import java.util.ArrayList;
 import java.util.Collection;
 import java.util.Collections;
@ -277,7 +275,6 @@ import java.util.HashMap;
 import java.util.HashSet;
 import java.util.List;
 import java.util.Map;
-import java.util.Random;
 import java.util.Set;
 import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.ExecutionException;
@ -3695,7 +3692,6 @@ public class FrontendServiceImpl implements FrontendService.Iface {
        // build partition & tablets
        List<TOlapTablePartition> partitions = Lists.newArrayList();
        List<TTabletLocation> tablets = Lists.newArrayList();
-        List<TTabletLocation> slaveTablets = new ArrayList<>();
        for (String partitionName : addPartitionClauseMap.keySet()) {
            Partition partition = table.getPartition(partitionName);
            TOlapTablePartition tPartition = new TOlapTablePartition();
@ -3728,25 +3724,12 @@ public class FrontendServiceImpl implements FrontendService.Iface {
                    if (bePathsMap.keySet().size() < quorum) {
                        LOG.warn("auto go quorum exception");
                    }
-                    if (request.isSetWriteSingleReplica() && request.isWriteSingleReplica()) {
-                        Long[] nodes = bePathsMap.keySet().toArray(new Long[0]);
-                        Random random = new SecureRandom();
-                        Long masterNode = nodes[random.nextInt(nodes.length)];
-                        Multimap<Long, Long> slaveBePathsMap = bePathsMap;
-                        slaveBePathsMap.removeAll(masterNode);
-                        tablets.add(new TTabletLocation(tablet.getId(),
-                                Lists.newArrayList(Sets.newHashSet(masterNode))));
-                        slaveTablets.add(new TTabletLocation(tablet.getId(),
-                                Lists.newArrayList(slaveBePathsMap.keySet())));
-                    } else {
-                        tablets.add(new TTabletLocation(tablet.getId(), Lists.newArrayList(bePathsMap.keySet())));
-                    }
+                    tablets.add(new TTabletLocation(tablet.getId(), Lists.newArrayList(bePathsMap.keySet())));
                }
            }
        }
        result.setPartitions(partitions);
        result.setTablets(tablets);
-        result.setSlaveTablets(slaveTablets);

        // build nodes
        List<TNodeInfo> nodeInfos = Lists.newArrayList();
@ -3902,7 +3885,6 @@ public class FrontendServiceImpl implements FrontendService.Iface {
        // so they won't be changed again. if other transaction changing it. just let it fail.
        List<TOlapTablePartition> partitions = new ArrayList<>();
        List<TTabletLocation> tablets = new ArrayList<>();
-        List<TTabletLocation> slaveTablets = new ArrayList<>();
        PartitionInfo partitionInfo = olapTable.getPartitionInfo();
        for (long partitionId : resultPartitionIds) {
            Partition partition = olapTable.getPartition(partitionId);
@ -3938,25 +3920,12 @@ public class FrontendServiceImpl implements FrontendService.Iface {
                    if (bePathsMap.keySet().size() < quorum) {
                        LOG.warn("auto go quorum exception");
                    }
-                    if (request.isSetWriteSingleReplica() && request.isWriteSingleReplica()) {
-                        Long[] nodes = bePathsMap.keySet().toArray(new Long[0]);
-                        Random random = new SecureRandom();
-                        Long masterNode = nodes[random.nextInt(nodes.length)];
-                        Multimap<Long, Long> slaveBePathsMap = bePathsMap;
-                        slaveBePathsMap.removeAll(masterNode);
-                        tablets.add(new TTabletLocation(tablet.getId(),
-                                Lists.newArrayList(Sets.newHashSet(masterNode))));
-                        slaveTablets.add(new TTabletLocation(tablet.getId(),
-                                Lists.newArrayList(slaveBePathsMap.keySet())));
-                    } else {
-                        tablets.add(new TTabletLocation(tablet.getId(), Lists.newArrayList(bePathsMap.keySet())));
-                    }
+                    tablets.add(new TTabletLocation(tablet.getId(), Lists.newArrayList(bePathsMap.keySet())));
                }
            }
        }
        result.setPartitions(partitions);
        result.setTablets(tablets);
-        result.setSlaveTablets(slaveTablets);

        // build nodes
        List<TNodeInfo> nodeInfos = Lists.newArrayList();
--- a/gensrc/thrift/FrontendService.thrift
+++ b/gensrc/thrift/FrontendService.thrift
@ -1483,7 +1483,6 @@ struct TCreatePartitionRequest {
    3: optional i64 table_id
    // for each partition column's partition values. [missing_rows, partition_keys]->Left bound(for range) or Point(for list)
    4: optional list<list<Exprs.TNullableStringLiteral>> partitionValues
-    5: optional bool write_single_replica = false
 }

 struct TCreatePartitionResult {
@ -1491,7 +1490,6 @@ struct TCreatePartitionResult {
    2: optional list<Descriptors.TOlapTablePartition> partitions
    3: optional list<Descriptors.TTabletLocation> tablets
    4: optional list<Descriptors.TNodeInfo> nodes
-    5: optional list<Descriptors.TTabletLocation> slave_tablets
 }

 // these two for auto detect replacing partition
@ -1500,7 +1498,6 @@ struct TReplacePartitionRequest {
    2: optional i64 db_id
    3: optional i64 table_id
    4: optional list<i64> partition_ids // partition to replace.
-    5: optional bool write_single_replica = false
 }

 struct TReplacePartitionResult {
@ -1508,7 +1505,6 @@ struct TReplacePartitionResult {
    2: optional list<Descriptors.TOlapTablePartition> partitions
    3: optional list<Descriptors.TTabletLocation> tablets
    4: optional list<Descriptors.TNodeInfo> nodes
-    5: optional list<Descriptors.TTabletLocation> slave_tablets
 }

 struct TGetMetaReplica {
--- a/regression-test/data/partition_p0/auto_partition/test_auto_partition_with_single_replica_insert.csv
+++ b/regression-test/data/partition_p0/auto_partition/test_auto_partition_with_single_replica_insert.csv
@ -1,78 +0,0 @@
-3590935922607536626,-,2025-02-16,星辰医疗科技有限公司
-3590935906895636626,-,2025-02-16,未来健康产业
-123,-,2025-02-16,蓝海生物有限公司
-100000048812501,-,2025-02-16,阳光医疗集团
-1000000076784258,-,2025-02-16,华夏健康科技
-1000022060522735,-,2025-02-16,瑞丰生物医药
-1000022193719484,-,2025-02-16,盛世医疗服务
-1000031422678924,-,2025-02-16,康宁健康有限公司
-1000085651028900,-,2025-02-16,史前生物科技
-1000093620518989,-,2025-02-16,健康之路公司
-1000103471774704,-,2025-02-16,安康医疗科技
-1000138777615262,-,2025-02-16,福瑞堂生物
-1000156823071129,-,2025-02-16,优质生活科技
-1000191711015262,-,2025-02-16,健康未来企业
-1000633041475486,-,2025-02-16,天使医疗集团
-1000681518627336,-,2025-02-16,百年健康公司
-1002458253925730,-,2025-02-16,康乐园生物科技
-1008126191610424,-,2025-02-16,华康医药有限公司
-1071904784424147,-,2025-02-16,金桥健康产业
-1076564522324147,-,2025-02-16,乐活医疗科技
-1202217708798485,-,2025-02-16,健康家园公司
-1224474148903456,-,2025-02-16,康泰生物科技
-2043829367811999,-,2025-02-16,未来医疗集团
-2191851926844270,-,2025-02-16,健康之源公司
-2232379824950609,-,2025-02-16,安宁医药有限公司
-2350341369782152,-,2025-02-16,和谐生物科技
-2548383917911403,-,2025-02-16,康健医疗服务
-2640774381717600,-,2025-02-16,瑞康医药有限公司
-2754625269782961,-,2025-02-16,乐享健康产业
-3064667398063809,-,2025-02-16,健康先锋公司
-3102689636972458,-,2025-02-16,安康生物科技
-3291916164371209,-,2025-02-16,未来之星医疗
-3946909802002976,-,2025-02-16,健康梦想公司
-3965513055005942,-,2025-02-16,康乐生物科技
-4143117309325214,-,2025-02-16,安宁健康产业
-4175970196426577,-,2025-02-16,乐活医疗集团
-4294566787233969,-,2025-02-16,健康之道公司
-4610682351457207,-,2025-02-16,瑞丰医疗科技
-4674640812462217,-,2025-02-16,未来健康企业
-4676494238858307,-,2025-02-16,安康医药有限公司
-4937264996861701,-,2025-02-16,乐享健康公司
-4947288173569190,-,2025-02-16,康宁医疗集团
-5115179098054305,-,2025-02-16,健康家园科技
-10000000430024147,-,2025-02-16,阳光医疗有限公司
-10000021073673208,-,2025-02-16,未来生物科技
-10000130032642122,-,2025-02-16,和谐健康产业
-10000365660973707,-,2025-02-16,安宁医药公司
-10000453096993544,-,2025-02-16,傻乐生物科技
-10000789012345678,-,2025-02-16,星辉医疗科技
-10000890123456789,-,2025-02-16,未来健康服务
-10000901234567890,-,2025-02-16,蓝天生物科技
-10001012345678901,-,2025-02-16,阳光健康产业
-10001123456789012,-,2025-02-16,华康医疗集团
-10001234567890123,-,2025-02-16,易丰生物医药
-10001345678901234,-,2025-02-16,盛世健康科技
-10001456789012345,-,2025-02-16,康宁医疗服务
-10001567890123456,-,2025-02-16,和谐生物公司
-10001678901234567,-,2025-02-16,健康之路科技
-10001789012345678,-,2025-02-16,安康生物产业
-10001890123456789,-,2025-02-16,福瑞堂医疗
-10001901234567890,-,2025-02-16,未来生活科技
-10002012345678901,-,2025-02-16,美好未来企业
-10002123456789012,-,2025-02-16,金地医疗集团
-10002234567890123,-,2025-02-16,老头健康公司
-10002345678901234,-,2025-02-16,平安园生物科技
-10002456789012345,-,2025-02-16,闪电医药有限公司
-10002567890123456,-,2025-02-16,铜桥健康产业
-10002678901234567,-,2025-02-16,乐天医疗科技
-10002789012345678,-,2025-02-16,健康成长公司
-10002890123456789,-,2025-02-16,尖端生物科技
-10002901234567890,-,2025-02-16,保护伞医疗集团
-10003012345678901,-,2025-02-16,青春之源公司
-10003123456789012,-,2025-02-16,大森林医药有限公司
-10003234567890123,-,2025-02-16,毒蛇生物科技
-10003345678901234,-,2025-02-16,金地医疗服务
-10003456789012345,-,2025-02-16,瑞丰医药有限公司
-10003567890123456,-,2025-02-16,乐游娱乐产业
-10003678901234567,-,2025-02-16,康岩先锋公司
--- a/regression-test/data/partition_p0/auto_partition/test_auto_partition_with_single_replica_insert.out
+++ b/regression-test/data/partition_p0/auto_partition/test_auto_partition_with_single_replica_insert.out
@ -1,161 +0,0 @@
-- This file is automatically generated. You should know what you did if you want to edit this
-- !select1 --
-3590935906895636626	-	2025-02-16	未来健康产业
-3590935922607536626	-	2025-02-16	星辰医疗科技有限公司
-10000000430024147	-	2025-02-16	阳光医疗有限公司
-1000000076784258	-	2025-02-16	华夏健康科技
-100000048812501	-	2025-02-16	阳光医疗集团
-10000021073673208	-	2025-02-16	未来生物科技
-10000130032642122	-	2025-02-16	和谐健康产业
-1000022060522735	-	2025-02-16	瑞丰生物医药
-1000022193719484	-	2025-02-16	盛世医疗服务
-1000031422678924	-	2025-02-16	康宁健康有限公司
-10000365660973707	-	2025-02-16	安宁医药公司
-10000453096993544	-	2025-02-16	傻乐生物科技
-10000789012345678	-	2025-02-16	星辉医疗科技
-1000085651028900	-	2025-02-16	史前生物科技
-10000890123456789	-	2025-02-16	未来健康服务
-10000901234567890	-	2025-02-16	蓝天生物科技
-1000093620518989	-	2025-02-16	健康之路公司
-10001012345678901	-	2025-02-16	阳光健康产业
-1000103471774704	-	2025-02-16	安康医疗科技
-10001123456789012	-	2025-02-16	华康医疗集团
-10001234567890123	-	2025-02-16	易丰生物医药
-10001345678901234	-	2025-02-16	盛世健康科技
-1000138777615262	-	2025-02-16	福瑞堂生物
-10001456789012345	-	2025-02-16	康宁医疗服务
-10001567890123456	-	2025-02-16	和谐生物公司
-1000156823071129	-	2025-02-16	优质生活科技
-10001678901234567	-	2025-02-16	健康之路科技
-10001789012345678	-	2025-02-16	安康生物产业
-10001890123456789	-	2025-02-16	福瑞堂医疗
-10001901234567890	-	2025-02-16	未来生活科技
-1000191711015262	-	2025-02-16	健康未来企业
-10002012345678901	-	2025-02-16	美好未来企业
-10002123456789012	-	2025-02-16	金地医疗集团
-10002234567890123	-	2025-02-16	老头健康公司
-10002345678901234	-	2025-02-16	平安园生物科技
-10002456789012345	-	2025-02-16	闪电医药有限公司
-10002567890123456	-	2025-02-16	铜桥健康产业
-10002678901234567	-	2025-02-16	乐天医疗科技
-10002789012345678	-	2025-02-16	健康成长公司
-10002890123456789	-	2025-02-16	尖端生物科技
-10002901234567890	-	2025-02-16	保护伞医疗集团
-10003012345678901	-	2025-02-16	青春之源公司
-10003123456789012	-	2025-02-16	大森林医药有限公司
-10003234567890123	-	2025-02-16	毒蛇生物科技
-10003345678901234	-	2025-02-16	金地医疗服务
-10003456789012345	-	2025-02-16	瑞丰医药有限公司
-10003567890123456	-	2025-02-16	乐游娱乐产业
-10003678901234567	-	2025-02-16	康岩先锋公司
-1000633041475486	-	2025-02-16	天使医疗集团
-1000681518627336	-	2025-02-16	百年健康公司
-1002458253925730	-	2025-02-16	康乐园生物科技
-1008126191610424	-	2025-02-16	华康医药有限公司
-1071904784424147	-	2025-02-16	金桥健康产业
-1076564522324147	-	2025-02-16	乐活医疗科技
-1202217708798485	-	2025-02-16	健康家园公司
-1224474148903456	-	2025-02-16	康泰生物科技
-123	-	2025-02-16	蓝海生物有限公司
-2043829367811999	-	2025-02-16	未来医疗集团
-2191851926844270	-	2025-02-16	健康之源公司
-2232379824950609	-	2025-02-16	安宁医药有限公司
-2350341369782152	-	2025-02-16	和谐生物科技
-2548383917911403	-	2025-02-16	康健医疗服务
-2640774381717600	-	2025-02-16	瑞康医药有限公司
-2754625269782961	-	2025-02-16	乐享健康产业
-3064667398063809	-	2025-02-16	健康先锋公司
-3102689636972458	-	2025-02-16	安康生物科技
-3291916164371209	-	2025-02-16	未来之星医疗
-3946909802002976	-	2025-02-16	健康梦想公司
-3965513055005942	-	2025-02-16	康乐生物科技
-4143117309325214	-	2025-02-16	安宁健康产业
-4175970196426577	-	2025-02-16	乐活医疗集团
-4294566787233969	-	2025-02-16	健康之道公司
-4610682351457207	-	2025-02-16	瑞丰医疗科技
-4674640812462217	-	2025-02-16	未来健康企业
-4676494238858307	-	2025-02-16	安康医药有限公司
-4937264996861701	-	2025-02-16	乐享健康公司
-4947288173569190	-	2025-02-16	康宁医疗集团
-5115179098054305	-	2025-02-16	健康家园科技
-
-- !select2 --
-3590935906895636626	-	2025-02-16	未来健康产业
-3590935922607536626	-	2025-02-16	星辰医疗科技有限公司
-10000000430024147	-	2025-02-16	阳光医疗有限公司
-1000000076784258	-	2025-02-16	华夏健康科技
-100000048812501	-	2025-02-16	阳光医疗集团
-10000021073673208	-	2025-02-16	未来生物科技
-10000130032642122	-	2025-02-16	和谐健康产业
-1000022060522735	-	2025-02-16	瑞丰生物医药
-1000022193719484	-	2025-02-16	盛世医疗服务
-1000031422678924	-	2025-02-16	康宁健康有限公司
-10000365660973707	-	2025-02-16	安宁医药公司
-10000453096993544	-	2025-02-16	傻乐生物科技
-10000789012345678	-	2025-02-16	星辉医疗科技
-1000085651028900	-	2025-02-16	史前生物科技
-10000890123456789	-	2025-02-16	未来健康服务
-10000901234567890	-	2025-02-16	蓝天生物科技
-1000093620518989	-	2025-02-16	健康之路公司
-10001012345678901	-	2025-02-16	阳光健康产业
-1000103471774704	-	2025-02-16	安康医疗科技
-10001123456789012	-	2025-02-16	华康医疗集团
-10001234567890123	-	2025-02-16	易丰生物医药
-10001345678901234	-	2025-02-16	盛世健康科技
-1000138777615262	-	2025-02-16	福瑞堂生物
-10001456789012345	-	2025-02-16	康宁医疗服务
-10001567890123456	-	2025-02-16	和谐生物公司
-1000156823071129	-	2025-02-16	优质生活科技
-10001678901234567	-	2025-02-16	健康之路科技
-10001789012345678	-	2025-02-16	安康生物产业
-10001890123456789	-	2025-02-16	福瑞堂医疗
-10001901234567890	-	2025-02-16	未来生活科技
-1000191711015262	-	2025-02-16	健康未来企业
-10002012345678901	-	2025-02-16	美好未来企业
-10002123456789012	-	2025-02-16	金地医疗集团
-10002234567890123	-	2025-02-16	老头健康公司
-10002345678901234	-	2025-02-16	平安园生物科技
-10002456789012345	-	2025-02-16	闪电医药有限公司
-10002567890123456	-	2025-02-16	铜桥健康产业
-10002678901234567	-	2025-02-16	乐天医疗科技
-10002789012345678	-	2025-02-16	健康成长公司
-10002890123456789	-	2025-02-16	尖端生物科技
-10002901234567890	-	2025-02-16	保护伞医疗集团
-10003012345678901	-	2025-02-16	青春之源公司
-10003123456789012	-	2025-02-16	大森林医药有限公司
-10003234567890123	-	2025-02-16	毒蛇生物科技
-10003345678901234	-	2025-02-16	金地医疗服务
-10003456789012345	-	2025-02-16	瑞丰医药有限公司
-10003567890123456	-	2025-02-16	乐游娱乐产业
-10003678901234567	-	2025-02-16	康岩先锋公司
-1000633041475486	-	2025-02-16	天使医疗集团
-1000681518627336	-	2025-02-16	百年健康公司
-1002458253925730	-	2025-02-16	康乐园生物科技
-1008126191610424	-	2025-02-16	华康医药有限公司
-1071904784424147	-	2025-02-16	金桥健康产业
-1076564522324147	-	2025-02-16	乐活医疗科技
-1202217708798485	-	2025-02-16	健康家园公司
-1224474148903456	-	2025-02-16	康泰生物科技
-123	-	2025-02-16	蓝海生物有限公司
-2043829367811999	-	2025-02-16	未来医疗集团
-2191851926844270	-	2025-02-16	健康之源公司
-2232379824950609	-	2025-02-16	安宁医药有限公司
-2350341369782152	-	2025-02-16	和谐生物科技
-2548383917911403	-	2025-02-16	康健医疗服务
-2640774381717600	-	2025-02-16	瑞康医药有限公司
-2754625269782961	-	2025-02-16	乐享健康产业
-3064667398063809	-	2025-02-16	健康先锋公司
-3102689636972458	-	2025-02-16	安康生物科技
-3291916164371209	-	2025-02-16	未来之星医疗
-3946909802002976	-	2025-02-16	健康梦想公司
-3965513055005942	-	2025-02-16	康乐生物科技
-4143117309325214	-	2025-02-16	安宁健康产业
-4175970196426577	-	2025-02-16	乐活医疗集团
-4294566787233969	-	2025-02-16	健康之道公司
-4610682351457207	-	2025-02-16	瑞丰医疗科技
-4674640812462217	-	2025-02-16	未来健康企业
-4676494238858307	-	2025-02-16	安康医药有限公司
-4937264996861701	-	2025-02-16	乐享健康公司
-4947288173569190	-	2025-02-16	康宁医疗集团
-5115179098054305	-	2025-02-16	健康家园科技
-
--- a/regression-test/suites/partition_p0/auto_partition/test_auto_partition_with_single_replica_insert.groovy
+++ b/regression-test/suites/partition_p0/auto_partition/test_auto_partition_with_single_replica_insert.groovy
@ -1,78 +0,0 @@
-// Licensed to the Apache Software Foundation (ASF) under one
-// or more contributor license agreements.  See the NOTICE file
-// distributed with this work for additional information
-// regarding copyright ownership.  The ASF licenses this file
-// to you under the Apache License, Version 2.0 (the
-// "License"); you may not use this file except in compliance
-// with the License.  You may obtain a copy of the License at
-//
-//   http://www.apache.org/licenses/LICENSE-2.0
-//
-// Unless required by applicable law or agreed to in writing,
-// software distributed under the License is distributed on an
-// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-// KIND, either express or implied.  See the License for the
-// specific language governing permissions and limitations
-// under the License.
-
-suite("test_auto_partition_with_single_replica_insert") {
-    def tableName1 = "test_auto_partition_with_single_replica_insert_1"
-    def tableName2 = "test_auto_partition_with_single_replica_insert_2"
-    sql "drop table if exists ${tableName1}"
-    sql """
-        CREATE TABLE `${tableName1}` (
-            `user_id` varchar(100) NULL,
-            `goods_id` varchar(100) NULL,
-            `dates` date NULL,
-            `chain_name` varchar(100) NULL
-        ) ENGINE=OLAP
-        DUPLICATE KEY(`user_id`, `goods_id`, `dates`)
-        COMMENT 'OLAP'
-        AUTO PARTITION BY LIST (`chain_name`)
-        (PARTITION pchain5fname10 VALUES IN ("chain_name"),
-        PARTITION p4e0995e85ce1534e4e3a5 VALUES IN ("星辰医疗科技有限公司"))
-        DISTRIBUTED BY HASH(`user_id`) BUCKETS AUTO
-        PROPERTIES (
-            "replication_allocation" = "tag.location.default: 1"
-        );
-        """
-    streamLoad {
-        table "${tableName1}"
-        set 'column_separator', ','
-        file "test_auto_partition_with_single_replica_insert.csv"
-        time 20000
-    }
-    sql " sync "
-    qt_select1 "select * from ${tableName1} order by user_id"
-    def result1 = sql "show partitions from ${tableName1}"
-    logger.info("${result1}")
-    assertEquals(result1.size(), 79)
-
-    sql "drop table if exists ${tableName2}"
-    sql """
-        CREATE TABLE `${tableName2}` (
-            `user_id` varchar(100) NULL,
-            `goods_id` varchar(100) NULL,
-            `dates` date NULL,
-            `chain_name` varchar(100) NULL
-        ) ENGINE=OLAP
-        DUPLICATE KEY(`user_id`, `goods_id`, `dates`)
-        COMMENT 'OLAP'
-        AUTO PARTITION BY LIST (`chain_name`)
-        (PARTITION pchain5fname10 VALUES IN ("chain_name"),
-        PARTITION p4e0995e85ce1534e4e3a5 VALUES IN ("星辰医疗科技有限公司"))
-        DISTRIBUTED BY HASH(`user_id`) BUCKETS AUTO
-        PROPERTIES (
-            "replication_allocation" = "tag.location.default: 1"
-        );
-        """
-    sql """set experimental_enable_nereids_planner = true"""
-    sql """set enable_memtable_on_sink_node = false"""
-    sql """set experimental_enable_single_replica_insert = true"""
-    sql "insert into ${tableName2} select user_id, goods_id, dates, chain_name from ${tableName1}"
-    sql " sync "
-    qt_select2 "select * from ${tableName2} order by user_id"
-    def result2 = sql "show partitions from ${tableName1}"
-    logger.info("${result2}")
-    assertEquals(result1.size(), 79)
-}