diff --git a/internal/core/src/pb/common.pb.cc b/internal/core/src/pb/common.pb.cc
index e994af71fbcfd..8b91d04636277 100644
--- a/internal/core/src/pb/common.pb.cc
+++ b/internal/core/src/pb/common.pb.cc
@@ -135,7 +135,6 @@ PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORIT
 PROTOBUF_CONSTEXPR MsgBase::MsgBase(
     ::_pbi::ConstantInitialized): _impl_{
     /*decltype(_impl_.properties_)*/{::_pbi::ConstantInitialized()}
-  , /*decltype(_impl_.replicateinfo_)*/nullptr
   , /*decltype(_impl_.msgid_)*/int64_t{0}
   , /*decltype(_impl_.timestamp_)*/uint64_t{0u}
   , /*decltype(_impl_.sourceid_)*/int64_t{0}
@@ -151,20 +150,6 @@ struct MsgBaseDefaultTypeInternal {
   };
 };
 PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 MsgBaseDefaultTypeInternal _MsgBase_default_instance_;
-PROTOBUF_CONSTEXPR ReplicateInfo::ReplicateInfo(
-    ::_pbi::ConstantInitialized): _impl_{
-    /*decltype(_impl_.msgtimestamp_)*/uint64_t{0u}
-  , /*decltype(_impl_.isreplicate_)*/false
-  , /*decltype(_impl_._cached_size_)*/{}} {}
-struct ReplicateInfoDefaultTypeInternal {
-  PROTOBUF_CONSTEXPR ReplicateInfoDefaultTypeInternal()
-      : _instance(::_pbi::ConstantInitialized{}) {}
-  ~ReplicateInfoDefaultTypeInternal() {}
-  union {
-    ReplicateInfo _instance;
-  };
-};
-PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 ReplicateInfoDefaultTypeInternal _ReplicateInfo_default_instance_;
 PROTOBUF_CONSTEXPR MsgHeader::MsgHeader(
     ::_pbi::ConstantInitialized): _impl_{
     /*decltype(_impl_.base_)*/nullptr
@@ -283,7 +268,7 @@ PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORIT
 }  // namespace common
 }  // namespace proto
 }  // namespace milvus
-static ::_pb::Metadata file_level_metadata_common_2eproto[18];
+static ::_pb::Metadata file_level_metadata_common_2eproto[17];
 static const ::_pb::EnumDescriptor* file_level_enum_descriptors_common_2eproto[13];
 static constexpr ::_pb::ServiceDescriptor const** file_level_service_descriptors_common_2eproto = nullptr;
 
@@ -366,15 +351,6 @@ const uint32_t TableStruct_common_2eproto::offsets[] PROTOBUF_SECTION_VARIABLE(p
   PROTOBUF_FIELD_OFFSET(::milvus::proto::common::MsgBase, _impl_.sourceid_),
   PROTOBUF_FIELD_OFFSET(::milvus::proto::common::MsgBase, _impl_.targetid_),
   PROTOBUF_FIELD_OFFSET(::milvus::proto::common::MsgBase, _impl_.properties_),
-  PROTOBUF_FIELD_OFFSET(::milvus::proto::common::MsgBase, _impl_.replicateinfo_),
-  ~0u,  // no _has_bits_
-  PROTOBUF_FIELD_OFFSET(::milvus::proto::common::ReplicateInfo, _internal_metadata_),
-  ~0u,  // no _extensions_
-  ~0u,  // no _oneof_case_
-  ~0u,  // no _weak_field_map_
-  ~0u,  // no _inlined_string_donated_
-  PROTOBUF_FIELD_OFFSET(::milvus::proto::common::ReplicateInfo, _impl_.isreplicate_),
-  PROTOBUF_FIELD_OFFSET(::milvus::proto::common::ReplicateInfo, _impl_.msgtimestamp_),
   ~0u,  // no _has_bits_
   PROTOBUF_FIELD_OFFSET(::milvus::proto::common::MsgHeader, _internal_metadata_),
   ~0u,  // no _extensions_
@@ -463,15 +439,14 @@ static const ::_pbi::MigrationSchema schemas[] PROTOBUF_SECTION_VARIABLE(protode
   { 48, -1, -1, sizeof(::milvus::proto::common::Address)},
   { 56, 64, -1, sizeof(::milvus::proto::common::MsgBase_PropertiesEntry_DoNotUse)},
   { 66, -1, -1, sizeof(::milvus::proto::common::MsgBase)},
-  { 79, -1, -1, sizeof(::milvus::proto::common::ReplicateInfo)},
-  { 87, -1, -1, sizeof(::milvus::proto::common::MsgHeader)},
-  { 94, -1, -1, sizeof(::milvus::proto::common::DMLMsgHeader)},
-  { 102, -1, -1, sizeof(::milvus::proto::common::PrivilegeExt)},
-  { 112, -1, -1, sizeof(::milvus::proto::common::SegmentStats)},
-  { 120, 128, -1, sizeof(::milvus::proto::common::ClientInfo_ReservedEntry_DoNotUse)},
-  { 130, -1, -1, sizeof(::milvus::proto::common::ClientInfo)},
-  { 142, 150, -1, sizeof(::milvus::proto::common::ServerInfo_ReservedEntry_DoNotUse)},
-  { 152, -1, -1, sizeof(::milvus::proto::common::ServerInfo)},
+  { 78, -1, -1, sizeof(::milvus::proto::common::MsgHeader)},
+  { 85, -1, -1, sizeof(::milvus::proto::common::DMLMsgHeader)},
+  { 93, -1, -1, sizeof(::milvus::proto::common::PrivilegeExt)},
+  { 103, -1, -1, sizeof(::milvus::proto::common::SegmentStats)},
+  { 111, 119, -1, sizeof(::milvus::proto::common::ClientInfo_ReservedEntry_DoNotUse)},
+  { 121, -1, -1, sizeof(::milvus::proto::common::ClientInfo)},
+  { 133, 141, -1, sizeof(::milvus::proto::common::ServerInfo_ReservedEntry_DoNotUse)},
+  { 143, -1, -1, sizeof(::milvus::proto::common::ServerInfo)},
 };
 
 static const ::_pb::Message* const file_default_instances[] = {
@@ -484,7 +459,6 @@ static const ::_pb::Message* const file_default_instances[] = {
   &::milvus::proto::common::_Address_default_instance_._instance,
   &::milvus::proto::common::_MsgBase_PropertiesEntry_DoNotUse_default_instance_._instance,
   &::milvus::proto::common::_MsgBase_default_instance_._instance,
-  &::milvus::proto::common::_ReplicateInfo_default_instance_._instance,
   &::milvus::proto::common::_MsgHeader_default_instance_._instance,
   &::milvus::proto::common::_DMLMsgHeader_default_instance_._instance,
   &::milvus::proto::common::_PrivilegeExt_default_instance_._instance,
@@ -508,187 +482,184 @@ const char descriptor_table_protodef_common_2eproto[] PROTOBUF_SECTION_VARIABLE(
   "alues\030\003 \003(\014\"O\n\020PlaceholderGroup\022;\n\014place"
   "holders\030\001 \003(\0132%.milvus.proto.common.Plac"
   "eholderValue\"#\n\007Address\022\n\n\002ip\030\001 \001(\t\022\014\n\004p"
-  "ort\030\002 \001(\003\"\257\002\n\007MsgBase\022.\n\010msg_type\030\001 \001(\0162"
+  "ort\030\002 \001(\003\"\364\001\n\007MsgBase\022.\n\010msg_type\030\001 \001(\0162"
   "\034.milvus.proto.common.MsgType\022\r\n\005msgID\030\002"
   " \001(\003\022\021\n\ttimestamp\030\003 \001(\004\022\020\n\010sourceID\030\004 \001("
   "\003\022\020\n\010targetID\030\005 \001(\003\022@\n\nproperties\030\006 \003(\0132"
   ",.milvus.proto.common.MsgBase.Properties"
-  "Entry\0229\n\rreplicateInfo\030\007 \001(\0132\".milvus.pr"
-  "oto.common.ReplicateInfo\0321\n\017PropertiesEn"
-  "try\022\013\n\003key\030\001 \001(\t\022\r\n\005value\030\002 \001(\t:\0028\001\":\n\rR"
-  "eplicateInfo\022\023\n\013isReplicate\030\001 \001(\010\022\024\n\014msg"
-  "Timestamp\030\002 \001(\004\"7\n\tMsgHeader\022*\n\004base\030\001 \001"
-  "(\0132\034.milvus.proto.common.MsgBase\"M\n\014DMLM"
-  "sgHeader\022*\n\004base\030\001 \001(\0132\034.milvus.proto.co"
-  "mmon.MsgBase\022\021\n\tshardName\030\002 \001(\t\"\273\001\n\014Priv"
-  "ilegeExt\0224\n\013object_type\030\001 \001(\0162\037.milvus.p"
-  "roto.common.ObjectType\022>\n\020object_privile"
-  "ge\030\002 \001(\0162$.milvus.proto.common.ObjectPri"
-  "vilege\022\031\n\021object_name_index\030\003 \001(\005\022\032\n\022obj"
-  "ect_name_indexs\030\004 \001(\005\"2\n\014SegmentStats\022\021\n"
-  "\tSegmentID\030\001 \001(\003\022\017\n\007NumRows\030\002 \001(\003\"\325\001\n\nCl"
-  "ientInfo\022\020\n\010sdk_type\030\001 \001(\t\022\023\n\013sdk_versio"
-  "n\030\002 \001(\t\022\022\n\nlocal_time\030\003 \001(\t\022\014\n\004user\030\004 \001("
-  "\t\022\014\n\004host\030\005 \001(\t\022\?\n\010reserved\030\006 \003(\0132-.milv"
-  "us.proto.common.ClientInfo.ReservedEntry"
-  "\032/\n\rReservedEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005value\030"
-  "\002 \001(\t:\0028\001\"\343\001\n\nServerInfo\022\022\n\nbuild_tags\030\001"
-  " \001(\t\022\022\n\nbuild_time\030\002 \001(\t\022\022\n\ngit_commit\030\003"
-  " \001(\t\022\022\n\ngo_version\030\004 \001(\t\022\023\n\013deploy_mode\030"
-  "\005 \001(\t\022\?\n\010reserved\030\006 \003(\0132-.milvus.proto.c"
-  "ommon.ServerInfo.ReservedEntry\032/\n\rReserv"
-  "edEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005value\030\002 \001(\t:\0028\001*"
-  "\303\n\n\tErrorCode\022\013\n\007Success\020\000\022\023\n\017Unexpected"
-  "Error\020\001\022\021\n\rConnectFailed\020\002\022\024\n\020Permission"
-  "Denied\020\003\022\027\n\023CollectionNotExists\020\004\022\023\n\017Ill"
-  "egalArgument\020\005\022\024\n\020IllegalDimension\020\007\022\024\n\020"
-  "IllegalIndexType\020\010\022\031\n\025IllegalCollectionN"
-  "ame\020\t\022\017\n\013IllegalTOPK\020\n\022\024\n\020IllegalRowReco"
-  "rd\020\013\022\023\n\017IllegalVectorID\020\014\022\027\n\023IllegalSear"
-  "chResult\020\r\022\020\n\014FileNotFound\020\016\022\016\n\nMetaFail"
-  "ed\020\017\022\017\n\013CacheFailed\020\020\022\026\n\022CannotCreateFol"
-  "der\020\021\022\024\n\020CannotCreateFile\020\022\022\026\n\022CannotDel"
-  "eteFolder\020\023\022\024\n\020CannotDeleteFile\020\024\022\023\n\017Bui"
-  "ldIndexError\020\025\022\020\n\014IllegalNLIST\020\026\022\025\n\021Ille"
-  "galMetricType\020\027\022\017\n\013OutOfMemory\020\030\022\021\n\rInde"
-  "xNotExist\020\031\022\023\n\017EmptyCollection\020\032\022\033\n\027Upda"
-  "teImportTaskFailure\020\033\022\032\n\026CollectionNameN"
-  "otFound\020\034\022\033\n\027CreateCredentialFailure\020\035\022\033"
-  "\n\027UpdateCredentialFailure\020\036\022\033\n\027DeleteCre"
-  "dentialFailure\020\037\022\030\n\024GetCredentialFailure"
-  "\020 \022\030\n\024ListCredUsersFailure\020!\022\022\n\016GetUserF"
-  "ailure\020\"\022\025\n\021CreateRoleFailure\020#\022\023\n\017DropR"
-  "oleFailure\020$\022\032\n\026OperateUserRoleFailure\020%"
-  "\022\025\n\021SelectRoleFailure\020&\022\025\n\021SelectUserFai"
-  "lure\020\'\022\031\n\025SelectResourceFailure\020(\022\033\n\027Ope"
-  "ratePrivilegeFailure\020)\022\026\n\022SelectGrantFai"
-  "lure\020*\022!\n\035RefreshPolicyInfoCacheFailure\020"
-  "+\022\025\n\021ListPolicyFailure\020,\022\022\n\016NotShardLead"
-  "er\020-\022\026\n\022NoReplicaAvailable\020.\022\023\n\017SegmentN"
-  "otFound\020/\022\r\n\tForceDeny\0200\022\r\n\tRateLimit\0201\022"
-  "\022\n\016NodeIDNotMatch\0202\022\024\n\020UpsertAutoIDTrue\020"
-  "3\022\034\n\030InsufficientMemoryToLoad\0204\022\030\n\024Memor"
-  "yQuotaExhausted\0205\022\026\n\022DiskQuotaExhausted\020"
-  "6\022\025\n\021TimeTickLongDelay\0207\022\021\n\rNotReadyServ"
-  "e\0208\022\033\n\027NotReadyCoordActivating\0209\022\017\n\013Data"
-  "CoordNA\020d\022\022\n\rDDRequestRace\020\350\007*c\n\nIndexSt"
-  "ate\022\022\n\016IndexStateNone\020\000\022\014\n\010Unissued\020\001\022\016\n"
-  "\nInProgress\020\002\022\014\n\010Finished\020\003\022\n\n\006Failed\020\004\022"
-  "\t\n\005Retry\020\005*\202\001\n\014SegmentState\022\024\n\020SegmentSt"
-  "ateNone\020\000\022\014\n\010NotExist\020\001\022\013\n\007Growing\020\002\022\n\n\006"
-  "Sealed\020\003\022\013\n\007Flushed\020\004\022\014\n\010Flushing\020\005\022\013\n\007D"
-  "ropped\020\006\022\r\n\tImporting\020\007*i\n\017PlaceholderTy"
-  "pe\022\010\n\004None\020\000\022\020\n\014BinaryVector\020d\022\017\n\013FloatV"
-  "ector\020e\022\021\n\rFloat16Vector\020f\022\t\n\005Int64\020\005\022\013\n"
-  "\007VarChar\020\025*\264\020\n\007MsgType\022\r\n\tUndefined\020\000\022\024\n"
-  "\020CreateCollection\020d\022\022\n\016DropCollection\020e\022"
-  "\021\n\rHasCollection\020f\022\026\n\022DescribeCollection"
-  "\020g\022\023\n\017ShowCollections\020h\022\024\n\020GetSystemConf"
-  "igs\020i\022\022\n\016LoadCollection\020j\022\025\n\021ReleaseColl"
-  "ection\020k\022\017\n\013CreateAlias\020l\022\r\n\tDropAlias\020m"
-  "\022\016\n\nAlterAlias\020n\022\023\n\017AlterCollection\020o\022\024\n"
-  "\020RenameCollection\020p\022\021\n\rDescribeAlias\020q\022\017"
-  "\n\013ListAliases\020r\022\024\n\017CreatePartition\020\310\001\022\022\n"
-  "\rDropPartition\020\311\001\022\021\n\014HasPartition\020\312\001\022\026\n\021"
-  "DescribePartition\020\313\001\022\023\n\016ShowPartitions\020\314"
-  "\001\022\023\n\016LoadPartitions\020\315\001\022\026\n\021ReleasePartiti"
-  "ons\020\316\001\022\021\n\014ShowSegments\020\372\001\022\024\n\017DescribeSeg"
-  "ment\020\373\001\022\021\n\014LoadSegments\020\374\001\022\024\n\017ReleaseSeg"
-  "ments\020\375\001\022\024\n\017HandoffSegments\020\376\001\022\030\n\023LoadBa"
-  "lanceSegments\020\377\001\022\025\n\020DescribeSegments\020\200\002\022"
-  "\034\n\027FederListIndexedSegment\020\201\002\022\"\n\035FederDe"
-  "scribeSegmentIndexData\020\202\002\022\020\n\013CreateIndex"
-  "\020\254\002\022\022\n\rDescribeIndex\020\255\002\022\016\n\tDropIndex\020\256\002\022"
-  "\027\n\022GetIndexStatistics\020\257\002\022\013\n\006Insert\020\220\003\022\013\n"
-  "\006Delete\020\221\003\022\n\n\005Flush\020\222\003\022\027\n\022ResendSegmentS"
-  "tats\020\223\003\022\013\n\006Upsert\020\224\003\022\013\n\006Search\020\364\003\022\021\n\014Sea"
-  "rchResult\020\365\003\022\022\n\rGetIndexState\020\366\003\022\032\n\025GetI"
-  "ndexBuildProgress\020\367\003\022\034\n\027GetCollectionSta"
-  "tistics\020\370\003\022\033\n\026GetPartitionStatistics\020\371\003\022"
-  "\r\n\010Retrieve\020\372\003\022\023\n\016RetrieveResult\020\373\003\022\024\n\017W"
-  "atchDmChannels\020\374\003\022\025\n\020RemoveDmChannels\020\375\003"
-  "\022\027\n\022WatchQueryChannels\020\376\003\022\030\n\023RemoveQuery"
-  "Channels\020\377\003\022\035\n\030SealedSegmentsChangeInfo\020"
-  "\200\004\022\027\n\022WatchDeltaChannels\020\201\004\022\024\n\017GetShardL"
-  "eaders\020\202\004\022\020\n\013GetReplicas\020\203\004\022\023\n\016UnsubDmCh"
-  "annel\020\204\004\022\024\n\017GetDistribution\020\205\004\022\025\n\020SyncDi"
-  "stribution\020\206\004\022\020\n\013SegmentInfo\020\330\004\022\017\n\nSyste"
-  "mInfo\020\331\004\022\024\n\017GetRecoveryInfo\020\332\004\022\024\n\017GetSeg"
-  "mentState\020\333\004\022\r\n\010TimeTick\020\260\t\022\023\n\016QueryNode"
-  "Stats\020\261\t\022\016\n\tLoadIndex\020\262\t\022\016\n\tRequestID\020\263\t"
-  "\022\017\n\nRequestTSO\020\264\t\022\024\n\017AllocateSegment\020\265\t\022"
-  "\026\n\021SegmentStatistics\020\266\t\022\025\n\020SegmentFlushD"
-  "one\020\267\t\022\017\n\nDataNodeTt\020\270\t\022\014\n\007Connect\020\271\t\022\024\n"
-  "\017ListClientInfos\020\272\t\022\023\n\016AllocTimestamp\020\273\t"
-  "\022\025\n\020CreateCredential\020\334\013\022\022\n\rGetCredential"
-  "\020\335\013\022\025\n\020DeleteCredential\020\336\013\022\025\n\020UpdateCred"
-  "ential\020\337\013\022\026\n\021ListCredUsernames\020\340\013\022\017\n\nCre"
-  "ateRole\020\300\014\022\r\n\010DropRole\020\301\014\022\024\n\017OperateUser"
-  "Role\020\302\014\022\017\n\nSelectRole\020\303\014\022\017\n\nSelectUser\020\304"
-  "\014\022\023\n\016SelectResource\020\305\014\022\025\n\020OperatePrivile"
-  "ge\020\306\014\022\020\n\013SelectGrant\020\307\014\022\033\n\026RefreshPolicy"
-  "InfoCache\020\310\014\022\017\n\nListPolicy\020\311\014\022\030\n\023CreateR"
-  "esourceGroup\020\244\r\022\026\n\021DropResourceGroup\020\245\r\022"
-  "\027\n\022ListResourceGroups\020\246\r\022\032\n\025DescribeReso"
-  "urceGroup\020\247\r\022\021\n\014TransferNode\020\250\r\022\024\n\017Trans"
-  "ferReplica\020\251\r\022\023\n\016CreateDatabase\020\211\016\022\021\n\014Dr"
-  "opDatabase\020\212\016\022\022\n\rListDatabases\020\213\016*\"\n\007Dsl"
-  "Type\022\007\n\003Dsl\020\000\022\016\n\nBoolExprV1\020\001*B\n\017Compact"
-  "ionState\022\021\n\rUndefiedState\020\000\022\r\n\tExecuting"
-  "\020\001\022\r\n\tCompleted\020\002*X\n\020ConsistencyLevel\022\n\n"
-  "\006Strong\020\000\022\013\n\007Session\020\001\022\013\n\007Bounded\020\002\022\016\n\nE"
-  "ventually\020\003\022\016\n\nCustomized\020\004*\236\001\n\013ImportSt"
-  "ate\022\021\n\rImportPending\020\000\022\020\n\014ImportFailed\020\001"
-  "\022\021\n\rImportStarted\020\002\022\023\n\017ImportPersisted\020\005"
-  "\022\021\n\rImportFlushed\020\010\022\023\n\017ImportCompleted\020\006"
-  "\022\032\n\026ImportFailedAndCleaned\020\007*2\n\nObjectTy"
-  "pe\022\016\n\nCollection\020\000\022\n\n\006Global\020\001\022\010\n\004User\020\002"
-  "*\241\010\n\017ObjectPrivilege\022\020\n\014PrivilegeAll\020\000\022\035"
-  "\n\031PrivilegeCreateCollection\020\001\022\033\n\027Privile"
-  "geDropCollection\020\002\022\037\n\033PrivilegeDescribeC"
-  "ollection\020\003\022\034\n\030PrivilegeShowCollections\020"
-  "\004\022\021\n\rPrivilegeLoad\020\005\022\024\n\020PrivilegeRelease"
-  "\020\006\022\027\n\023PrivilegeCompaction\020\007\022\023\n\017Privilege"
-  "Insert\020\010\022\023\n\017PrivilegeDelete\020\t\022\032\n\026Privile"
-  "geGetStatistics\020\n\022\030\n\024PrivilegeCreateInde"
-  "x\020\013\022\030\n\024PrivilegeIndexDetail\020\014\022\026\n\022Privile"
-  "geDropIndex\020\r\022\023\n\017PrivilegeSearch\020\016\022\022\n\016Pr"
-  "ivilegeFlush\020\017\022\022\n\016PrivilegeQuery\020\020\022\030\n\024Pr"
-  "ivilegeLoadBalance\020\021\022\023\n\017PrivilegeImport\020"
-  "\022\022\034\n\030PrivilegeCreateOwnership\020\023\022\027\n\023Privi"
-  "legeUpdateUser\020\024\022\032\n\026PrivilegeDropOwnersh"
-  "ip\020\025\022\034\n\030PrivilegeSelectOwnership\020\026\022\034\n\030Pr"
-  "ivilegeManageOwnership\020\027\022\027\n\023PrivilegeSel"
-  "ectUser\020\030\022\023\n\017PrivilegeUpsert\020\031\022 \n\034Privil"
-  "egeCreateResourceGroup\020\032\022\036\n\032PrivilegeDro"
-  "pResourceGroup\020\033\022\"\n\036PrivilegeDescribeRes"
-  "ourceGroup\020\034\022\037\n\033PrivilegeListResourceGro"
-  "ups\020\035\022\031\n\025PrivilegeTransferNode\020\036\022\034\n\030Priv"
-  "ilegeTransferReplica\020\037\022\037\n\033PrivilegeGetLo"
-  "adingProgress\020 \022\031\n\025PrivilegeGetLoadState"
-  "\020!\022\035\n\031PrivilegeRenameCollection\020\"\022\033\n\027Pri"
-  "vilegeCreateDatabase\020#\022\031\n\025PrivilegeDropD"
-  "atabase\020$\022\032\n\026PrivilegeListDatabases\020%\022\025\n"
-  "\021PrivilegeFlushAll\020&*S\n\tStateCode\022\020\n\014Ini"
-  "tializing\020\000\022\013\n\007Healthy\020\001\022\014\n\010Abnormal\020\002\022\013"
-  "\n\007StandBy\020\003\022\014\n\010Stopping\020\004*c\n\tLoadState\022\025"
-  "\n\021LoadStateNotExist\020\000\022\024\n\020LoadStateNotLoa"
-  "d\020\001\022\024\n\020LoadStateLoading\020\002\022\023\n\017LoadStateLo"
-  "aded\020\003:^\n\021privilege_ext_obj\022\037.google.pro"
-  "tobuf.MessageOptions\030\351\007 \001(\0132!.milvus.pro"
-  "to.common.PrivilegeExtBm\n\016io.milvus.grpc"
-  "B\013CommonProtoP\001Z4github.com/milvus-io/mi"
-  "lvus-proto/go-api/v2/commonpb\240\001\001\252\002\022Milvu"
-  "s.Client.Grpcb\006proto3"
+  "Entry\0321\n\017PropertiesEntry\022\013\n\003key\030\001 \001(\t\022\r\n"
+  "\005value\030\002 \001(\t:\0028\001\"7\n\tMsgHeader\022*\n\004base\030\001 "
+  "\001(\0132\034.milvus.proto.common.MsgBase\"M\n\014DML"
+  "MsgHeader\022*\n\004base\030\001 \001(\0132\034.milvus.proto.c"
+  "ommon.MsgBase\022\021\n\tshardName\030\002 \001(\t\"\273\001\n\014Pri"
+  "vilegeExt\0224\n\013object_type\030\001 \001(\0162\037.milvus."
+  "proto.common.ObjectType\022>\n\020object_privil"
+  "ege\030\002 \001(\0162$.milvus.proto.common.ObjectPr"
+  "ivilege\022\031\n\021object_name_index\030\003 \001(\005\022\032\n\022ob"
+  "ject_name_indexs\030\004 \001(\005\"2\n\014SegmentStats\022\021"
+  "\n\tSegmentID\030\001 \001(\003\022\017\n\007NumRows\030\002 \001(\003\"\325\001\n\nC"
+  "lientInfo\022\020\n\010sdk_type\030\001 \001(\t\022\023\n\013sdk_versi"
+  "on\030\002 \001(\t\022\022\n\nlocal_time\030\003 \001(\t\022\014\n\004user\030\004 \001"
+  "(\t\022\014\n\004host\030\005 \001(\t\022\?\n\010reserved\030\006 \003(\0132-.mil"
+  "vus.proto.common.ClientInfo.ReservedEntr"
+  "y\032/\n\rReservedEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005value"
+  "\030\002 \001(\t:\0028\001\"\343\001\n\nServerInfo\022\022\n\nbuild_tags\030"
+  "\001 \001(\t\022\022\n\nbuild_time\030\002 \001(\t\022\022\n\ngit_commit\030"
+  "\003 \001(\t\022\022\n\ngo_version\030\004 \001(\t\022\023\n\013deploy_mode"
+  "\030\005 \001(\t\022\?\n\010reserved\030\006 \003(\0132-.milvus.proto."
+  "common.ServerInfo.ReservedEntry\032/\n\rReser"
+  "vedEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005value\030\002 \001(\t:\0028\001"
+  "*\303\n\n\tErrorCode\022\013\n\007Success\020\000\022\023\n\017Unexpecte"
+  "dError\020\001\022\021\n\rConnectFailed\020\002\022\024\n\020Permissio"
+  "nDenied\020\003\022\027\n\023CollectionNotExists\020\004\022\023\n\017Il"
+  "legalArgument\020\005\022\024\n\020IllegalDimension\020\007\022\024\n"
+  "\020IllegalIndexType\020\010\022\031\n\025IllegalCollection"
+  "Name\020\t\022\017\n\013IllegalTOPK\020\n\022\024\n\020IllegalRowRec"
+  "ord\020\013\022\023\n\017IllegalVectorID\020\014\022\027\n\023IllegalSea"
+  "rchResult\020\r\022\020\n\014FileNotFound\020\016\022\016\n\nMetaFai"
+  "led\020\017\022\017\n\013CacheFailed\020\020\022\026\n\022CannotCreateFo"
+  "lder\020\021\022\024\n\020CannotCreateFile\020\022\022\026\n\022CannotDe"
+  "leteFolder\020\023\022\024\n\020CannotDeleteFile\020\024\022\023\n\017Bu"
+  "ildIndexError\020\025\022\020\n\014IllegalNLIST\020\026\022\025\n\021Ill"
+  "egalMetricType\020\027\022\017\n\013OutOfMemory\020\030\022\021\n\rInd"
+  "exNotExist\020\031\022\023\n\017EmptyCollection\020\032\022\033\n\027Upd"
+  "ateImportTaskFailure\020\033\022\032\n\026CollectionName"
+  "NotFound\020\034\022\033\n\027CreateCredentialFailure\020\035\022"
+  "\033\n\027UpdateCredentialFailure\020\036\022\033\n\027DeleteCr"
+  "edentialFailure\020\037\022\030\n\024GetCredentialFailur"
+  "e\020 \022\030\n\024ListCredUsersFailure\020!\022\022\n\016GetUser"
+  "Failure\020\"\022\025\n\021CreateRoleFailure\020#\022\023\n\017Drop"
+  "RoleFailure\020$\022\032\n\026OperateUserRoleFailure\020"
+  "%\022\025\n\021SelectRoleFailure\020&\022\025\n\021SelectUserFa"
+  "ilure\020\'\022\031\n\025SelectResourceFailure\020(\022\033\n\027Op"
+  "eratePrivilegeFailure\020)\022\026\n\022SelectGrantFa"
+  "ilure\020*\022!\n\035RefreshPolicyInfoCacheFailure"
+  "\020+\022\025\n\021ListPolicyFailure\020,\022\022\n\016NotShardLea"
+  "der\020-\022\026\n\022NoReplicaAvailable\020.\022\023\n\017Segment"
+  "NotFound\020/\022\r\n\tForceDeny\0200\022\r\n\tRateLimit\0201"
+  "\022\022\n\016NodeIDNotMatch\0202\022\024\n\020UpsertAutoIDTrue"
+  "\0203\022\034\n\030InsufficientMemoryToLoad\0204\022\030\n\024Memo"
+  "ryQuotaExhausted\0205\022\026\n\022DiskQuotaExhausted"
+  "\0206\022\025\n\021TimeTickLongDelay\0207\022\021\n\rNotReadySer"
+  "ve\0208\022\033\n\027NotReadyCoordActivating\0209\022\017\n\013Dat"
+  "aCoordNA\020d\022\022\n\rDDRequestRace\020\350\007*c\n\nIndexS"
+  "tate\022\022\n\016IndexStateNone\020\000\022\014\n\010Unissued\020\001\022\016"
+  "\n\nInProgress\020\002\022\014\n\010Finished\020\003\022\n\n\006Failed\020\004"
+  "\022\t\n\005Retry\020\005*\202\001\n\014SegmentState\022\024\n\020SegmentS"
+  "tateNone\020\000\022\014\n\010NotExist\020\001\022\013\n\007Growing\020\002\022\n\n"
+  "\006Sealed\020\003\022\013\n\007Flushed\020\004\022\014\n\010Flushing\020\005\022\013\n\007"
+  "Dropped\020\006\022\r\n\tImporting\020\007*i\n\017PlaceholderT"
+  "ype\022\010\n\004None\020\000\022\020\n\014BinaryVector\020d\022\017\n\013Float"
+  "Vector\020e\022\021\n\rFloat16Vector\020f\022\t\n\005Int64\020\005\022\013"
+  "\n\007VarChar\020\025*\264\020\n\007MsgType\022\r\n\tUndefined\020\000\022\024"
+  "\n\020CreateCollection\020d\022\022\n\016DropCollection\020e"
+  "\022\021\n\rHasCollection\020f\022\026\n\022DescribeCollectio"
+  "n\020g\022\023\n\017ShowCollections\020h\022\024\n\020GetSystemCon"
+  "figs\020i\022\022\n\016LoadCollection\020j\022\025\n\021ReleaseCol"
+  "lection\020k\022\017\n\013CreateAlias\020l\022\r\n\tDropAlias\020"
+  "m\022\016\n\nAlterAlias\020n\022\023\n\017AlterCollection\020o\022\024"
+  "\n\020RenameCollection\020p\022\021\n\rDescribeAlias\020q\022"
+  "\017\n\013ListAliases\020r\022\024\n\017CreatePartition\020\310\001\022\022"
+  "\n\rDropPartition\020\311\001\022\021\n\014HasPartition\020\312\001\022\026\n"
+  "\021DescribePartition\020\313\001\022\023\n\016ShowPartitions\020"
+  "\314\001\022\023\n\016LoadPartitions\020\315\001\022\026\n\021ReleasePartit"
+  "ions\020\316\001\022\021\n\014ShowSegments\020\372\001\022\024\n\017DescribeSe"
+  "gment\020\373\001\022\021\n\014LoadSegments\020\374\001\022\024\n\017ReleaseSe"
+  "gments\020\375\001\022\024\n\017HandoffSegments\020\376\001\022\030\n\023LoadB"
+  "alanceSegments\020\377\001\022\025\n\020DescribeSegments\020\200\002"
+  "\022\034\n\027FederListIndexedSegment\020\201\002\022\"\n\035FederD"
+  "escribeSegmentIndexData\020\202\002\022\020\n\013CreateInde"
+  "x\020\254\002\022\022\n\rDescribeIndex\020\255\002\022\016\n\tDropIndex\020\256\002"
+  "\022\027\n\022GetIndexStatistics\020\257\002\022\013\n\006Insert\020\220\003\022\013"
+  "\n\006Delete\020\221\003\022\n\n\005Flush\020\222\003\022\027\n\022ResendSegment"
+  "Stats\020\223\003\022\013\n\006Upsert\020\224\003\022\013\n\006Search\020\364\003\022\021\n\014Se"
+  "archResult\020\365\003\022\022\n\rGetIndexState\020\366\003\022\032\n\025Get"
+  "IndexBuildProgress\020\367\003\022\034\n\027GetCollectionSt"
+  "atistics\020\370\003\022\033\n\026GetPartitionStatistics\020\371\003"
+  "\022\r\n\010Retrieve\020\372\003\022\023\n\016RetrieveResult\020\373\003\022\024\n\017"
+  "WatchDmChannels\020\374\003\022\025\n\020RemoveDmChannels\020\375"
+  "\003\022\027\n\022WatchQueryChannels\020\376\003\022\030\n\023RemoveQuer"
+  "yChannels\020\377\003\022\035\n\030SealedSegmentsChangeInfo"
+  "\020\200\004\022\027\n\022WatchDeltaChannels\020\201\004\022\024\n\017GetShard"
+  "Leaders\020\202\004\022\020\n\013GetReplicas\020\203\004\022\023\n\016UnsubDmC"
+  "hannel\020\204\004\022\024\n\017GetDistribution\020\205\004\022\025\n\020SyncD"
+  "istribution\020\206\004\022\020\n\013SegmentInfo\020\330\004\022\017\n\nSyst"
+  "emInfo\020\331\004\022\024\n\017GetRecoveryInfo\020\332\004\022\024\n\017GetSe"
+  "gmentState\020\333\004\022\r\n\010TimeTick\020\260\t\022\023\n\016QueryNod"
+  "eStats\020\261\t\022\016\n\tLoadIndex\020\262\t\022\016\n\tRequestID\020\263"
+  "\t\022\017\n\nRequestTSO\020\264\t\022\024\n\017AllocateSegment\020\265\t"
+  "\022\026\n\021SegmentStatistics\020\266\t\022\025\n\020SegmentFlush"
+  "Done\020\267\t\022\017\n\nDataNodeTt\020\270\t\022\014\n\007Connect\020\271\t\022\024"
+  "\n\017ListClientInfos\020\272\t\022\023\n\016AllocTimestamp\020\273"
+  "\t\022\025\n\020CreateCredential\020\334\013\022\022\n\rGetCredentia"
+  "l\020\335\013\022\025\n\020DeleteCredential\020\336\013\022\025\n\020UpdateCre"
+  "dential\020\337\013\022\026\n\021ListCredUsernames\020\340\013\022\017\n\nCr"
+  "eateRole\020\300\014\022\r\n\010DropRole\020\301\014\022\024\n\017OperateUse"
+  "rRole\020\302\014\022\017\n\nSelectRole\020\303\014\022\017\n\nSelectUser\020"
+  "\304\014\022\023\n\016SelectResource\020\305\014\022\025\n\020OperatePrivil"
+  "ege\020\306\014\022\020\n\013SelectGrant\020\307\014\022\033\n\026RefreshPolic"
+  "yInfoCache\020\310\014\022\017\n\nListPolicy\020\311\014\022\030\n\023Create"
+  "ResourceGroup\020\244\r\022\026\n\021DropResourceGroup\020\245\r"
+  "\022\027\n\022ListResourceGroups\020\246\r\022\032\n\025DescribeRes"
+  "ourceGroup\020\247\r\022\021\n\014TransferNode\020\250\r\022\024\n\017Tran"
+  "sferReplica\020\251\r\022\023\n\016CreateDatabase\020\211\016\022\021\n\014D"
+  "ropDatabase\020\212\016\022\022\n\rListDatabases\020\213\016*\"\n\007Ds"
+  "lType\022\007\n\003Dsl\020\000\022\016\n\nBoolExprV1\020\001*B\n\017Compac"
+  "tionState\022\021\n\rUndefiedState\020\000\022\r\n\tExecutin"
+  "g\020\001\022\r\n\tCompleted\020\002*X\n\020ConsistencyLevel\022\n"
+  "\n\006Strong\020\000\022\013\n\007Session\020\001\022\013\n\007Bounded\020\002\022\016\n\n"
+  "Eventually\020\003\022\016\n\nCustomized\020\004*\236\001\n\013ImportS"
+  "tate\022\021\n\rImportPending\020\000\022\020\n\014ImportFailed\020"
+  "\001\022\021\n\rImportStarted\020\002\022\023\n\017ImportPersisted\020"
+  "\005\022\021\n\rImportFlushed\020\010\022\023\n\017ImportCompleted\020"
+  "\006\022\032\n\026ImportFailedAndCleaned\020\007*2\n\nObjectT"
+  "ype\022\016\n\nCollection\020\000\022\n\n\006Global\020\001\022\010\n\004User\020"
+  "\002*\241\010\n\017ObjectPrivilege\022\020\n\014PrivilegeAll\020\000\022"
+  "\035\n\031PrivilegeCreateCollection\020\001\022\033\n\027Privil"
+  "egeDropCollection\020\002\022\037\n\033PrivilegeDescribe"
+  "Collection\020\003\022\034\n\030PrivilegeShowCollections"
+  "\020\004\022\021\n\rPrivilegeLoad\020\005\022\024\n\020PrivilegeReleas"
+  "e\020\006\022\027\n\023PrivilegeCompaction\020\007\022\023\n\017Privileg"
+  "eInsert\020\010\022\023\n\017PrivilegeDelete\020\t\022\032\n\026Privil"
+  "egeGetStatistics\020\n\022\030\n\024PrivilegeCreateInd"
+  "ex\020\013\022\030\n\024PrivilegeIndexDetail\020\014\022\026\n\022Privil"
+  "egeDropIndex\020\r\022\023\n\017PrivilegeSearch\020\016\022\022\n\016P"
+  "rivilegeFlush\020\017\022\022\n\016PrivilegeQuery\020\020\022\030\n\024P"
+  "rivilegeLoadBalance\020\021\022\023\n\017PrivilegeImport"
+  "\020\022\022\034\n\030PrivilegeCreateOwnership\020\023\022\027\n\023Priv"
+  "ilegeUpdateUser\020\024\022\032\n\026PrivilegeDropOwners"
+  "hip\020\025\022\034\n\030PrivilegeSelectOwnership\020\026\022\034\n\030P"
+  "rivilegeManageOwnership\020\027\022\027\n\023PrivilegeSe"
+  "lectUser\020\030\022\023\n\017PrivilegeUpsert\020\031\022 \n\034Privi"
+  "legeCreateResourceGroup\020\032\022\036\n\032PrivilegeDr"
+  "opResourceGroup\020\033\022\"\n\036PrivilegeDescribeRe"
+  "sourceGroup\020\034\022\037\n\033PrivilegeListResourceGr"
+  "oups\020\035\022\031\n\025PrivilegeTransferNode\020\036\022\034\n\030Pri"
+  "vilegeTransferReplica\020\037\022\037\n\033PrivilegeGetL"
+  "oadingProgress\020 \022\031\n\025PrivilegeGetLoadStat"
+  "e\020!\022\035\n\031PrivilegeRenameCollection\020\"\022\033\n\027Pr"
+  "ivilegeCreateDatabase\020#\022\031\n\025PrivilegeDrop"
+  "Database\020$\022\032\n\026PrivilegeListDatabases\020%\022\025"
+  "\n\021PrivilegeFlushAll\020&*S\n\tStateCode\022\020\n\014In"
+  "itializing\020\000\022\013\n\007Healthy\020\001\022\014\n\010Abnormal\020\002\022"
+  "\013\n\007StandBy\020\003\022\014\n\010Stopping\020\004*c\n\tLoadState\022"
+  "\025\n\021LoadStateNotExist\020\000\022\024\n\020LoadStateNotLo"
+  "ad\020\001\022\024\n\020LoadStateLoading\020\002\022\023\n\017LoadStateL"
+  "oaded\020\003:^\n\021privilege_ext_obj\022\037.google.pr"
+  "otobuf.MessageOptions\030\351\007 \001(\0132!.milvus.pr"
+  "oto.common.PrivilegeExtBm\n\016io.milvus.grp"
+  "cB\013CommonProtoP\001Z4github.com/milvus-io/m"
+  "ilvus-proto/go-api/v2/commonpb\240\001\001\252\002\022Milv"
+  "us.Client.Grpcb\006proto3"
   ;
 static const ::_pbi::DescriptorTable* const descriptor_table_common_2eproto_deps[1] = {
   &::descriptor_table_google_2fprotobuf_2fdescriptor_2eproto,
 };
 static ::_pbi::once_flag descriptor_table_common_2eproto_once;
 const ::_pbi::DescriptorTable descriptor_table_common_2eproto = {
-    false, false, 7341, descriptor_table_protodef_common_2eproto,
+    false, false, 7222, descriptor_table_protodef_common_2eproto,
     "common.proto",
-    &descriptor_table_common_2eproto_once, descriptor_table_common_2eproto_deps, 1, 18,
+    &descriptor_table_common_2eproto_once, descriptor_table_common_2eproto_deps, 1, 17,
     schemas, file_default_instances, TableStruct_common_2eproto::offsets,
     file_level_metadata_common_2eproto, file_level_enum_descriptors_common_2eproto,
     file_level_service_descriptors_common_2eproto,
@@ -2771,13 +2742,8 @@ ::PROTOBUF_NAMESPACE_ID::Metadata MsgBase_PropertiesEntry_DoNotUse::GetMetadata(
 
 class MsgBase::_Internal {
  public:
-  static const ::milvus::proto::common::ReplicateInfo& replicateinfo(const MsgBase* msg);
 };
 
-const ::milvus::proto::common::ReplicateInfo&
-MsgBase::_Internal::replicateinfo(const MsgBase* msg) {
-  return *msg->_impl_.replicateinfo_;
-}
 MsgBase::MsgBase(::PROTOBUF_NAMESPACE_ID::Arena* arena,
                          bool is_message_owned)
   : ::PROTOBUF_NAMESPACE_ID::Message(arena, is_message_owned) {
@@ -2792,7 +2758,6 @@ MsgBase::MsgBase(const MsgBase& from)
   MsgBase* const _this = this; (void)_this;
   new (&_impl_) Impl_{
       /*decltype(_impl_.properties_)*/{}
-    , decltype(_impl_.replicateinfo_){nullptr}
     , decltype(_impl_.msgid_){}
     , decltype(_impl_.timestamp_){}
     , decltype(_impl_.sourceid_){}
@@ -2802,9 +2767,6 @@ MsgBase::MsgBase(const MsgBase& from)
 
   _internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_);
   _this->_impl_.properties_.MergeFrom(from._impl_.properties_);
-  if (from._internal_has_replicateinfo()) {
-    _this->_impl_.replicateinfo_ = new ::milvus::proto::common::ReplicateInfo(*from._impl_.replicateinfo_);
-  }
   ::memcpy(&_impl_.msgid_, &from._impl_.msgid_,
     static_cast<size_t>(reinterpret_cast<char*>(&_impl_.msg_type_) -
     reinterpret_cast<char*>(&_impl_.msgid_)) + sizeof(_impl_.msg_type_));
@@ -2817,7 +2779,6 @@ inline void MsgBase::SharedCtor(
   (void)is_message_owned;
   new (&_impl_) Impl_{
       /*decltype(_impl_.properties_)*/{::_pbi::ArenaInitialized(), arena}
-    , decltype(_impl_.replicateinfo_){nullptr}
     , decltype(_impl_.msgid_){int64_t{0}}
     , decltype(_impl_.timestamp_){uint64_t{0u}}
     , decltype(_impl_.sourceid_){int64_t{0}}
@@ -2841,7 +2802,6 @@ inline void MsgBase::SharedDtor() {
   GOOGLE_DCHECK(GetArenaForAllocation() == nullptr);
   _impl_.properties_.Destruct();
   _impl_.properties_.~MapField();
-  if (this != internal_default_instance()) delete _impl_.replicateinfo_;
 }
 
 void MsgBase::ArenaDtor(void* object) {
@@ -2859,10 +2819,6 @@ void MsgBase::Clear() {
   (void) cached_has_bits;
 
   _impl_.properties_.Clear();
-  if (GetArenaForAllocation() == nullptr && _impl_.replicateinfo_ != nullptr) {
-    delete _impl_.replicateinfo_;
-  }
-  _impl_.replicateinfo_ = nullptr;
   ::memset(&_impl_.msgid_, 0, static_cast<size_t>(
       reinterpret_cast<char*>(&_impl_.msg_type_) -
       reinterpret_cast<char*>(&_impl_.msgid_)) + sizeof(_impl_.msg_type_));
@@ -2929,14 +2885,6 @@ const char* MsgBase::_InternalParse(const char* ptr, ::_pbi::ParseContext* ctx)
         } else
           goto handle_unusual;
         continue;
-      // .milvus.proto.common.ReplicateInfo replicateInfo = 7;
-      case 7:
-        if (PROTOBUF_PREDICT_TRUE(static_cast<uint8_t>(tag) == 58)) {
-          ptr = ctx->ParseMessage(_internal_mutable_replicateinfo(), ptr);
-          CHK_(ptr);
-        } else
-          goto handle_unusual;
-        continue;
       default:
         goto handle_unusual;
     }  // switch
@@ -3027,13 +2975,6 @@ uint8_t* MsgBase::_InternalSerialize(
     }
   }
 
-  // .milvus.proto.common.ReplicateInfo replicateInfo = 7;
-  if (this->_internal_has_replicateinfo()) {
-    target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::
-      InternalWriteMessage(7, _Internal::replicateinfo(this),
-        _Internal::replicateinfo(this).GetCachedSize(), target, stream);
-  }
-
   if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
     target = ::_pbi::WireFormat::InternalSerializeUnknownFieldsToArray(
         _internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance), target, stream);
@@ -3059,13 +3000,6 @@ size_t MsgBase::ByteSizeLong() const {
     total_size += MsgBase_PropertiesEntry_DoNotUse::Funcs::ByteSizeLong(it->first, it->second);
   }
 
-  // .milvus.proto.common.ReplicateInfo replicateInfo = 7;
-  if (this->_internal_has_replicateinfo()) {
-    total_size += 1 +
-      ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize(
-        *_impl_.replicateinfo_);
-  }
-
   // int64 msgID = 2;
   if (this->_internal_msgid() != 0) {
     total_size += ::_pbi::WireFormatLite::Int64SizePlusOne(this->_internal_msgid());
@@ -3111,10 +3045,6 @@ void MsgBase::MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const ::PROTOB
   (void) cached_has_bits;
 
   _this->_impl_.properties_.MergeFrom(from._impl_.properties_);
-  if (from._internal_has_replicateinfo()) {
-    _this->_internal_mutable_replicateinfo()->::milvus::proto::common::ReplicateInfo::MergeFrom(
-        from._internal_replicateinfo());
-  }
   if (from._internal_msgid() != 0) {
     _this->_internal_set_msgid(from._internal_msgid());
   }
@@ -3151,9 +3081,9 @@ void MsgBase::InternalSwap(MsgBase* other) {
   ::PROTOBUF_NAMESPACE_ID::internal::memswap<
       PROTOBUF_FIELD_OFFSET(MsgBase, _impl_.msg_type_)
       + sizeof(MsgBase::_impl_.msg_type_)
-      - PROTOBUF_FIELD_OFFSET(MsgBase, _impl_.replicateinfo_)>(
-          reinterpret_cast<char*>(&_impl_.replicateinfo_),
-          reinterpret_cast<char*>(&other->_impl_.replicateinfo_));
+      - PROTOBUF_FIELD_OFFSET(MsgBase, _impl_.msgid_)>(
+          reinterpret_cast<char*>(&_impl_.msgid_),
+          reinterpret_cast<char*>(&other->_impl_.msgid_));
 }
 
 ::PROTOBUF_NAMESPACE_ID::Metadata MsgBase::GetMetadata() const {
@@ -3164,217 +3094,6 @@ ::PROTOBUF_NAMESPACE_ID::Metadata MsgBase::GetMetadata() const {
 
 // ===================================================================
 
-class ReplicateInfo::_Internal {
- public:
-};
-
-ReplicateInfo::ReplicateInfo(::PROTOBUF_NAMESPACE_ID::Arena* arena,
-                         bool is_message_owned)
-  : ::PROTOBUF_NAMESPACE_ID::Message(arena, is_message_owned) {
-  SharedCtor(arena, is_message_owned);
-  // @@protoc_insertion_point(arena_constructor:milvus.proto.common.ReplicateInfo)
-}
-ReplicateInfo::ReplicateInfo(const ReplicateInfo& from)
-  : ::PROTOBUF_NAMESPACE_ID::Message() {
-  ReplicateInfo* const _this = this; (void)_this;
-  new (&_impl_) Impl_{
-      decltype(_impl_.msgtimestamp_){}
-    , decltype(_impl_.isreplicate_){}
-    , /*decltype(_impl_._cached_size_)*/{}};
-
-  _internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_);
-  ::memcpy(&_impl_.msgtimestamp_, &from._impl_.msgtimestamp_,
-    static_cast<size_t>(reinterpret_cast<char*>(&_impl_.isreplicate_) -
-    reinterpret_cast<char*>(&_impl_.msgtimestamp_)) + sizeof(_impl_.isreplicate_));
-  // @@protoc_insertion_point(copy_constructor:milvus.proto.common.ReplicateInfo)
-}
-
-inline void ReplicateInfo::SharedCtor(
-    ::_pb::Arena* arena, bool is_message_owned) {
-  (void)arena;
-  (void)is_message_owned;
-  new (&_impl_) Impl_{
-      decltype(_impl_.msgtimestamp_){uint64_t{0u}}
-    , decltype(_impl_.isreplicate_){false}
-    , /*decltype(_impl_._cached_size_)*/{}
-  };
-}
-
-ReplicateInfo::~ReplicateInfo() {
-  // @@protoc_insertion_point(destructor:milvus.proto.common.ReplicateInfo)
-  if (auto *arena = _internal_metadata_.DeleteReturnArena<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>()) {
-  (void)arena;
-    return;
-  }
-  SharedDtor();
-}
-
-inline void ReplicateInfo::SharedDtor() {
-  GOOGLE_DCHECK(GetArenaForAllocation() == nullptr);
-}
-
-void ReplicateInfo::SetCachedSize(int size) const {
-  _impl_._cached_size_.Set(size);
-}
-
-void ReplicateInfo::Clear() {
-// @@protoc_insertion_point(message_clear_start:milvus.proto.common.ReplicateInfo)
-  uint32_t cached_has_bits = 0;
-  // Prevent compiler warnings about cached_has_bits being unused
-  (void) cached_has_bits;
-
-  ::memset(&_impl_.msgtimestamp_, 0, static_cast<size_t>(
-      reinterpret_cast<char*>(&_impl_.isreplicate_) -
-      reinterpret_cast<char*>(&_impl_.msgtimestamp_)) + sizeof(_impl_.isreplicate_));
-  _internal_metadata_.Clear<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>();
-}
-
-const char* ReplicateInfo::_InternalParse(const char* ptr, ::_pbi::ParseContext* ctx) {
-#define CHK_(x) if (PROTOBUF_PREDICT_FALSE(!(x))) goto failure
-  while (!ctx->Done(&ptr)) {
-    uint32_t tag;
-    ptr = ::_pbi::ReadTag(ptr, &tag);
-    switch (tag >> 3) {
-      // bool isReplicate = 1;
-      case 1:
-        if (PROTOBUF_PREDICT_TRUE(static_cast<uint8_t>(tag) == 8)) {
-          _impl_.isreplicate_ = ::PROTOBUF_NAMESPACE_ID::internal::ReadVarint64(&ptr);
-          CHK_(ptr);
-        } else
-          goto handle_unusual;
-        continue;
-      // uint64 msgTimestamp = 2;
-      case 2:
-        if (PROTOBUF_PREDICT_TRUE(static_cast<uint8_t>(tag) == 16)) {
-          _impl_.msgtimestamp_ = ::PROTOBUF_NAMESPACE_ID::internal::ReadVarint64(&ptr);
-          CHK_(ptr);
-        } else
-          goto handle_unusual;
-        continue;
-      default:
-        goto handle_unusual;
-    }  // switch
-  handle_unusual:
-    if ((tag == 0) || ((tag & 7) == 4)) {
-      CHK_(ptr);
-      ctx->SetLastTag(tag);
-      goto message_done;
-    }
-    ptr = UnknownFieldParse(
-        tag,
-        _internal_metadata_.mutable_unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(),
-        ptr, ctx);
-    CHK_(ptr != nullptr);
-  }  // while
-message_done:
-  return ptr;
-failure:
-  ptr = nullptr;
-  goto message_done;
-#undef CHK_
-}
-
-uint8_t* ReplicateInfo::_InternalSerialize(
-    uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const {
-  // @@protoc_insertion_point(serialize_to_array_start:milvus.proto.common.ReplicateInfo)
-  uint32_t cached_has_bits = 0;
-  (void) cached_has_bits;
-
-  // bool isReplicate = 1;
-  if (this->_internal_isreplicate() != 0) {
-    target = stream->EnsureSpace(target);
-    target = ::_pbi::WireFormatLite::WriteBoolToArray(1, this->_internal_isreplicate(), target);
-  }
-
-  // uint64 msgTimestamp = 2;
-  if (this->_internal_msgtimestamp() != 0) {
-    target = stream->EnsureSpace(target);
-    target = ::_pbi::WireFormatLite::WriteUInt64ToArray(2, this->_internal_msgtimestamp(), target);
-  }
-
-  if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
-    target = ::_pbi::WireFormat::InternalSerializeUnknownFieldsToArray(
-        _internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance), target, stream);
-  }
-  // @@protoc_insertion_point(serialize_to_array_end:milvus.proto.common.ReplicateInfo)
-  return target;
-}
-
-size_t ReplicateInfo::ByteSizeLong() const {
-// @@protoc_insertion_point(message_byte_size_start:milvus.proto.common.ReplicateInfo)
-  size_t total_size = 0;
-
-  uint32_t cached_has_bits = 0;
-  // Prevent compiler warnings about cached_has_bits being unused
-  (void) cached_has_bits;
-
-  // uint64 msgTimestamp = 2;
-  if (this->_internal_msgtimestamp() != 0) {
-    total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(this->_internal_msgtimestamp());
-  }
-
-  // bool isReplicate = 1;
-  if (this->_internal_isreplicate() != 0) {
-    total_size += 1 + 1;
-  }
-
-  return MaybeComputeUnknownFieldsSize(total_size, &_impl_._cached_size_);
-}
-
-const ::PROTOBUF_NAMESPACE_ID::Message::ClassData ReplicateInfo::_class_data_ = {
-    ::PROTOBUF_NAMESPACE_ID::Message::CopyWithSourceCheck,
-    ReplicateInfo::MergeImpl
-};
-const ::PROTOBUF_NAMESPACE_ID::Message::ClassData*ReplicateInfo::GetClassData() const { return &_class_data_; }
-
-
-void ReplicateInfo::MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const ::PROTOBUF_NAMESPACE_ID::Message& from_msg) {
-  auto* const _this = static_cast<ReplicateInfo*>(&to_msg);
-  auto& from = static_cast<const ReplicateInfo&>(from_msg);
-  // @@protoc_insertion_point(class_specific_merge_from_start:milvus.proto.common.ReplicateInfo)
-  GOOGLE_DCHECK_NE(&from, _this);
-  uint32_t cached_has_bits = 0;
-  (void) cached_has_bits;
-
-  if (from._internal_msgtimestamp() != 0) {
-    _this->_internal_set_msgtimestamp(from._internal_msgtimestamp());
-  }
-  if (from._internal_isreplicate() != 0) {
-    _this->_internal_set_isreplicate(from._internal_isreplicate());
-  }
-  _this->_internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_);
-}
-
-void ReplicateInfo::CopyFrom(const ReplicateInfo& from) {
-// @@protoc_insertion_point(class_specific_copy_from_start:milvus.proto.common.ReplicateInfo)
-  if (&from == this) return;
-  Clear();
-  MergeFrom(from);
-}
-
-bool ReplicateInfo::IsInitialized() const {
-  return true;
-}
-
-void ReplicateInfo::InternalSwap(ReplicateInfo* other) {
-  using std::swap;
-  _internal_metadata_.InternalSwap(&other->_internal_metadata_);
-  ::PROTOBUF_NAMESPACE_ID::internal::memswap<
-      PROTOBUF_FIELD_OFFSET(ReplicateInfo, _impl_.isreplicate_)
-      + sizeof(ReplicateInfo::_impl_.isreplicate_)
-      - PROTOBUF_FIELD_OFFSET(ReplicateInfo, _impl_.msgtimestamp_)>(
-          reinterpret_cast<char*>(&_impl_.msgtimestamp_),
-          reinterpret_cast<char*>(&other->_impl_.msgtimestamp_));
-}
-
-::PROTOBUF_NAMESPACE_ID::Metadata ReplicateInfo::GetMetadata() const {
-  return ::_pbi::AssignDescriptors(
-      &descriptor_table_common_2eproto_getter, &descriptor_table_common_2eproto_once,
-      file_level_metadata_common_2eproto[9]);
-}
-
-// ===================================================================
-
 class MsgHeader::_Internal {
  public:
   static const ::milvus::proto::common::MsgBase& base(const MsgHeader* msg);
@@ -3563,7 +3282,7 @@ void MsgHeader::InternalSwap(MsgHeader* other) {
 ::PROTOBUF_NAMESPACE_ID::Metadata MsgHeader::GetMetadata() const {
   return ::_pbi::AssignDescriptors(
       &descriptor_table_common_2eproto_getter, &descriptor_table_common_2eproto_once,
-      file_level_metadata_common_2eproto[10]);
+      file_level_metadata_common_2eproto[9]);
 }
 
 // ===================================================================
@@ -3808,7 +3527,7 @@ void DMLMsgHeader::InternalSwap(DMLMsgHeader* other) {
 ::PROTOBUF_NAMESPACE_ID::Metadata DMLMsgHeader::GetMetadata() const {
   return ::_pbi::AssignDescriptors(
       &descriptor_table_common_2eproto_getter, &descriptor_table_common_2eproto_once,
-      file_level_metadata_common_2eproto[11]);
+      file_level_metadata_common_2eproto[10]);
 }
 
 // ===================================================================
@@ -4073,7 +3792,7 @@ void PrivilegeExt::InternalSwap(PrivilegeExt* other) {
 ::PROTOBUF_NAMESPACE_ID::Metadata PrivilegeExt::GetMetadata() const {
   return ::_pbi::AssignDescriptors(
       &descriptor_table_common_2eproto_getter, &descriptor_table_common_2eproto_once,
-      file_level_metadata_common_2eproto[12]);
+      file_level_metadata_common_2eproto[11]);
 }
 
 // ===================================================================
@@ -4284,7 +4003,7 @@ void SegmentStats::InternalSwap(SegmentStats* other) {
 ::PROTOBUF_NAMESPACE_ID::Metadata SegmentStats::GetMetadata() const {
   return ::_pbi::AssignDescriptors(
       &descriptor_table_common_2eproto_getter, &descriptor_table_common_2eproto_once,
-      file_level_metadata_common_2eproto[13]);
+      file_level_metadata_common_2eproto[12]);
 }
 
 // ===================================================================
@@ -4298,7 +4017,7 @@ void ClientInfo_ReservedEntry_DoNotUse::MergeFrom(const ClientInfo_ReservedEntry
 ::PROTOBUF_NAMESPACE_ID::Metadata ClientInfo_ReservedEntry_DoNotUse::GetMetadata() const {
   return ::_pbi::AssignDescriptors(
       &descriptor_table_common_2eproto_getter, &descriptor_table_common_2eproto_once,
-      file_level_metadata_common_2eproto[14]);
+      file_level_metadata_common_2eproto[13]);
 }
 
 // ===================================================================
@@ -4769,7 +4488,7 @@ void ClientInfo::InternalSwap(ClientInfo* other) {
 ::PROTOBUF_NAMESPACE_ID::Metadata ClientInfo::GetMetadata() const {
   return ::_pbi::AssignDescriptors(
       &descriptor_table_common_2eproto_getter, &descriptor_table_common_2eproto_once,
-      file_level_metadata_common_2eproto[15]);
+      file_level_metadata_common_2eproto[14]);
 }
 
 // ===================================================================
@@ -4783,7 +4502,7 @@ void ServerInfo_ReservedEntry_DoNotUse::MergeFrom(const ServerInfo_ReservedEntry
 ::PROTOBUF_NAMESPACE_ID::Metadata ServerInfo_ReservedEntry_DoNotUse::GetMetadata() const {
   return ::_pbi::AssignDescriptors(
       &descriptor_table_common_2eproto_getter, &descriptor_table_common_2eproto_once,
-      file_level_metadata_common_2eproto[16]);
+      file_level_metadata_common_2eproto[15]);
 }
 
 // ===================================================================
@@ -5254,7 +4973,7 @@ void ServerInfo::InternalSwap(ServerInfo* other) {
 ::PROTOBUF_NAMESPACE_ID::Metadata ServerInfo::GetMetadata() const {
   return ::_pbi::AssignDescriptors(
       &descriptor_table_common_2eproto_getter, &descriptor_table_common_2eproto_once,
-      file_level_metadata_common_2eproto[17]);
+      file_level_metadata_common_2eproto[16]);
 }
 PROTOBUF_ATTRIBUTE_INIT_PRIORITY2 ::PROTOBUF_NAMESPACE_ID::internal::ExtensionIdentifier< ::PROTOBUF_NAMESPACE_ID::MessageOptions,
     ::PROTOBUF_NAMESPACE_ID::internal::MessageTypeTraits< ::milvus::proto::common::PrivilegeExt >, 11, false>
@@ -5301,10 +5020,6 @@ template<> PROTOBUF_NOINLINE ::milvus::proto::common::MsgBase*
 Arena::CreateMaybeMessage< ::milvus::proto::common::MsgBase >(Arena* arena) {
   return Arena::CreateMessageInternal< ::milvus::proto::common::MsgBase >(arena);
 }
-template<> PROTOBUF_NOINLINE ::milvus::proto::common::ReplicateInfo*
-Arena::CreateMaybeMessage< ::milvus::proto::common::ReplicateInfo >(Arena* arena) {
-  return Arena::CreateMessageInternal< ::milvus::proto::common::ReplicateInfo >(arena);
-}
 template<> PROTOBUF_NOINLINE ::milvus::proto::common::MsgHeader*
 Arena::CreateMaybeMessage< ::milvus::proto::common::MsgHeader >(Arena* arena) {
   return Arena::CreateMessageInternal< ::milvus::proto::common::MsgHeader >(arena);
diff --git a/internal/core/src/pb/common.pb.h b/internal/core/src/pb/common.pb.h
index 690bcf51a8afd..21bb97cd79630 100644
--- a/internal/core/src/pb/common.pb.h
+++ b/internal/core/src/pb/common.pb.h
@@ -91,9 +91,6 @@ extern PlaceholderValueDefaultTypeInternal _PlaceholderValue_default_instance_;
 class PrivilegeExt;
 struct PrivilegeExtDefaultTypeInternal;
 extern PrivilegeExtDefaultTypeInternal _PrivilegeExt_default_instance_;
-class ReplicateInfo;
-struct ReplicateInfoDefaultTypeInternal;
-extern ReplicateInfoDefaultTypeInternal _ReplicateInfo_default_instance_;
 class SegmentStats;
 struct SegmentStatsDefaultTypeInternal;
 extern SegmentStatsDefaultTypeInternal _SegmentStats_default_instance_;
@@ -123,7 +120,6 @@ template<> ::milvus::proto::common::MsgHeader* Arena::CreateMaybeMessage<::milvu
 template<> ::milvus::proto::common::PlaceholderGroup* Arena::CreateMaybeMessage<::milvus::proto::common::PlaceholderGroup>(Arena*);
 template<> ::milvus::proto::common::PlaceholderValue* Arena::CreateMaybeMessage<::milvus::proto::common::PlaceholderValue>(Arena*);
 template<> ::milvus::proto::common::PrivilegeExt* Arena::CreateMaybeMessage<::milvus::proto::common::PrivilegeExt>(Arena*);
-template<> ::milvus::proto::common::ReplicateInfo* Arena::CreateMaybeMessage<::milvus::proto::common::ReplicateInfo>(Arena*);
 template<> ::milvus::proto::common::SegmentStats* Arena::CreateMaybeMessage<::milvus::proto::common::SegmentStats>(Arena*);
 template<> ::milvus::proto::common::ServerInfo* Arena::CreateMaybeMessage<::milvus::proto::common::ServerInfo>(Arena*);
 template<> ::milvus::proto::common::ServerInfo_ReservedEntry_DoNotUse* Arena::CreateMaybeMessage<::milvus::proto::common::ServerInfo_ReservedEntry_DoNotUse>(Arena*);
@@ -2011,7 +2007,6 @@ class MsgBase final :
 
   enum : int {
     kPropertiesFieldNumber = 6,
-    kReplicateInfoFieldNumber = 7,
     kMsgIDFieldNumber = 2,
     kTimestampFieldNumber = 3,
     kSourceIDFieldNumber = 4,
@@ -2035,24 +2030,6 @@ class MsgBase final :
   ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >*
       mutable_properties();
 
-  // .milvus.proto.common.ReplicateInfo replicateInfo = 7;
-  bool has_replicateinfo() const;
-  private:
-  bool _internal_has_replicateinfo() const;
-  public:
-  void clear_replicateinfo();
-  const ::milvus::proto::common::ReplicateInfo& replicateinfo() const;
-  PROTOBUF_NODISCARD ::milvus::proto::common::ReplicateInfo* release_replicateinfo();
-  ::milvus::proto::common::ReplicateInfo* mutable_replicateinfo();
-  void set_allocated_replicateinfo(::milvus::proto::common::ReplicateInfo* replicateinfo);
-  private:
-  const ::milvus::proto::common::ReplicateInfo& _internal_replicateinfo() const;
-  ::milvus::proto::common::ReplicateInfo* _internal_mutable_replicateinfo();
-  public:
-  void unsafe_arena_set_allocated_replicateinfo(
-      ::milvus::proto::common::ReplicateInfo* replicateinfo);
-  ::milvus::proto::common::ReplicateInfo* unsafe_arena_release_replicateinfo();
-
   // int64 msgID = 2;
   void clear_msgid();
   int64_t msgid() const;
@@ -2111,7 +2088,6 @@ class MsgBase final :
         std::string, std::string,
         ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_STRING,
         ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_STRING> properties_;
-    ::milvus::proto::common::ReplicateInfo* replicateinfo_;
     int64_t msgid_;
     uint64_t timestamp_;
     int64_t sourceid_;
@@ -2124,165 +2100,6 @@ class MsgBase final :
 };
 // -------------------------------------------------------------------
 
-class ReplicateInfo final :
-    public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:milvus.proto.common.ReplicateInfo) */ {
- public:
-  inline ReplicateInfo() : ReplicateInfo(nullptr) {}
-  ~ReplicateInfo() override;
-  explicit PROTOBUF_CONSTEXPR ReplicateInfo(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized);
-
-  ReplicateInfo(const ReplicateInfo& from);
-  ReplicateInfo(ReplicateInfo&& from) noexcept
-    : ReplicateInfo() {
-    *this = ::std::move(from);
-  }
-
-  inline ReplicateInfo& operator=(const ReplicateInfo& from) {
-    CopyFrom(from);
-    return *this;
-  }
-  inline ReplicateInfo& operator=(ReplicateInfo&& from) noexcept {
-    if (this == &from) return *this;
-    if (GetOwningArena() == from.GetOwningArena()
-  #ifdef PROTOBUF_FORCE_COPY_IN_MOVE
-        && GetOwningArena() != nullptr
-  #endif  // !PROTOBUF_FORCE_COPY_IN_MOVE
-    ) {
-      InternalSwap(&from);
-    } else {
-      CopyFrom(from);
-    }
-    return *this;
-  }
-
-  static const ::PROTOBUF_NAMESPACE_ID::Descriptor* descriptor() {
-    return GetDescriptor();
-  }
-  static const ::PROTOBUF_NAMESPACE_ID::Descriptor* GetDescriptor() {
-    return default_instance().GetMetadata().descriptor;
-  }
-  static const ::PROTOBUF_NAMESPACE_ID::Reflection* GetReflection() {
-    return default_instance().GetMetadata().reflection;
-  }
-  static const ReplicateInfo& default_instance() {
-    return *internal_default_instance();
-  }
-  static inline const ReplicateInfo* internal_default_instance() {
-    return reinterpret_cast<const ReplicateInfo*>(
-               &_ReplicateInfo_default_instance_);
-  }
-  static constexpr int kIndexInFileMessages =
-    9;
-
-  friend void swap(ReplicateInfo& a, ReplicateInfo& b) {
-    a.Swap(&b);
-  }
-  inline void Swap(ReplicateInfo* other) {
-    if (other == this) return;
-  #ifdef PROTOBUF_FORCE_COPY_IN_SWAP
-    if (GetOwningArena() != nullptr &&
-        GetOwningArena() == other->GetOwningArena()) {
-   #else  // PROTOBUF_FORCE_COPY_IN_SWAP
-    if (GetOwningArena() == other->GetOwningArena()) {
-  #endif  // !PROTOBUF_FORCE_COPY_IN_SWAP
-      InternalSwap(other);
-    } else {
-      ::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(this, other);
-    }
-  }
-  void UnsafeArenaSwap(ReplicateInfo* other) {
-    if (other == this) return;
-    GOOGLE_DCHECK(GetOwningArena() == other->GetOwningArena());
-    InternalSwap(other);
-  }
-
-  // implements Message ----------------------------------------------
-
-  ReplicateInfo* New(::PROTOBUF_NAMESPACE_ID::Arena* arena = nullptr) const final {
-    return CreateMaybeMessage<ReplicateInfo>(arena);
-  }
-  using ::PROTOBUF_NAMESPACE_ID::Message::CopyFrom;
-  void CopyFrom(const ReplicateInfo& from);
-  using ::PROTOBUF_NAMESPACE_ID::Message::MergeFrom;
-  void MergeFrom( const ReplicateInfo& from) {
-    ReplicateInfo::MergeImpl(*this, from);
-  }
-  private:
-  static void MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const ::PROTOBUF_NAMESPACE_ID::Message& from_msg);
-  public:
-  PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
-  bool IsInitialized() const final;
-
-  size_t ByteSizeLong() const final;
-  const char* _InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) final;
-  uint8_t* _InternalSerialize(
-      uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const final;
-  int GetCachedSize() const final { return _impl_._cached_size_.Get(); }
-
-  private:
-  void SharedCtor(::PROTOBUF_NAMESPACE_ID::Arena* arena, bool is_message_owned);
-  void SharedDtor();
-  void SetCachedSize(int size) const final;
-  void InternalSwap(ReplicateInfo* other);
-
-  private:
-  friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata;
-  static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() {
-    return "milvus.proto.common.ReplicateInfo";
-  }
-  protected:
-  explicit ReplicateInfo(::PROTOBUF_NAMESPACE_ID::Arena* arena,
-                       bool is_message_owned = false);
-  public:
-
-  static const ClassData _class_data_;
-  const ::PROTOBUF_NAMESPACE_ID::Message::ClassData*GetClassData() const final;
-
-  ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final;
-
-  // nested types ----------------------------------------------------
-
-  // accessors -------------------------------------------------------
-
-  enum : int {
-    kMsgTimestampFieldNumber = 2,
-    kIsReplicateFieldNumber = 1,
-  };
-  // uint64 msgTimestamp = 2;
-  void clear_msgtimestamp();
-  uint64_t msgtimestamp() const;
-  void set_msgtimestamp(uint64_t value);
-  private:
-  uint64_t _internal_msgtimestamp() const;
-  void _internal_set_msgtimestamp(uint64_t value);
-  public:
-
-  // bool isReplicate = 1;
-  void clear_isreplicate();
-  bool isreplicate() const;
-  void set_isreplicate(bool value);
-  private:
-  bool _internal_isreplicate() const;
-  void _internal_set_isreplicate(bool value);
-  public:
-
-  // @@protoc_insertion_point(class_scope:milvus.proto.common.ReplicateInfo)
- private:
-  class _Internal;
-
-  template <typename T> friend class ::PROTOBUF_NAMESPACE_ID::Arena::InternalHelper;
-  typedef void InternalArenaConstructable_;
-  typedef void DestructorSkippable_;
-  struct Impl_ {
-    uint64_t msgtimestamp_;
-    bool isreplicate_;
-    mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_;
-  };
-  union { Impl_ _impl_; };
-  friend struct ::TableStruct_common_2eproto;
-};
-// -------------------------------------------------------------------
-
 class MsgHeader final :
     public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:milvus.proto.common.MsgHeader) */ {
  public:
@@ -2331,7 +2148,7 @@ class MsgHeader final :
                &_MsgHeader_default_instance_);
   }
   static constexpr int kIndexInFileMessages =
-    10;
+    9;
 
   friend void swap(MsgHeader& a, MsgHeader& b) {
     a.Swap(&b);
@@ -2488,7 +2305,7 @@ class DMLMsgHeader final :
                &_DMLMsgHeader_default_instance_);
   }
   static constexpr int kIndexInFileMessages =
-    11;
+    10;
 
   friend void swap(DMLMsgHeader& a, DMLMsgHeader& b) {
     a.Swap(&b);
@@ -2661,7 +2478,7 @@ class PrivilegeExt final :
                &_PrivilegeExt_default_instance_);
   }
   static constexpr int kIndexInFileMessages =
-    12;
+    11;
 
   friend void swap(PrivilegeExt& a, PrivilegeExt& b) {
     a.Swap(&b);
@@ -2842,7 +2659,7 @@ class SegmentStats final :
                &_SegmentStats_default_instance_);
   }
   static constexpr int kIndexInFileMessages =
-    13;
+    12;
 
   friend void swap(SegmentStats& a, SegmentStats& b) {
     a.Swap(&b);
@@ -3029,7 +2846,7 @@ class ClientInfo final :
                &_ClientInfo_default_instance_);
   }
   static constexpr int kIndexInFileMessages =
-    15;
+    14;
 
   friend void swap(ClientInfo& a, ClientInfo& b) {
     a.Swap(&b);
@@ -3300,7 +3117,7 @@ class ServerInfo final :
                &_ServerInfo_default_instance_);
   }
   static constexpr int kIndexInFileMessages =
-    17;
+    16;
 
   friend void swap(ServerInfo& a, ServerInfo& b) {
     a.Swap(&b);
@@ -4262,140 +4079,6 @@ MsgBase::mutable_properties() {
   return _internal_mutable_properties();
 }
 
-// .milvus.proto.common.ReplicateInfo replicateInfo = 7;
-inline bool MsgBase::_internal_has_replicateinfo() const {
-  return this != internal_default_instance() && _impl_.replicateinfo_ != nullptr;
-}
-inline bool MsgBase::has_replicateinfo() const {
-  return _internal_has_replicateinfo();
-}
-inline void MsgBase::clear_replicateinfo() {
-  if (GetArenaForAllocation() == nullptr && _impl_.replicateinfo_ != nullptr) {
-    delete _impl_.replicateinfo_;
-  }
-  _impl_.replicateinfo_ = nullptr;
-}
-inline const ::milvus::proto::common::ReplicateInfo& MsgBase::_internal_replicateinfo() const {
-  const ::milvus::proto::common::ReplicateInfo* p = _impl_.replicateinfo_;
-  return p != nullptr ? *p : reinterpret_cast<const ::milvus::proto::common::ReplicateInfo&>(
-      ::milvus::proto::common::_ReplicateInfo_default_instance_);
-}
-inline const ::milvus::proto::common::ReplicateInfo& MsgBase::replicateinfo() const {
-  // @@protoc_insertion_point(field_get:milvus.proto.common.MsgBase.replicateInfo)
-  return _internal_replicateinfo();
-}
-inline void MsgBase::unsafe_arena_set_allocated_replicateinfo(
-    ::milvus::proto::common::ReplicateInfo* replicateinfo) {
-  if (GetArenaForAllocation() == nullptr) {
-    delete reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*>(_impl_.replicateinfo_);
-  }
-  _impl_.replicateinfo_ = replicateinfo;
-  if (replicateinfo) {
-    
-  } else {
-    
-  }
-  // @@protoc_insertion_point(field_unsafe_arena_set_allocated:milvus.proto.common.MsgBase.replicateInfo)
-}
-inline ::milvus::proto::common::ReplicateInfo* MsgBase::release_replicateinfo() {
-  
-  ::milvus::proto::common::ReplicateInfo* temp = _impl_.replicateinfo_;
-  _impl_.replicateinfo_ = nullptr;
-#ifdef PROTOBUF_FORCE_COPY_IN_RELEASE
-  auto* old =  reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*>(temp);
-  temp = ::PROTOBUF_NAMESPACE_ID::internal::DuplicateIfNonNull(temp);
-  if (GetArenaForAllocation() == nullptr) { delete old; }
-#else  // PROTOBUF_FORCE_COPY_IN_RELEASE
-  if (GetArenaForAllocation() != nullptr) {
-    temp = ::PROTOBUF_NAMESPACE_ID::internal::DuplicateIfNonNull(temp);
-  }
-#endif  // !PROTOBUF_FORCE_COPY_IN_RELEASE
-  return temp;
-}
-inline ::milvus::proto::common::ReplicateInfo* MsgBase::unsafe_arena_release_replicateinfo() {
-  // @@protoc_insertion_point(field_release:milvus.proto.common.MsgBase.replicateInfo)
-  
-  ::milvus::proto::common::ReplicateInfo* temp = _impl_.replicateinfo_;
-  _impl_.replicateinfo_ = nullptr;
-  return temp;
-}
-inline ::milvus::proto::common::ReplicateInfo* MsgBase::_internal_mutable_replicateinfo() {
-  
-  if (_impl_.replicateinfo_ == nullptr) {
-    auto* p = CreateMaybeMessage<::milvus::proto::common::ReplicateInfo>(GetArenaForAllocation());
-    _impl_.replicateinfo_ = p;
-  }
-  return _impl_.replicateinfo_;
-}
-inline ::milvus::proto::common::ReplicateInfo* MsgBase::mutable_replicateinfo() {
-  ::milvus::proto::common::ReplicateInfo* _msg = _internal_mutable_replicateinfo();
-  // @@protoc_insertion_point(field_mutable:milvus.proto.common.MsgBase.replicateInfo)
-  return _msg;
-}
-inline void MsgBase::set_allocated_replicateinfo(::milvus::proto::common::ReplicateInfo* replicateinfo) {
-  ::PROTOBUF_NAMESPACE_ID::Arena* message_arena = GetArenaForAllocation();
-  if (message_arena == nullptr) {
-    delete _impl_.replicateinfo_;
-  }
-  if (replicateinfo) {
-    ::PROTOBUF_NAMESPACE_ID::Arena* submessage_arena =
-        ::PROTOBUF_NAMESPACE_ID::Arena::InternalGetOwningArena(replicateinfo);
-    if (message_arena != submessage_arena) {
-      replicateinfo = ::PROTOBUF_NAMESPACE_ID::internal::GetOwnedMessage(
-          message_arena, replicateinfo, submessage_arena);
-    }
-    
-  } else {
-    
-  }
-  _impl_.replicateinfo_ = replicateinfo;
-  // @@protoc_insertion_point(field_set_allocated:milvus.proto.common.MsgBase.replicateInfo)
-}
-
-// -------------------------------------------------------------------
-
-// ReplicateInfo
-
-// bool isReplicate = 1;
-inline void ReplicateInfo::clear_isreplicate() {
-  _impl_.isreplicate_ = false;
-}
-inline bool ReplicateInfo::_internal_isreplicate() const {
-  return _impl_.isreplicate_;
-}
-inline bool ReplicateInfo::isreplicate() const {
-  // @@protoc_insertion_point(field_get:milvus.proto.common.ReplicateInfo.isReplicate)
-  return _internal_isreplicate();
-}
-inline void ReplicateInfo::_internal_set_isreplicate(bool value) {
-  
-  _impl_.isreplicate_ = value;
-}
-inline void ReplicateInfo::set_isreplicate(bool value) {
-  _internal_set_isreplicate(value);
-  // @@protoc_insertion_point(field_set:milvus.proto.common.ReplicateInfo.isReplicate)
-}
-
-// uint64 msgTimestamp = 2;
-inline void ReplicateInfo::clear_msgtimestamp() {
-  _impl_.msgtimestamp_ = uint64_t{0u};
-}
-inline uint64_t ReplicateInfo::_internal_msgtimestamp() const {
-  return _impl_.msgtimestamp_;
-}
-inline uint64_t ReplicateInfo::msgtimestamp() const {
-  // @@protoc_insertion_point(field_get:milvus.proto.common.ReplicateInfo.msgTimestamp)
-  return _internal_msgtimestamp();
-}
-inline void ReplicateInfo::_internal_set_msgtimestamp(uint64_t value) {
-  
-  _impl_.msgtimestamp_ = value;
-}
-inline void ReplicateInfo::set_msgtimestamp(uint64_t value) {
-  _internal_set_msgtimestamp(value);
-  // @@protoc_insertion_point(field_set:milvus.proto.common.ReplicateInfo.msgTimestamp)
-}
-
 // -------------------------------------------------------------------
 
 // MsgHeader
@@ -5367,8 +5050,6 @@ ServerInfo::mutable_reserved() {
 
 // -------------------------------------------------------------------
 
-// -------------------------------------------------------------------
-
 
 // @@protoc_insertion_point(namespace_scope)
 
diff --git a/internal/datanode/data_sync_service.go b/internal/datanode/data_sync_service.go
index c888060cefc95..ef3c51ed250d1 100644
--- a/internal/datanode/data_sync_service.go
+++ b/internal/datanode/data_sync_service.go
@@ -19,6 +19,7 @@ package datanode
 import (
 	"context"
 	"sync"
+	"time"
 
 	"github.com/cockroachdb/errors"
 	"go.uber.org/zap"
@@ -103,6 +104,7 @@ func (dsService *dataSyncService) GracefullyClose() {
 
 func (dsService *dataSyncService) close() {
 	dsService.stopOnce.Do(func() {
+		start := time.Now()
 		log := log.Ctx(dsService.ctx).With(
 			zap.Int64("collectionID", dsService.collectionID),
 			zap.String("vChanName", dsService.vchannelName),
@@ -111,7 +113,7 @@ func (dsService *dataSyncService) close() {
 			log.Info("dataSyncService closing flowgraph")
 			dsService.dispClient.Deregister(dsService.vchannelName)
 			dsService.fg.Close()
-			log.Info("dataSyncService flowgraph closed")
+			log.Info("dataSyncService flowgraph closed", zap.Duration("dur", time.Since(start)))
 		}
 
 		dsService.clearGlobalFlushingCache()
@@ -125,7 +127,7 @@ func (dsService *dataSyncService) close() {
 		dsService.cancelFn()
 		dsService.channel.close()
 
-		log.Info("dataSyncService closed")
+		log.Info("dataSyncService closed", zap.Duration("dur", time.Since(start)))
 	})
 }
 
diff --git a/internal/rootcoord/drop_collection_task.go b/internal/rootcoord/drop_collection_task.go
index f35fca1770355..c532007dfbef5 100644
--- a/internal/rootcoord/drop_collection_task.go
+++ b/internal/rootcoord/drop_collection_task.go
@@ -105,6 +105,7 @@ func (t *dropCollectionTask) Execute(ctx context.Context) error {
 	redoTask.AddAsyncStep(&removeDmlChannelsStep{
 		baseStep:  baseStep{core: t.core},
 		pChannels: collMeta.PhysicalChannelNames,
+		vChannels: collMeta.VirtualChannelNames,
 	})
 	redoTask.AddAsyncStep(newConfirmGCStep(t.core, collMeta.CollectionID, allPartition))
 	redoTask.AddAsyncStep(&deleteCollectionMetaStep{
diff --git a/internal/rootcoord/step.go b/internal/rootcoord/step.go
index 5a51996a6c05c..f773e24f1a2ee 100644
--- a/internal/rootcoord/step.go
+++ b/internal/rootcoord/step.go
@@ -19,6 +19,8 @@ package rootcoord
 import (
 	"context"
 	"fmt"
+	"github.com/milvus-io/milvus/pkg/log"
+	"go.uber.org/zap"
 	"time"
 
 	"github.com/milvus-io/milvus-proto/go-api/v2/milvuspb"
@@ -75,6 +77,9 @@ type deleteCollectionMetaStep struct {
 
 func (s *deleteCollectionMetaStep) Execute(ctx context.Context) ([]nestedStep, error) {
 	err := s.core.meta.RemoveCollection(ctx, s.collectionID, s.ts)
+	if err != nil {
+		log.Info("dyh debug, rc, deleteCollectionMetaStep done", zap.Int64("coll", s.collectionID))
+	}
 	return nil, err
 }
 
@@ -89,10 +94,12 @@ func (s *deleteCollectionMetaStep) Weight() stepPriority {
 type removeDmlChannelsStep struct {
 	baseStep
 	pChannels []string
+	vChannels []string
 }
 
 func (s *removeDmlChannelsStep) Execute(ctx context.Context) ([]nestedStep, error) {
 	s.core.chanTimeTick.removeDmlChannels(s.pChannels...)
+	log.Info("dyh debug, rc, removeDmlChannelsStep done", zap.Strings("vchannels", s.vChannels))
 	return nil, nil
 }
 
@@ -207,6 +214,7 @@ func (s *deleteCollectionDataStep) Execute(ctx context.Context) ([]nestedStep, e
 			channel:  channel,
 		})
 	}
+	log.Info("dyh debug, rc, deleteCollectionData done", zap.Int64("col", s.coll.CollectionID))
 	return children, nil
 }
 
@@ -232,6 +240,7 @@ func (s *waitForTsSyncedStep) Execute(ctx context.Context) ([]nestedStep, error)
 		// time.Sleep(Params.ProxyCfg.TimeTickInterval)
 		return nil, fmt.Errorf("ts not synced yet, channel: %s, synced: %d, want: %d", s.channel, syncedTs, s.ts)
 	}
+	log.Info("dyh debug, rc, waitForTsSyncedStep done")
 	return nil, nil
 }
 
@@ -471,6 +480,7 @@ func (b *confirmGCStep) Execute(ctx context.Context) ([]nestedStep, error) {
 
 	finished := b.core.broker.GcConfirm(ctx, b.collectionID, b.partitionID)
 	if finished {
+		log.Info("dyh debug, rc, confirmGCStep done", zap.Int64("col", b.collectionID))
 		return nil, nil
 	}