diff --git a/internal/datanode/flow_graph_insert_buffer_node.go b/internal/datanode/flow_graph_insert_buffer_node.go
index a5e92169d8..ce64996ca2 100644
--- a/internal/datanode/flow_graph_insert_buffer_node.go
+++ b/internal/datanode/flow_graph_insert_buffer_node.go
@@ -793,6 +793,7 @@ func (ibNode *insertBufferNode) getCollMetabySegID(segmentID UniqueID) (meta *et
 	if err != nil {
 		return
 	}
+	meta = &etcdpb.CollectionMeta{}
 	meta.ID = ret.collectionID
 
 	coll, err := ibNode.replica.getCollectionByID(ret.collectionID)