We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent ecbc9af commit 0d7febfCopy full SHA for 0d7febf
src/plan/arrow_flight_read.rs
@@ -203,7 +203,10 @@ impl ExecutionPlan for ArrowFlightReadExec {
203
let channel_manager_capture = channel_manager.clone();
204
let schema = schema.clone();
205
let query_id = query_id.clone();
206
- let flight_metadata = flight_metadata.clone().unwrap_or_default().as_ref().clone();
+ let flight_metadata = flight_metadata
207
+ .as_ref()
208
+ .map(|v| v.as_ref().clone())
209
+ .unwrap_or_default();
210
let key = StageKey {
211
query_id,
212
stage_id: child_stage_num,
0 commit comments