debug

databendlabs · Sep 5, 2024 · a695a7d · a695a7d
1 parent 2a9a7c5
commit a695a7d
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/query/service/src/servers/flight/v1/exchange/exchange_manager.rs b/src/query/service/src/servers/flight/v1/exchange/exchange_manager.rs
@@ -664,7 +664,7 @@ impl QueryCoordinator {
         target: String,
         begin: usize,
     ) -> Result<FlightDataAckStream> {
-        let (tx, rx) = async_channel::bounded(8);
+        let (tx, rx) = async_channel::unbounded();
         let identifier = ExchangeIdentifier::Statistics(target);
 
         match self.exchanges.entry(identifier) {
@@ -706,7 +706,7 @@ impl QueryCoordinator {
         fragment: usize,
         begin: usize,
     ) -> Result<FlightDataAckStream> {
-        let (tx, rx) = async_channel::bounded(8);
+        let (tx, rx) = async_channel::unbounded();
         let identifier = ExchangeIdentifier::fragment_sender(target, fragment);
 
         match self.exchanges.entry(identifier) {