fix: remove decoding message size limit in telemetry and connector gr…

…pc client (#11758)
risingwavelabs · Aug 17, 2023 · 0874a48 · 0874a48
1 parent cf56e72
commit 0874a48
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/src/rpc_client/src/connector_client.rs b/src/rpc_client/src/connector_client.rs
@@ -158,7 +158,7 @@ impl ConnectorClient {
             }
         };
         Ok(Self {
-            rpc_client: ConnectorServiceClient::new(channel),
+            rpc_client: ConnectorServiceClient::new(channel).max_decoding_message_size(usize::MAX),
             endpoint: connector_endpoint.to_string(),
         })
     }

diff --git a/src/rpc_client/src/meta_client.rs b/src/rpc_client/src/meta_client.rs
@@ -1268,7 +1268,8 @@ impl GrpcMetaClientCore {
         let scale_client =
             ScaleServiceClient::new(channel.clone()).max_decoding_message_size(usize::MAX);
         let backup_client = BackupServiceClient::new(channel.clone());
-        let telemetry_client = TelemetryInfoServiceClient::new(channel.clone());
+        let telemetry_client =
+            TelemetryInfoServiceClient::new(channel.clone()).max_decoding_message_size(usize::MAX);
         let system_params_client = SystemParamsServiceClient::new(channel.clone());
         let serving_client = ServingServiceClient::new(channel.clone());
         let cloud_client = CloudServiceClient::new(channel.clone());