@@ -27,7 +27,7 @@ use datafusion::logical_expr::LogicalPlan;
2727use datafusion:: sql:: parser:: DFParser ;
2828use datafusion_app:: local:: ExecutionContext ;
2929use datafusion_app:: observability:: ObservabilityRequestDetails ;
30- use futures:: { Stream , StreamExt , TryStreamExt } ;
30+ use futures:: { StreamExt , TryStreamExt } ;
3131use jiff:: Timestamp ;
3232use log:: { debug, error, info} ;
3333use metrics:: { counter, histogram} ;
@@ -236,7 +236,7 @@ impl FlightSqlService for FlightSqlServiceImpl {
236236 start,
237237 Some ( request_id. to_string ( ) ) ,
238238 res. as_ref ( ) . err ( ) ,
239- "get_flight_info_statement" . to_string ( ) ,
239+ "/ get_flight_info_statement" . to_string ( ) ,
240240 "get_flight_info_statement_latency_ms" ,
241241 )
242242 . await ;
@@ -262,7 +262,7 @@ impl FlightSqlService for FlightSqlServiceImpl {
262262 start,
263263 Some ( request_id) ,
264264 res. as_ref ( ) . err ( ) ,
265- "do_get_statement" . to_string ( ) ,
265+ "/ do_get_statement" . to_string ( ) ,
266266 "do_get_statement_latency_ms" ,
267267 )
268268 . await ;
@@ -288,7 +288,7 @@ impl FlightSqlService for FlightSqlServiceImpl {
288288 start,
289289 Some ( request_id) ,
290290 res. as_ref ( ) . err ( ) ,
291- "do_get_fallback" . to_string ( ) ,
291+ "/ do_get_fallback" . to_string ( ) ,
292292 "do_get_fallback_latency_ms" ,
293293 )
294294 . await ;
0 commit comments