Skip to content

Commit a928ac8

Browse files
lmatzhzxa21
andauthored
fix: remove decoding message size limit in telemetry and connector gr… (#11779)
Co-authored-by: Zhanxiang (Patrick) Huang <[email protected]>
1 parent 0c592db commit a928ac8

File tree

2 files changed

+3
-2
lines changed

2 files changed

+3
-2
lines changed

src/rpc_client/src/connector_client.rs

+1-1
Original file line numberDiff line numberDiff line change
@@ -179,7 +179,7 @@ impl ConnectorClient {
179179
}
180180
};
181181
Ok(Self {
182-
rpc_client: ConnectorServiceClient::new(channel),
182+
rpc_client: ConnectorServiceClient::new(channel).max_decoding_message_size(usize::MAX),
183183
endpoint: connector_endpoint.to_string(),
184184
})
185185
}

src/rpc_client/src/meta_client.rs

+2-1
Original file line numberDiff line numberDiff line change
@@ -1251,7 +1251,8 @@ impl GrpcMetaClientCore {
12511251
let scale_client =
12521252
ScaleServiceClient::new(channel.clone()).max_decoding_message_size(usize::MAX);
12531253
let backup_client = BackupServiceClient::new(channel.clone());
1254-
let telemetry_client = TelemetryInfoServiceClient::new(channel.clone());
1254+
let telemetry_client =
1255+
TelemetryInfoServiceClient::new(channel.clone()).max_decoding_message_size(usize::MAX);
12551256
let system_params_client = SystemParamsServiceClient::new(channel.clone());
12561257
let serving_client = ServingServiceClient::new(channel.clone());
12571258
let cloud_client = CloudServiceClient::new(channel);

0 commit comments

Comments
 (0)