Skip to content

Commit 0874a48

Browse files
authored
fix: remove decoding message size limit in telemetry and connector grpc client (#11758)
1 parent cf56e72 commit 0874a48

File tree

2 files changed

+3
-2
lines changed

2 files changed

+3
-2
lines changed

src/rpc_client/src/connector_client.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -158,7 +158,7 @@ impl ConnectorClient {
158158
}
159159
};
160160
Ok(Self {
161-
rpc_client: ConnectorServiceClient::new(channel),
161+
rpc_client: ConnectorServiceClient::new(channel).max_decoding_message_size(usize::MAX),
162162
endpoint: connector_endpoint.to_string(),
163163
})
164164
}

src/rpc_client/src/meta_client.rs

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1268,7 +1268,8 @@ impl GrpcMetaClientCore {
12681268
let scale_client =
12691269
ScaleServiceClient::new(channel.clone()).max_decoding_message_size(usize::MAX);
12701270
let backup_client = BackupServiceClient::new(channel.clone());
1271-
let telemetry_client = TelemetryInfoServiceClient::new(channel.clone());
1271+
let telemetry_client =
1272+
TelemetryInfoServiceClient::new(channel.clone()).max_decoding_message_size(usize::MAX);
12721273
let system_params_client = SystemParamsServiceClient::new(channel.clone());
12731274
let serving_client = ServingServiceClient::new(channel.clone());
12741275
let cloud_client = CloudServiceClient::new(channel.clone());

0 commit comments

Comments
 (0)