diff --git a/ballista/scheduler/src/flight_sql.rs b/ballista/scheduler/src/flight_sql.rs index 8956ba46e..2187db064 100644 --- a/ballista/scheduler/src/flight_sql.rs +++ b/ballista/scheduler/src/flight_sql.rs @@ -361,7 +361,7 @@ impl FlightSqlServiceImpl { } fn df_schema_to_arrow(&self, schema: &DFSchemaRef) -> Result, Status> { - let Schema = (&**schema).into(); + let arrow_schema: Schema = (&**schema).into(); let schema_bytes = self.schema_to_arrow(Arc::new(arrow_schema))?; Ok(schema_bytes) }