File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -529,10 +529,22 @@ mod tests {
529529
530530 #[ test]
531531 fn test_shuffle_format_parsing ( ) {
532- assert_eq ! ( "arrow_ipc" . parse:: <ShuffleFormat >( ) . unwrap( ) , ShuffleFormat :: ArrowIpc ) ;
533- assert_eq ! ( "arrow-ipc" . parse:: <ShuffleFormat >( ) . unwrap( ) , ShuffleFormat :: ArrowIpc ) ;
534- assert_eq ! ( "ipc" . parse:: <ShuffleFormat >( ) . unwrap( ) , ShuffleFormat :: ArrowIpc ) ;
535- assert_eq ! ( "vortex" . parse:: <ShuffleFormat >( ) . unwrap( ) , ShuffleFormat :: Vortex ) ;
532+ assert_eq ! (
533+ "arrow_ipc" . parse:: <ShuffleFormat >( ) . unwrap( ) ,
534+ ShuffleFormat :: ArrowIpc
535+ ) ;
536+ assert_eq ! (
537+ "arrow-ipc" . parse:: <ShuffleFormat >( ) . unwrap( ) ,
538+ ShuffleFormat :: ArrowIpc
539+ ) ;
540+ assert_eq ! (
541+ "ipc" . parse:: <ShuffleFormat >( ) . unwrap( ) ,
542+ ShuffleFormat :: ArrowIpc
543+ ) ;
544+ assert_eq ! (
545+ "vortex" . parse:: <ShuffleFormat >( ) . unwrap( ) ,
546+ ShuffleFormat :: Vortex
547+ ) ;
536548 assert ! ( "invalid" . parse:: <ShuffleFormat >( ) . is_err( ) ) ;
537549 }
538550}
Original file line number Diff line number Diff line change @@ -1023,7 +1023,8 @@ mod test {
10231023 use crate :: config:: BALLISTA_IS_FINAL_STAGE ;
10241024
10251025 // Test that is_final_stage is included in key-value pairs
1026- let config = SessionConfig :: new_with_ballista ( ) . with_ballista_is_final_stage ( true ) ;
1026+ let config =
1027+ SessionConfig :: new_with_ballista ( ) . with_ballista_is_final_stage ( true ) ;
10271028 let pairs = config. to_key_value_pairs ( ) ;
10281029
10291030 let is_final_pair = pairs. iter ( ) . find ( |p| p. key == BALLISTA_IS_FINAL_STAGE ) ;
You can’t perform that action at this time.
0 commit comments