diff --git a/ballista/scheduler/src/flight_sql.rs b/ballista/scheduler/src/flight_sql.rs index 16f24393..245ae7e1 100644 --- a/ballista/scheduler/src/flight_sql.rs +++ b/ballista/scheduler/src/flight_sql.rs @@ -20,7 +20,7 @@ use arrow_flight::flight_service_server::FlightService; use arrow_flight::sql::server::{FlightSqlService, PeekableFlightDataStream}; use arrow_flight::sql::{ ActionClosePreparedStatementRequest, ActionCreatePreparedStatementRequest, - ActionCreatePreparedStatementResult, CommandGetSqlInfo, CommandGetTableTypes, CommandGetTables, + ActionCreatePreparedStatementResult, CommandGetTableTypes, CommandGetTables, CommandPreparedStatementQuery, CommandPreparedStatementUpdate, CommandStatementQuery, SqlInfo, }; use arrow_flight::{ @@ -643,16 +643,6 @@ impl FlightSqlService for FlightSqlServiceImpl { Ok(resp) } - async fn get_flight_info_sql_info( - &self, - _query: CommandGetSqlInfo, - _request: Request, - ) -> Result, Status> { - debug!("get_flight_info_sql_info"); - // TODO: implement for FlightSQL JDBC to work - Err(Status::unimplemented("Implement CommandGetSqlInfo")) - } - async fn do_put_prepared_statement_update( &self, handle: CommandPreparedStatementUpdate,