From c3cce20413f7ea24cec9685d04f8f354abf37097 Mon Sep 17 00:00:00 2001
From: "cai.zhang" <cai.zhang@zilliz.com>
Date: Mon, 25 Oct 2021 17:57:14 +0800
Subject: [PATCH] Reset the msgstream threshold to PulsarMaxMessageSize
 (#10186)

Signed-off-by: cai.zhang <cai.zhang@zilliz.com>
---
 internal/proxy/task.go | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

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 */