diff --git a/internal/proxy/task.go b/internal/proxy/task.go
index 74214c4ae0..39055e6fe3 100644
--- a/internal/proxy/task.go
+++ b/internal/proxy/task.go
@@ -906,8 +906,7 @@ func (it *insertTask) _assignSegmentID(stream msgstream.MsgStream, pack *msgstre
 		return 0
 	}
 
-	factor := 10
-	threshold := Params.PulsarMaxMessageSize / factor
+	threshold := Params.PulsarMaxMessageSize
 	log.Debug("Proxy", zap.Int("threshold of message size: ", threshold))
 	// not accurate
 	/* #nosec G103 */