Skip to content
Permalink

Comparing changes

This is a direct comparison between two commits made in this repository or its related repositories. View the default comparison for this range or learn more about diff comparisons.

Open a pull request

Create a new pull request by comparing changes across two branches. If you need to, you can also . Learn more about diff comparisons here.
base repository: databendlabs/databend
Failed to load repositories. Confirm that selected base ref is valid, then try again.
Loading
base: eafd5096a3c43ad55d8a2f769d5f44916511472e
Choose a base ref
..
head repository: databendlabs/databend
Failed to load repositories. Confirm that selected head ref is valid, then try again.
Loading
compare: 20b311d8d0720f941039e602fea4552a030ccd19
Choose a head ref
Showing with 15 additions and 233 deletions.
  1. +1 −6 src/query/service/src/api/rpc/exchange/exchange_manager.rs
  2. +12 −213 src/query/service/src/api/rpc/flight_client.rs
  3. +2 −14 src/query/service/src/api/rpc/flight_service.rs
7 changes: 1 addition & 6 deletions src/query/service/src/api/rpc/exchange/exchange_manager.rs
Original file line number Diff line number Diff line change
@@ -112,12 +112,7 @@ impl DataExchangeManager {
targets_exchanges.insert(
(connection_info.target.id.clone(), *fragment),
flight_client
.do_exchange(
&packet.query_id,
source,
&connection_info.target.id,
*fragment,
)
.do_exchange(&packet.query_id, source, *fragment)
.await?,
);
}
Loading