From a639ccacbb6e2f209f00d817412351312558f6e1 Mon Sep 17 00:00:00 2001
From: zwang28 <70626450+zwang28@users.noreply.github.com>
Date: Tue, 5 Sep 2023 21:26:31 +0800
Subject: [PATCH] chore(rpc): set message size to max for stream client
 (#12082)

---
 src/rpc_client/src/stream_client.rs | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/src/rpc_client/src/stream_client.rs b/src/rpc_client/src/stream_client.rs
index 531a8669fdeed..09a4c607043eb 100644
--- a/src/rpc_client/src/stream_client.rs
+++ b/src/rpc_client/src/stream_client.rs
@@ -52,7 +52,9 @@ impl StreamClient {
             .await?
             .tracing_injected();
 
-        Ok(Self(StreamServiceClient::new(channel)))
+        Ok(Self(
+            StreamServiceClient::new(channel).max_decoding_message_size(usize::MAX),
+        ))
     }
 }