Rollback hardcoded client decoded size

gabotechs · gabotechs · commit 0d29d17ef9c9 · 2025-09-21T19:15:10.000+02:00
diff --git a/src/execution_plans/network_coalesce.rs b/src/execution_plans/network_coalesce.rs
@@ -300,7 +300,6 @@ impl ExecutionPlan for NetworkCoalesceExec {
         let stream = async move {
             let channel = channel_resolver.get_channel_for_url(&url).await?;
             let stream = FlightServiceClient::new(channel)
-                .max_decoding_message_size(2 * 1024 * 1024 * 1024)
                 .do_get(ticket)
                 .await
                 .map_err(map_status_to_datafusion_error)?
diff --git a/src/execution_plans/network_shuffle.rs b/src/execution_plans/network_shuffle.rs
@@ -337,7 +337,6 @@ impl ExecutionPlan for NetworkShuffleExec {
 
                 let channel = channel_resolver.get_channel_for_url(&url).await?;
                 let stream = FlightServiceClient::new(channel)
-                    .max_decoding_message_size(2 * 1024 * 1024 * 1024)
                     .do_get(ticket)
                     .await
                     .map_err(map_status_to_datafusion_error)?
