diff --git a/core/frame/meta_frame.go b/core/frame/meta_frame.go
index 1d54a21b0..712c00976 100644
--- a/core/frame/meta_frame.go
+++ b/core/frame/meta_frame.go
@@ -62,11 +62,19 @@ func (m *MetaFrame) Encode() []byte {
 	transactionID := y3.NewPrimitivePacketEncoder(byte(TagOfTransactionID))
 	transactionID.SetStringValue(m.tid)
 	meta.AddPrimitivePacket(transactionID)
+
 	// source ID
 	sourceID := y3.NewPrimitivePacketEncoder(byte(TagOfSourceID))
 	sourceID.SetStringValue(m.sourceID)
 	meta.AddPrimitivePacket(sourceID)
 
+	// metadata
+	if m.metadata != nil {
+		metadata := y3.NewPrimitivePacketEncoder(byte(TagOfMetadata))
+		metadata.SetBytesValue(m.metadata)
+		meta.AddPrimitivePacket(metadata)
+	}
+
 	return meta.Encode()
 }