Skip to content

Commit

Permalink
Fix wrong location causing not support flight-sql-jdbc-driver (apache…
Browse files Browse the repository at this point in the history
…#1012)

return empty location in FlightEndpoint
  • Loading branch information
chenmc committed Apr 30, 2024
1 parent 04766d5 commit 35c5c59
Showing 1 changed file with 1 addition and 5 deletions.
6 changes: 1 addition & 5 deletions ballista/scheduler/src/flight_sql.rs
Original file line number Diff line number Diff line change
Expand Up @@ -289,15 +289,11 @@ impl FlightSqlServiceImpl {
} else {
Err(Status::internal("Error getting stats".to_string()))?
}
let authority = format!("{}:{}", &host, &port);
let loc = Location {
uri: format!("grpc+tcp://{authority}"),
};
let buf = fetch.as_any().encode_to_vec();
let ticket = Ticket { ticket: buf.into() };
let fiep = FlightEndpoint {
ticket: Some(ticket),
location: vec![loc],
location: vec![],
};
fieps.push(fiep);
}
Expand Down

0 comments on commit 35c5c59

Please sign in to comment.