diff --git a/internal/msgstream/msg.go b/internal/msgstream/msg.go
index 9e3203b429..849a9e942a 100644
--- a/internal/msgstream/msg.go
+++ b/internal/msgstream/msg.go
@@ -804,6 +804,7 @@ func (dp *DropPartitionMsg) Unmarshal(input MarshalType) (TsMsg, error) {
 
 /////////////////////////////////////////LoadIndex//////////////////////////////////////////
 // TODO(wxyu): comment it until really needed
+/*
 type LoadIndexMsg struct {
 	BaseMsg
 	internalpb.LoadIndex
@@ -853,6 +854,7 @@ func (lim *LoadIndexMsg) Unmarshal(input MarshalType) (TsMsg, error) {
 
 	return loadIndexMsg, nil
 }
+*/
 
 /////////////////////////////////////////LoadBalanceSegments//////////////////////////////////////////
 type LoadBalanceSegmentsMsg struct {
diff --git a/internal/msgstream/unmarshal.go b/internal/msgstream/unmarshal.go
index 63db71a846..16bec0b118 100644
--- a/internal/msgstream/unmarshal.go
+++ b/internal/msgstream/unmarshal.go
@@ -60,7 +60,6 @@ func (pudf *ProtoUDFactory) NewUnmarshalDispatcher() *ProtoUnmarshalDispatcher {
 	dropCollectionMsg := DropCollectionMsg{}
 	createPartitionMsg := CreatePartitionMsg{}
 	dropPartitionMsg := DropPartitionMsg{}
-	loadIndexMsg := LoadIndexMsg{}
 	queryNodeSegStatsMsg := QueryNodeStatsMsg{}
 	segmentStatisticsMsg := SegmentStatisticsMsg{}
 	loadBalanceSegmentsMsg := LoadBalanceSegmentsMsg{}
@@ -80,7 +79,6 @@ func (pudf *ProtoUDFactory) NewUnmarshalDispatcher() *ProtoUnmarshalDispatcher {
 	p.TempMap[commonpb.MsgType_DropCollection] = dropCollectionMsg.Unmarshal
 	p.TempMap[commonpb.MsgType_CreatePartition] = createPartitionMsg.Unmarshal
 	p.TempMap[commonpb.MsgType_DropPartition] = dropPartitionMsg.Unmarshal
-	p.TempMap[commonpb.MsgType_LoadIndex] = loadIndexMsg.Unmarshal
 	p.TempMap[commonpb.MsgType_SegmentStatistics] = segmentStatisticsMsg.Unmarshal
 	p.TempMap[commonpb.MsgType_LoadBalanceSegments] = loadBalanceSegmentsMsg.Unmarshal
 	p.TempMap[commonpb.MsgType_DataNodeTt] = dataNodeTtMsg.Unmarshal