diff --git a/internal/core/src/pb/common.pb.cc b/internal/core/src/pb/common.pb.cc
index d71ef09b61..8b91d04636 100644
--- a/internal/core/src/pb/common.pb.cc
+++ b/internal/core/src/pb/common.pb.cc
@@ -121,9 +121,21 @@ struct AddressDefaultTypeInternal {
   };
 };
 PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 AddressDefaultTypeInternal _Address_default_instance_;
+PROTOBUF_CONSTEXPR MsgBase_PropertiesEntry_DoNotUse::MsgBase_PropertiesEntry_DoNotUse(
+    ::_pbi::ConstantInitialized) {}
+struct MsgBase_PropertiesEntry_DoNotUseDefaultTypeInternal {
+  PROTOBUF_CONSTEXPR MsgBase_PropertiesEntry_DoNotUseDefaultTypeInternal()
+      : _instance(::_pbi::ConstantInitialized{}) {}
+  ~MsgBase_PropertiesEntry_DoNotUseDefaultTypeInternal() {}
+  union {
+    MsgBase_PropertiesEntry_DoNotUse _instance;
+  };
+};
+PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 MsgBase_PropertiesEntry_DoNotUseDefaultTypeInternal _MsgBase_PropertiesEntry_DoNotUse_default_instance_;
 PROTOBUF_CONSTEXPR MsgBase::MsgBase(
     ::_pbi::ConstantInitialized): _impl_{
-    /*decltype(_impl_.msgid_)*/int64_t{0}
+    /*decltype(_impl_.properties_)*/{::_pbi::ConstantInitialized()}
+  , /*decltype(_impl_.msgid_)*/int64_t{0}
   , /*decltype(_impl_.timestamp_)*/uint64_t{0u}
   , /*decltype(_impl_.sourceid_)*/int64_t{0}
   , /*decltype(_impl_.targetid_)*/int64_t{0}
@@ -256,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[16];
+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;
 
@@ -317,6 +329,16 @@ const uint32_t TableStruct_common_2eproto::offsets[] PROTOBUF_SECTION_VARIABLE(p
   ~0u,  // no _inlined_string_donated_
   PROTOBUF_FIELD_OFFSET(::milvus::proto::common::Address, _impl_.ip_),
   PROTOBUF_FIELD_OFFSET(::milvus::proto::common::Address, _impl_.port_),
+  PROTOBUF_FIELD_OFFSET(::milvus::proto::common::MsgBase_PropertiesEntry_DoNotUse, _has_bits_),
+  PROTOBUF_FIELD_OFFSET(::milvus::proto::common::MsgBase_PropertiesEntry_DoNotUse, _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::MsgBase_PropertiesEntry_DoNotUse, key_),
+  PROTOBUF_FIELD_OFFSET(::milvus::proto::common::MsgBase_PropertiesEntry_DoNotUse, value_),
+  0,
+  1,
   ~0u,  // no _has_bits_
   PROTOBUF_FIELD_OFFSET(::milvus::proto::common::MsgBase, _internal_metadata_),
   ~0u,  // no _extensions_
@@ -328,6 +350,7 @@ const uint32_t TableStruct_common_2eproto::offsets[] PROTOBUF_SECTION_VARIABLE(p
   PROTOBUF_FIELD_OFFSET(::milvus::proto::common::MsgBase, _impl_.timestamp_),
   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_),
   ~0u,  // no _has_bits_
   PROTOBUF_FIELD_OFFSET(::milvus::proto::common::MsgHeader, _internal_metadata_),
   ~0u,  // no _extensions_
@@ -414,15 +437,16 @@ static const ::_pbi::MigrationSchema schemas[] PROTOBUF_SECTION_VARIABLE(protode
   { 32, -1, -1, sizeof(::milvus::proto::common::PlaceholderValue)},
   { 41, -1, -1, sizeof(::milvus::proto::common::PlaceholderGroup)},
   { 48, -1, -1, sizeof(::milvus::proto::common::Address)},
-  { 56, -1, -1, sizeof(::milvus::proto::common::MsgBase)},
-  { 67, -1, -1, sizeof(::milvus::proto::common::MsgHeader)},
-  { 74, -1, -1, sizeof(::milvus::proto::common::DMLMsgHeader)},
-  { 82, -1, -1, sizeof(::milvus::proto::common::PrivilegeExt)},
-  { 92, -1, -1, sizeof(::milvus::proto::common::SegmentStats)},
-  { 100, 108, -1, sizeof(::milvus::proto::common::ClientInfo_ReservedEntry_DoNotUse)},
-  { 110, -1, -1, sizeof(::milvus::proto::common::ClientInfo)},
-  { 122, 130, -1, sizeof(::milvus::proto::common::ServerInfo_ReservedEntry_DoNotUse)},
-  { 132, -1, -1, sizeof(::milvus::proto::common::ServerInfo)},
+  { 56, 64, -1, sizeof(::milvus::proto::common::MsgBase_PropertiesEntry_DoNotUse)},
+  { 66, -1, -1, sizeof(::milvus::proto::common::MsgBase)},
+  { 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[] = {
@@ -433,6 +457,7 @@ static const ::_pb::Message* const file_default_instances[] = {
   &::milvus::proto::common::_PlaceholderValue_default_instance_._instance,
   &::milvus::proto::common::_PlaceholderGroup_default_instance_._instance,
   &::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::_MsgHeader_default_instance_._instance,
   &::milvus::proto::common::_DMLMsgHeader_default_instance_._instance,
@@ -457,181 +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\"\177\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\"7\n\tMsgHeader\022*\n\004base\030"
-  "\001 \001(\0132\034.milvus.proto.common.MsgBase\"M\n\014D"
-  "MLMsgHeader\022*\n\004base\030\001 \001(\0132\034.milvus.proto"
-  ".common.MsgBase\022\021\n\tshardName\030\002 \001(\t\"\273\001\n\014P"
-  "rivilegeExt\0224\n\013object_type\030\001 \001(\0162\037.milvu"
-  "s.proto.common.ObjectType\022>\n\020object_priv"
-  "ilege\030\002 \001(\0162$.milvus.proto.common.Object"
-  "Privilege\022\031\n\021object_name_index\030\003 \001(\005\022\032\n\022"
-  "object_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"
-  "\nClientInfo\022\020\n\010sdk_type\030\001 \001(\t\022\023\n\013sdk_ver"
-  "sion\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-.m"
-  "ilvus.proto.common.ClientInfo.ReservedEn"
-  "try\032/\n\rReservedEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005val"
-  "ue\030\002 \001(\t:\0028\001\"\343\001\n\nServerInfo\022\022\n\nbuild_tag"
-  "s\030\001 \001(\t\022\022\n\nbuild_time\030\002 \001(\t\022\022\n\ngit_commi"
-  "t\030\003 \001(\t\022\022\n\ngo_version\030\004 \001(\t\022\023\n\013deploy_mo"
-  "de\030\005 \001(\t\022\?\n\010reserved\030\006 \003(\0132-.milvus.prot"
-  "o.common.ServerInfo.ReservedEntry\032/\n\rRes"
-  "ervedEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005value\030\002 \001(\t:\002"
-  "8\001*\303\n\n\tErrorCode\022\013\n\007Success\020\000\022\023\n\017Unexpec"
-  "tedError\020\001\022\021\n\rConnectFailed\020\002\022\024\n\020Permiss"
-  "ionDenied\020\003\022\027\n\023CollectionNotExists\020\004\022\023\n\017"
-  "IllegalArgument\020\005\022\024\n\020IllegalDimension\020\007\022"
-  "\024\n\020IllegalIndexType\020\010\022\031\n\025IllegalCollecti"
-  "onName\020\t\022\017\n\013IllegalTOPK\020\n\022\024\n\020IllegalRowR"
-  "ecord\020\013\022\023\n\017IllegalVectorID\020\014\022\027\n\023IllegalS"
-  "earchResult\020\r\022\020\n\014FileNotFound\020\016\022\016\n\nMetaF"
-  "ailed\020\017\022\017\n\013CacheFailed\020\020\022\026\n\022CannotCreate"
-  "Folder\020\021\022\024\n\020CannotCreateFile\020\022\022\026\n\022Cannot"
-  "DeleteFolder\020\023\022\024\n\020CannotDeleteFile\020\024\022\023\n\017"
-  "BuildIndexError\020\025\022\020\n\014IllegalNLIST\020\026\022\025\n\021I"
-  "llegalMetricType\020\027\022\017\n\013OutOfMemory\020\030\022\021\n\rI"
-  "ndexNotExist\020\031\022\023\n\017EmptyCollection\020\032\022\033\n\027U"
-  "pdateImportTaskFailure\020\033\022\032\n\026CollectionNa"
-  "meNotFound\020\034\022\033\n\027CreateCredentialFailure\020"
-  "\035\022\033\n\027UpdateCredentialFailure\020\036\022\033\n\027Delete"
-  "CredentialFailure\020\037\022\030\n\024GetCredentialFail"
-  "ure\020 \022\030\n\024ListCredUsersFailure\020!\022\022\n\016GetUs"
-  "erFailure\020\"\022\025\n\021CreateRoleFailure\020#\022\023\n\017Dr"
-  "opRoleFailure\020$\022\032\n\026OperateUserRoleFailur"
-  "e\020%\022\025\n\021SelectRoleFailure\020&\022\025\n\021SelectUser"
-  "Failure\020\'\022\031\n\025SelectResourceFailure\020(\022\033\n\027"
-  "OperatePrivilegeFailure\020)\022\026\n\022SelectGrant"
-  "Failure\020*\022!\n\035RefreshPolicyInfoCacheFailu"
-  "re\020+\022\025\n\021ListPolicyFailure\020,\022\022\n\016NotShardL"
-  "eader\020-\022\026\n\022NoReplicaAvailable\020.\022\023\n\017Segme"
-  "ntNotFound\020/\022\r\n\tForceDeny\0200\022\r\n\tRateLimit"
-  "\0201\022\022\n\016NodeIDNotMatch\0202\022\024\n\020UpsertAutoIDTr"
-  "ue\0203\022\034\n\030InsufficientMemoryToLoad\0204\022\030\n\024Me"
-  "moryQuotaExhausted\0205\022\026\n\022DiskQuotaExhaust"
-  "ed\0206\022\025\n\021TimeTickLongDelay\0207\022\021\n\rNotReadyS"
-  "erve\0208\022\033\n\027NotReadyCoordActivating\0209\022\017\n\013D"
-  "ataCoordNA\020d\022\022\n\rDDRequestRace\020\350\007*c\n\nInde"
-  "xState\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\020Segmen"
-  "tStateNone\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\007Dropped\020\006\022\r\n\tImporting\020\007*i\n\017Placeholde"
-  "rType\022\010\n\004None\020\000\022\020\n\014BinaryVector\020d\022\017\n\013Flo"
-  "atVector\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\022DescribeCollect"
-  "ion\020g\022\023\n\017ShowCollections\020h\022\024\n\020GetSystemC"
-  "onfigs\020i\022\022\n\016LoadCollection\020j\022\025\n\021ReleaseC"
-  "ollection\020k\022\017\n\013CreateAlias\020l\022\r\n\tDropAlia"
-  "s\020m\022\016\n\nAlterAlias\020n\022\023\n\017AlterCollection\020o"
-  "\022\024\n\020RenameCollection\020p\022\021\n\rDescribeAlias\020"
-  "q\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\016ShowPartition"
-  "s\020\314\001\022\023\n\016LoadPartitions\020\315\001\022\026\n\021ReleasePart"
-  "itions\020\316\001\022\021\n\014ShowSegments\020\372\001\022\024\n\017Describe"
-  "Segment\020\373\001\022\021\n\014LoadSegments\020\374\001\022\024\n\017Release"
-  "Segments\020\375\001\022\024\n\017HandoffSegments\020\376\001\022\030\n\023Loa"
-  "dBalanceSegments\020\377\001\022\025\n\020DescribeSegments\020"
-  "\200\002\022\034\n\027FederListIndexedSegment\020\201\002\022\"\n\035Fede"
-  "rDescribeSegmentIndexData\020\202\002\022\020\n\013CreateIn"
-  "dex\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\022ResendSegme"
-  "ntStats\020\223\003\022\013\n\006Upsert\020\224\003\022\013\n\006Search\020\364\003\022\021\n\014"
-  "SearchResult\020\365\003\022\022\n\rGetIndexState\020\366\003\022\032\n\025G"
-  "etIndexBuildProgress\020\367\003\022\034\n\027GetCollection"
-  "Statistics\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\017WatchDmChannels\020\374\003\022\025\n\020RemoveDmChannels"
-  "\020\375\003\022\027\n\022WatchQueryChannels\020\376\003\022\030\n\023RemoveQu"
-  "eryChannels\020\377\003\022\035\n\030SealedSegmentsChangeIn"
-  "fo\020\200\004\022\027\n\022WatchDeltaChannels\020\201\004\022\024\n\017GetSha"
-  "rdLeaders\020\202\004\022\020\n\013GetReplicas\020\203\004\022\023\n\016UnsubD"
-  "mChannel\020\204\004\022\024\n\017GetDistribution\020\205\004\022\025\n\020Syn"
-  "cDistribution\020\206\004\022\020\n\013SegmentInfo\020\330\004\022\017\n\nSy"
-  "stemInfo\020\331\004\022\024\n\017GetRecoveryInfo\020\332\004\022\024\n\017Get"
-  "SegmentState\020\333\004\022\r\n\010TimeTick\020\260\t\022\023\n\016QueryN"
-  "odeStats\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\020SegmentFlu"
-  "shDone\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\rGetCredent"
-  "ial\020\335\013\022\025\n\020DeleteCredential\020\336\013\022\025\n\020UpdateC"
-  "redential\020\337\013\022\026\n\021ListCredUsernames\020\340\013\022\017\n\n"
-  "CreateRole\020\300\014\022\r\n\010DropRole\020\301\014\022\024\n\017OperateU"
-  "serRole\020\302\014\022\017\n\nSelectRole\020\303\014\022\017\n\nSelectUse"
-  "r\020\304\014\022\023\n\016SelectResource\020\305\014\022\025\n\020OperatePriv"
-  "ilege\020\306\014\022\020\n\013SelectGrant\020\307\014\022\033\n\026RefreshPol"
-  "icyInfoCache\020\310\014\022\017\n\nListPolicy\020\311\014\022\030\n\023Crea"
-  "teResourceGroup\020\244\r\022\026\n\021DropResourceGroup\020"
-  "\245\r\022\027\n\022ListResourceGroups\020\246\r\022\032\n\025DescribeR"
-  "esourceGroup\020\247\r\022\021\n\014TransferNode\020\250\r\022\024\n\017Tr"
-  "ansferReplica\020\251\r\022\023\n\016CreateDatabase\020\211\016\022\021\n"
-  "\014DropDatabase\020\212\016\022\022\n\rListDatabases\020\213\016*\"\n\007"
-  "DslType\022\007\n\003Dsl\020\000\022\016\n\nBoolExprV1\020\001*B\n\017Comp"
-  "actionState\022\021\n\rUndefiedState\020\000\022\r\n\tExecut"
-  "ing\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\nEventually\020\003\022\016\n\nCustomized\020\004*\236\001\n\013Impor"
-  "tState\022\021\n\rImportPending\020\000\022\020\n\014ImportFaile"
-  "d\020\001\022\021\n\rImportStarted\020\002\022\023\n\017ImportPersiste"
-  "d\020\005\022\021\n\rImportFlushed\020\010\022\023\n\017ImportComplete"
-  "d\020\006\022\032\n\026ImportFailedAndCleaned\020\007*2\n\nObjec"
-  "tType\022\016\n\nCollection\020\000\022\n\n\006Global\020\001\022\010\n\004Use"
-  "r\020\002*\241\010\n\017ObjectPrivilege\022\020\n\014PrivilegeAll\020"
-  "\000\022\035\n\031PrivilegeCreateCollection\020\001\022\033\n\027Priv"
-  "ilegeDropCollection\020\002\022\037\n\033PrivilegeDescri"
-  "beCollection\020\003\022\034\n\030PrivilegeShowCollectio"
-  "ns\020\004\022\021\n\rPrivilegeLoad\020\005\022\024\n\020PrivilegeRele"
-  "ase\020\006\022\027\n\023PrivilegeCompaction\020\007\022\023\n\017Privil"
-  "egeInsert\020\010\022\023\n\017PrivilegeDelete\020\t\022\032\n\026Priv"
-  "ilegeGetStatistics\020\n\022\030\n\024PrivilegeCreateI"
-  "ndex\020\013\022\030\n\024PrivilegeIndexDetail\020\014\022\026\n\022Priv"
-  "ilegeDropIndex\020\r\022\023\n\017PrivilegeSearch\020\016\022\022\n"
-  "\016PrivilegeFlush\020\017\022\022\n\016PrivilegeQuery\020\020\022\030\n"
-  "\024PrivilegeLoadBalance\020\021\022\023\n\017PrivilegeImpo"
-  "rt\020\022\022\034\n\030PrivilegeCreateOwnership\020\023\022\027\n\023Pr"
-  "ivilegeUpdateUser\020\024\022\032\n\026PrivilegeDropOwne"
-  "rship\020\025\022\034\n\030PrivilegeSelectOwnership\020\026\022\034\n"
-  "\030PrivilegeManageOwnership\020\027\022\027\n\023Privilege"
-  "SelectUser\020\030\022\023\n\017PrivilegeUpsert\020\031\022 \n\034Pri"
-  "vilegeCreateResourceGroup\020\032\022\036\n\032Privilege"
-  "DropResourceGroup\020\033\022\"\n\036PrivilegeDescribe"
-  "ResourceGroup\020\034\022\037\n\033PrivilegeListResource"
-  "Groups\020\035\022\031\n\025PrivilegeTransferNode\020\036\022\034\n\030P"
-  "rivilegeTransferReplica\020\037\022\037\n\033PrivilegeGe"
-  "tLoadingProgress\020 \022\031\n\025PrivilegeGetLoadSt"
-  "ate\020!\022\035\n\031PrivilegeRenameCollection\020\"\022\033\n\027"
-  "PrivilegeCreateDatabase\020#\022\031\n\025PrivilegeDr"
-  "opDatabase\020$\022\032\n\026PrivilegeListDatabases\020%"
-  "\022\025\n\021PrivilegeFlushAll\020&*S\n\tStateCode\022\020\n\014"
-  "Initializing\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\tLoadStat"
-  "e\022\025\n\021LoadStateNotExist\020\000\022\024\n\020LoadStateNot"
-  "Load\020\001\022\024\n\020LoadStateLoading\020\002\022\023\n\017LoadStat"
-  "eLoaded\020\003:^\n\021privilege_ext_obj\022\037.google."
-  "protobuf.MessageOptions\030\351\007 \001(\0132!.milvus."
-  "proto.common.PrivilegeExtBm\n\016io.milvus.g"
-  "rpcB\013CommonProtoP\001Z4github.com/milvus-io"
-  "/milvus-proto/go-api/v2/commonpb\240\001\001\252\002\022Mi"
-  "lvus.Client.Grpcb\006proto3"
+  "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\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, 7104, 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, 16,
+    &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,
@@ -2698,6 +2726,20 @@ void Address::InternalSwap(Address* other) {
 
 // ===================================================================
 
+MsgBase_PropertiesEntry_DoNotUse::MsgBase_PropertiesEntry_DoNotUse() {}
+MsgBase_PropertiesEntry_DoNotUse::MsgBase_PropertiesEntry_DoNotUse(::PROTOBUF_NAMESPACE_ID::Arena* arena)
+    : SuperType(arena) {}
+void MsgBase_PropertiesEntry_DoNotUse::MergeFrom(const MsgBase_PropertiesEntry_DoNotUse& other) {
+  MergeFromInternal(other);
+}
+::PROTOBUF_NAMESPACE_ID::Metadata MsgBase_PropertiesEntry_DoNotUse::GetMetadata() const {
+  return ::_pbi::AssignDescriptors(
+      &descriptor_table_common_2eproto_getter, &descriptor_table_common_2eproto_once,
+      file_level_metadata_common_2eproto[7]);
+}
+
+// ===================================================================
+
 class MsgBase::_Internal {
  public:
 };
@@ -2706,13 +2748,17 @@ MsgBase::MsgBase(::PROTOBUF_NAMESPACE_ID::Arena* arena,
                          bool is_message_owned)
   : ::PROTOBUF_NAMESPACE_ID::Message(arena, is_message_owned) {
   SharedCtor(arena, is_message_owned);
+  if (arena != nullptr && !is_message_owned) {
+    arena->OwnCustomDestructor(this, &MsgBase::ArenaDtor);
+  }
   // @@protoc_insertion_point(arena_constructor:milvus.proto.common.MsgBase)
 }
 MsgBase::MsgBase(const MsgBase& from)
   : ::PROTOBUF_NAMESPACE_ID::Message() {
   MsgBase* const _this = this; (void)_this;
   new (&_impl_) Impl_{
-      decltype(_impl_.msgid_){}
+      /*decltype(_impl_.properties_)*/{}
+    , decltype(_impl_.msgid_){}
     , decltype(_impl_.timestamp_){}
     , decltype(_impl_.sourceid_){}
     , decltype(_impl_.targetid_){}
@@ -2720,6 +2766,7 @@ MsgBase::MsgBase(const MsgBase& from)
     , /*decltype(_impl_._cached_size_)*/{}};
 
   _internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_);
+  _this->_impl_.properties_.MergeFrom(from._impl_.properties_);
   ::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_));
@@ -2731,7 +2778,8 @@ inline void MsgBase::SharedCtor(
   (void)arena;
   (void)is_message_owned;
   new (&_impl_) Impl_{
-      decltype(_impl_.msgid_){int64_t{0}}
+      /*decltype(_impl_.properties_)*/{::_pbi::ArenaInitialized(), arena}
+    , decltype(_impl_.msgid_){int64_t{0}}
     , decltype(_impl_.timestamp_){uint64_t{0u}}
     , decltype(_impl_.sourceid_){int64_t{0}}
     , decltype(_impl_.targetid_){int64_t{0}}
@@ -2744,6 +2792,7 @@ MsgBase::~MsgBase() {
   // @@protoc_insertion_point(destructor:milvus.proto.common.MsgBase)
   if (auto *arena = _internal_metadata_.DeleteReturnArena<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>()) {
   (void)arena;
+    ArenaDtor(this);
     return;
   }
   SharedDtor();
@@ -2751,8 +2800,14 @@ MsgBase::~MsgBase() {
 
 inline void MsgBase::SharedDtor() {
   GOOGLE_DCHECK(GetArenaForAllocation() == nullptr);
+  _impl_.properties_.Destruct();
+  _impl_.properties_.~MapField();
 }
 
+void MsgBase::ArenaDtor(void* object) {
+  MsgBase* _this = reinterpret_cast< MsgBase* >(object);
+  _this->_impl_.properties_.Destruct();
+}
 void MsgBase::SetCachedSize(int size) const {
   _impl_._cached_size_.Set(size);
 }
@@ -2763,6 +2818,7 @@ void MsgBase::Clear() {
   // Prevent compiler warnings about cached_has_bits being unused
   (void) cached_has_bits;
 
+  _impl_.properties_.Clear();
   ::memset(&_impl_.msgid_, 0, static_cast<size_t>(
       reinterpret_cast<char*>(&_impl_.msg_type_) -
       reinterpret_cast<char*>(&_impl_.msgid_)) + sizeof(_impl_.msg_type_));
@@ -2816,6 +2872,19 @@ const char* MsgBase::_InternalParse(const char* ptr, ::_pbi::ParseContext* ctx)
         } else
           goto handle_unusual;
         continue;
+      // map<string, string> properties = 6;
+      case 6:
+        if (PROTOBUF_PREDICT_TRUE(static_cast<uint8_t>(tag) == 50)) {
+          ptr -= 1;
+          do {
+            ptr += 1;
+            ptr = ctx->ParseMessage(&_impl_.properties_, ptr);
+            CHK_(ptr);
+            if (!ctx->DataAvailable(ptr)) break;
+          } while (::PROTOBUF_NAMESPACE_ID::internal::ExpectTag<50>(ptr));
+        } else
+          goto handle_unusual;
+        continue;
       default:
         goto handle_unusual;
     }  // switch
@@ -2876,6 +2945,36 @@ uint8_t* MsgBase::_InternalSerialize(
     target = ::_pbi::WireFormatLite::WriteInt64ToArray(5, this->_internal_targetid(), target);
   }
 
+  // map<string, string> properties = 6;
+  if (!this->_internal_properties().empty()) {
+    using MapType = ::_pb::Map<std::string, std::string>;
+    using WireHelper = MsgBase_PropertiesEntry_DoNotUse::Funcs;
+    const auto& map_field = this->_internal_properties();
+    auto check_utf8 = [](const MapType::value_type& entry) {
+      (void)entry;
+      ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
+        entry.first.data(), static_cast<int>(entry.first.length()),
+        ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
+        "milvus.proto.common.MsgBase.PropertiesEntry.key");
+      ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
+        entry.second.data(), static_cast<int>(entry.second.length()),
+        ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
+        "milvus.proto.common.MsgBase.PropertiesEntry.value");
+    };
+
+    if (stream->IsSerializationDeterministic() && map_field.size() > 1) {
+      for (const auto& entry : ::_pbi::MapSorterPtr<MapType>(map_field)) {
+        target = WireHelper::InternalSerialize(6, entry.first, entry.second, target, stream);
+        check_utf8(entry);
+      }
+    } else {
+      for (const auto& entry : map_field) {
+        target = WireHelper::InternalSerialize(6, entry.first, entry.second, target, stream);
+        check_utf8(entry);
+      }
+    }
+  }
+
   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);
@@ -2892,6 +2991,15 @@ size_t MsgBase::ByteSizeLong() const {
   // Prevent compiler warnings about cached_has_bits being unused
   (void) cached_has_bits;
 
+  // map<string, string> properties = 6;
+  total_size += 1 *
+      ::PROTOBUF_NAMESPACE_ID::internal::FromIntSize(this->_internal_properties_size());
+  for (::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >::const_iterator
+      it = this->_internal_properties().begin();
+      it != this->_internal_properties().end(); ++it) {
+    total_size += MsgBase_PropertiesEntry_DoNotUse::Funcs::ByteSizeLong(it->first, it->second);
+  }
+
   // int64 msgID = 2;
   if (this->_internal_msgid() != 0) {
     total_size += ::_pbi::WireFormatLite::Int64SizePlusOne(this->_internal_msgid());
@@ -2936,6 +3044,7 @@ void MsgBase::MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const ::PROTOB
   uint32_t cached_has_bits = 0;
   (void) cached_has_bits;
 
+  _this->_impl_.properties_.MergeFrom(from._impl_.properties_);
   if (from._internal_msgid() != 0) {
     _this->_internal_set_msgid(from._internal_msgid());
   }
@@ -2968,6 +3077,7 @@ bool MsgBase::IsInitialized() const {
 void MsgBase::InternalSwap(MsgBase* other) {
   using std::swap;
   _internal_metadata_.InternalSwap(&other->_internal_metadata_);
+  _impl_.properties_.InternalSwap(&other->_impl_.properties_);
   ::PROTOBUF_NAMESPACE_ID::internal::memswap<
       PROTOBUF_FIELD_OFFSET(MsgBase, _impl_.msg_type_)
       + sizeof(MsgBase::_impl_.msg_type_)
@@ -2979,7 +3089,7 @@ void MsgBase::InternalSwap(MsgBase* other) {
 ::PROTOBUF_NAMESPACE_ID::Metadata MsgBase::GetMetadata() const {
   return ::_pbi::AssignDescriptors(
       &descriptor_table_common_2eproto_getter, &descriptor_table_common_2eproto_once,
-      file_level_metadata_common_2eproto[7]);
+      file_level_metadata_common_2eproto[8]);
 }
 
 // ===================================================================
@@ -3172,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[8]);
+      file_level_metadata_common_2eproto[9]);
 }
 
 // ===================================================================
@@ -3417,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[9]);
+      file_level_metadata_common_2eproto[10]);
 }
 
 // ===================================================================
@@ -3682,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[10]);
+      file_level_metadata_common_2eproto[11]);
 }
 
 // ===================================================================
@@ -3893,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[11]);
+      file_level_metadata_common_2eproto[12]);
 }
 
 // ===================================================================
@@ -3907,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[12]);
+      file_level_metadata_common_2eproto[13]);
 }
 
 // ===================================================================
@@ -4378,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[13]);
+      file_level_metadata_common_2eproto[14]);
 }
 
 // ===================================================================
@@ -4392,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[14]);
+      file_level_metadata_common_2eproto[15]);
 }
 
 // ===================================================================
@@ -4863,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[15]);
+      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>
@@ -4902,6 +5012,10 @@ template<> PROTOBUF_NOINLINE ::milvus::proto::common::Address*
 Arena::CreateMaybeMessage< ::milvus::proto::common::Address >(Arena* arena) {
   return Arena::CreateMessageInternal< ::milvus::proto::common::Address >(arena);
 }
+template<> PROTOBUF_NOINLINE ::milvus::proto::common::MsgBase_PropertiesEntry_DoNotUse*
+Arena::CreateMaybeMessage< ::milvus::proto::common::MsgBase_PropertiesEntry_DoNotUse >(Arena* arena) {
+  return Arena::CreateMessageInternal< ::milvus::proto::common::MsgBase_PropertiesEntry_DoNotUse >(arena);
+}
 template<> PROTOBUF_NOINLINE ::milvus::proto::common::MsgBase*
 Arena::CreateMaybeMessage< ::milvus::proto::common::MsgBase >(Arena* arena) {
   return Arena::CreateMessageInternal< ::milvus::proto::common::MsgBase >(arena);
diff --git a/internal/core/src/pb/common.pb.h b/internal/core/src/pb/common.pb.h
index 4e164b872f..21bb97cd79 100644
--- a/internal/core/src/pb/common.pb.h
+++ b/internal/core/src/pb/common.pb.h
@@ -76,6 +76,9 @@ extern KeyValuePairDefaultTypeInternal _KeyValuePair_default_instance_;
 class MsgBase;
 struct MsgBaseDefaultTypeInternal;
 extern MsgBaseDefaultTypeInternal _MsgBase_default_instance_;
+class MsgBase_PropertiesEntry_DoNotUse;
+struct MsgBase_PropertiesEntry_DoNotUseDefaultTypeInternal;
+extern MsgBase_PropertiesEntry_DoNotUseDefaultTypeInternal _MsgBase_PropertiesEntry_DoNotUse_default_instance_;
 class MsgHeader;
 struct MsgHeaderDefaultTypeInternal;
 extern MsgHeaderDefaultTypeInternal _MsgHeader_default_instance_;
@@ -112,6 +115,7 @@ template<> ::milvus::proto::common::DMLMsgHeader* Arena::CreateMaybeMessage<::mi
 template<> ::milvus::proto::common::KeyDataPair* Arena::CreateMaybeMessage<::milvus::proto::common::KeyDataPair>(Arena*);
 template<> ::milvus::proto::common::KeyValuePair* Arena::CreateMaybeMessage<::milvus::proto::common::KeyValuePair>(Arena*);
 template<> ::milvus::proto::common::MsgBase* Arena::CreateMaybeMessage<::milvus::proto::common::MsgBase>(Arena*);
+template<> ::milvus::proto::common::MsgBase_PropertiesEntry_DoNotUse* Arena::CreateMaybeMessage<::milvus::proto::common::MsgBase_PropertiesEntry_DoNotUse>(Arena*);
 template<> ::milvus::proto::common::MsgHeader* Arena::CreateMaybeMessage<::milvus::proto::common::MsgHeader>(Arena*);
 template<> ::milvus::proto::common::PlaceholderGroup* Arena::CreateMaybeMessage<::milvus::proto::common::PlaceholderGroup>(Arena*);
 template<> ::milvus::proto::common::PlaceholderValue* Arena::CreateMaybeMessage<::milvus::proto::common::PlaceholderValue>(Arena*);
@@ -1850,6 +1854,34 @@ class Address final :
 };
 // -------------------------------------------------------------------
 
+class MsgBase_PropertiesEntry_DoNotUse : public ::PROTOBUF_NAMESPACE_ID::internal::MapEntry<MsgBase_PropertiesEntry_DoNotUse, 
+    std::string, std::string,
+    ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_STRING,
+    ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_STRING> {
+public:
+  typedef ::PROTOBUF_NAMESPACE_ID::internal::MapEntry<MsgBase_PropertiesEntry_DoNotUse, 
+    std::string, std::string,
+    ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_STRING,
+    ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_STRING> SuperType;
+  MsgBase_PropertiesEntry_DoNotUse();
+  explicit PROTOBUF_CONSTEXPR MsgBase_PropertiesEntry_DoNotUse(
+      ::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized);
+  explicit MsgBase_PropertiesEntry_DoNotUse(::PROTOBUF_NAMESPACE_ID::Arena* arena);
+  void MergeFrom(const MsgBase_PropertiesEntry_DoNotUse& other);
+  static const MsgBase_PropertiesEntry_DoNotUse* internal_default_instance() { return reinterpret_cast<const MsgBase_PropertiesEntry_DoNotUse*>(&_MsgBase_PropertiesEntry_DoNotUse_default_instance_); }
+  static bool ValidateKey(std::string* s) {
+    return ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(s->data(), static_cast<int>(s->size()), ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::PARSE, "milvus.proto.common.MsgBase.PropertiesEntry.key");
+ }
+  static bool ValidateValue(std::string* s) {
+    return ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(s->data(), static_cast<int>(s->size()), ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::PARSE, "milvus.proto.common.MsgBase.PropertiesEntry.value");
+ }
+  using ::PROTOBUF_NAMESPACE_ID::Message::MergeFrom;
+  ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final;
+  friend struct ::TableStruct_common_2eproto;
+};
+
+// -------------------------------------------------------------------
+
 class MsgBase final :
     public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:milvus.proto.common.MsgBase) */ {
  public:
@@ -1898,7 +1930,7 @@ class MsgBase final :
                &_MsgBase_default_instance_);
   }
   static constexpr int kIndexInFileMessages =
-    7;
+    8;
 
   friend void swap(MsgBase& a, MsgBase& b) {
     a.Swap(&b);
@@ -1959,6 +1991,8 @@ class MsgBase final :
   protected:
   explicit MsgBase(::PROTOBUF_NAMESPACE_ID::Arena* arena,
                        bool is_message_owned = false);
+  private:
+  static void ArenaDtor(void* object);
   public:
 
   static const ClassData _class_data_;
@@ -1968,15 +2002,34 @@ class MsgBase final :
 
   // nested types ----------------------------------------------------
 
+
   // accessors -------------------------------------------------------
 
   enum : int {
+    kPropertiesFieldNumber = 6,
     kMsgIDFieldNumber = 2,
     kTimestampFieldNumber = 3,
     kSourceIDFieldNumber = 4,
     kTargetIDFieldNumber = 5,
     kMsgTypeFieldNumber = 1,
   };
+  // map<string, string> properties = 6;
+  int properties_size() const;
+  private:
+  int _internal_properties_size() const;
+  public:
+  void clear_properties();
+  private:
+  const ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >&
+      _internal_properties() const;
+  ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >*
+      _internal_mutable_properties();
+  public:
+  const ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >&
+      properties() const;
+  ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >*
+      mutable_properties();
+
   // int64 msgID = 2;
   void clear_msgid();
   int64_t msgid() const;
@@ -2030,6 +2083,11 @@ class MsgBase final :
   typedef void InternalArenaConstructable_;
   typedef void DestructorSkippable_;
   struct Impl_ {
+    ::PROTOBUF_NAMESPACE_ID::internal::MapField<
+        MsgBase_PropertiesEntry_DoNotUse,
+        std::string, std::string,
+        ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_STRING,
+        ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_STRING> properties_;
     int64_t msgid_;
     uint64_t timestamp_;
     int64_t sourceid_;
@@ -2090,7 +2148,7 @@ class MsgHeader final :
                &_MsgHeader_default_instance_);
   }
   static constexpr int kIndexInFileMessages =
-    8;
+    9;
 
   friend void swap(MsgHeader& a, MsgHeader& b) {
     a.Swap(&b);
@@ -2247,7 +2305,7 @@ class DMLMsgHeader final :
                &_DMLMsgHeader_default_instance_);
   }
   static constexpr int kIndexInFileMessages =
-    9;
+    10;
 
   friend void swap(DMLMsgHeader& a, DMLMsgHeader& b) {
     a.Swap(&b);
@@ -2420,7 +2478,7 @@ class PrivilegeExt final :
                &_PrivilegeExt_default_instance_);
   }
   static constexpr int kIndexInFileMessages =
-    10;
+    11;
 
   friend void swap(PrivilegeExt& a, PrivilegeExt& b) {
     a.Swap(&b);
@@ -2601,7 +2659,7 @@ class SegmentStats final :
                &_SegmentStats_default_instance_);
   }
   static constexpr int kIndexInFileMessages =
-    11;
+    12;
 
   friend void swap(SegmentStats& a, SegmentStats& b) {
     a.Swap(&b);
@@ -2788,7 +2846,7 @@ class ClientInfo final :
                &_ClientInfo_default_instance_);
   }
   static constexpr int kIndexInFileMessages =
-    13;
+    14;
 
   friend void swap(ClientInfo& a, ClientInfo& b) {
     a.Swap(&b);
@@ -3059,7 +3117,7 @@ class ServerInfo final :
                &_ServerInfo_default_instance_);
   }
   static constexpr int kIndexInFileMessages =
-    15;
+    16;
 
   friend void swap(ServerInfo& a, ServerInfo& b) {
     a.Swap(&b);
@@ -3888,6 +3946,8 @@ inline void Address::set_port(int64_t value) {
 
 // -------------------------------------------------------------------
 
+// -------------------------------------------------------------------
+
 // MsgBase
 
 // .milvus.proto.common.MsgType msg_type = 1;
@@ -3990,6 +4050,35 @@ inline void MsgBase::set_targetid(int64_t value) {
   // @@protoc_insertion_point(field_set:milvus.proto.common.MsgBase.targetID)
 }
 
+// map<string, string> properties = 6;
+inline int MsgBase::_internal_properties_size() const {
+  return _impl_.properties_.size();
+}
+inline int MsgBase::properties_size() const {
+  return _internal_properties_size();
+}
+inline void MsgBase::clear_properties() {
+  _impl_.properties_.Clear();
+}
+inline const ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >&
+MsgBase::_internal_properties() const {
+  return _impl_.properties_.GetMap();
+}
+inline const ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >&
+MsgBase::properties() const {
+  // @@protoc_insertion_point(field_map:milvus.proto.common.MsgBase.properties)
+  return _internal_properties();
+}
+inline ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >*
+MsgBase::_internal_mutable_properties() {
+  return _impl_.properties_.MutableMap();
+}
+inline ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >*
+MsgBase::mutable_properties() {
+  // @@protoc_insertion_point(field_mutable_map:milvus.proto.common.MsgBase.properties)
+  return _internal_mutable_properties();
+}
+
 // -------------------------------------------------------------------
 
 // MsgHeader
@@ -4959,6 +5048,8 @@ ServerInfo::mutable_reserved() {
 
 // -------------------------------------------------------------------
 
+// -------------------------------------------------------------------
+
 
 // @@protoc_insertion_point(namespace_scope)
 
diff --git a/internal/datacoord/server_test.go b/internal/datacoord/server_test.go
index b3a0166660..e6a3e66ea9 100644
--- a/internal/datacoord/server_test.go
+++ b/internal/datacoord/server_test.go
@@ -37,6 +37,8 @@ import (
 	clientv3 "go.etcd.io/etcd/client/v3"
 	"go.uber.org/zap"
 	"google.golang.org/grpc"
+	"google.golang.org/grpc/codes"
+	grpcStatus "google.golang.org/grpc/status"
 
 	"github.com/milvus-io/milvus-proto/go-api/v2/commonpb"
 	"github.com/milvus-io/milvus-proto/go-api/v2/milvuspb"
@@ -328,6 +330,40 @@ func TestFlush(t *testing.T) {
 		assert.NoError(t, err)
 		assert.ErrorIs(t, merr.Error(resp.GetStatus()), merr.ErrServiceNotReady)
 	})
+
+	t.Run("test rolling upgrade", func(t *testing.T) {
+		svr := newTestServer(t, nil)
+		closeTestServer(t, svr)
+		svr.stateCode.Store(commonpb.StateCode_Healthy)
+		sm := NewSessionManager()
+
+		datanodeClient := mocks.NewMockDataNodeClient(t)
+		datanodeClient.EXPECT().FlushChannels(mock.Anything, mock.Anything).Return(nil,
+			grpcStatus.Error(codes.Unimplemented, "mock grpc unimplemented error"))
+
+		sm.sessions = struct {
+			sync.RWMutex
+			data map[int64]*Session
+		}{data: map[int64]*Session{1: {
+			client: datanodeClient,
+			clientCreator: func(ctx context.Context, addr string, nodeID int64) (types.DataNodeClient, error) {
+				return datanodeClient, nil
+			},
+		}}}
+
+		svr.sessionManager = sm
+		svr.cluster.sessionManager = sm
+
+		err := svr.channelManager.AddNode(1)
+		assert.NoError(t, err)
+		err = svr.channelManager.Watch(&channel{Name: "ch1", CollectionID: 0})
+		assert.NoError(t, err)
+
+		resp, err := svr.Flush(context.TODO(), req)
+		assert.NoError(t, err)
+		assert.EqualValues(t, commonpb.ErrorCode_Success, resp.GetStatus().GetErrorCode())
+		assert.Equal(t, Timestamp(0), resp.GetFlushTs())
+	})
 }
 
 // func TestGetComponentStates(t *testing.T) {
diff --git a/internal/datacoord/services.go b/internal/datacoord/services.go
index 7631151cba..7b5fbafbec 100644
--- a/internal/datacoord/services.go
+++ b/internal/datacoord/services.go
@@ -28,6 +28,7 @@ import (
 	"go.opentelemetry.io/otel"
 	"go.uber.org/zap"
 	"golang.org/x/sync/errgroup"
+	"google.golang.org/grpc/codes"
 
 	"github.com/milvus-io/milvus-proto/go-api/v2/commonpb"
 	"github.com/milvus-io/milvus-proto/go-api/v2/milvuspb"
@@ -39,6 +40,7 @@ import (
 	"github.com/milvus-io/milvus/pkg/log"
 	"github.com/milvus-io/milvus/pkg/metrics"
 	"github.com/milvus-io/milvus/pkg/util/commonpbutil"
+	"github.com/milvus-io/milvus/pkg/util/funcutil"
 	"github.com/milvus-io/milvus/pkg/util/merr"
 	"github.com/milvus-io/milvus/pkg/util/metricsinfo"
 	"github.com/milvus-io/milvus/pkg/util/paramtable"
@@ -66,11 +68,11 @@ func (s *Server) GetStatisticsChannel(ctx context.Context, req *internalpb.GetSt
 // this api only guarantees all the segments requested is sealed
 // these segments will be flushed only after the Flush policy is fulfilled
 func (s *Server) Flush(ctx context.Context, req *datapb.FlushRequest) (*datapb.FlushResponse, error) {
-	log := log.Ctx(ctx)
-	log.Info("receive flush request",
+	log := log.Ctx(ctx).With(
 		zap.Int64("dbID", req.GetDbID()),
 		zap.Int64("collectionID", req.GetCollectionID()),
 		zap.Bool("isImporting", req.GetIsImport()))
+	log.Info("receive flush request")
 	ctx, sp := otel.Tracer(typeutil.DataCoordRole).Start(ctx, "DataCoord-Flush")
 	defer sp.End()
 
@@ -113,6 +115,7 @@ func (s *Server) Flush(ctx context.Context, req *datapb.FlushRequest) (*datapb.F
 		}
 	}
 
+	var isUnimplemented bool
 	err = retry.Do(ctx, func() error {
 		for _, channelInfo := range s.channelManager.GetChannels() {
 			nodeID := channelInfo.NodeID
@@ -123,6 +126,10 @@ func (s *Server) Flush(ctx context.Context, req *datapb.FlushRequest) (*datapb.F
 				return channel.Name
 			})
 			err = s.cluster.FlushChannels(ctx, nodeID, ts, channelNames)
+			if err != nil && funcutil.IsGrpcErr(err, codes.Unimplemented) {
+				isUnimplemented = true
+				return nil
+			}
 			if err != nil {
 				return err
 			}
@@ -135,6 +142,13 @@ func (s *Server) Flush(ctx context.Context, req *datapb.FlushRequest) (*datapb.F
 		}, nil
 	}
 
+	if isUnimplemented {
+		// For compatible with rolling upgrade from version 2.2.x,
+		// fall back to the flush logic of version 2.2.x;
+		log.Warn("DataNode FlushChannels unimplemented", zap.Error(err))
+		ts = 0
+	}
+
 	log.Info("flush response with segments",
 		zap.Int64("collectionID", req.GetCollectionID()),
 		zap.Int64s("sealSegments", sealedSegmentIDs),