fix(meta): remove message size limit for sink coordination service (#23485) (#23534)

Co-authored-by: Li0k <yuli@singularity-data.com>

Author: risingwave-ci

src/meta/node/src/server.rs

@@ -736,7 +736,10 @@ pub async fn start_service_as_election_leader(
         .add_service(SessionParamServiceServer::new(session_params_srv))
         .add_service(TelemetryInfoServiceServer::new(telemetry_srv))
         .add_service(ServingServiceServer::new(serving_srv))
-        .add_service(SinkCoordinationServiceServer::new(sink_coordination_srv))
+        .add_service(
+            SinkCoordinationServiceServer::new(sink_coordination_srv)
+                .max_decoding_message_size(usize::MAX),
+        )
         .add_service(
             EventLogServiceServer::new(event_log_srv).max_decoding_message_size(usize::MAX),
         )

src/rpc_client/src/meta_client.rs

@@ -1977,7 +1977,8 @@ impl GrpcMetaClientCore {
         let session_params_client = SessionParamServiceClient::new(channel.clone());
         let serving_client = ServingServiceClient::new(channel.clone());
         let cloud_client = CloudServiceClient::new(channel.clone());
-        let sink_coordinate_client = SinkCoordinationServiceClient::new(channel.clone());
+        let sink_coordinate_client = SinkCoordinationServiceClient::new(channel.clone())
+            .max_decoding_message_size(usize::MAX);
         let event_log_client = EventLogServiceClient::new(channel.clone());
         let cluster_limit_client = ClusterLimitServiceClient::new(channel.clone());
         let hosted_iceberg_catalog_service_client =