File tree Expand file tree Collapse file tree 1 file changed +0
-2
lines changed Expand file tree Collapse file tree 1 file changed +0
-2
lines changed Original file line number Diff line number Diff line change @@ -783,7 +783,6 @@ async fn test_multi_threaded_encrypted_writing() {
783783 } ) ;
784784
785785 // Get column writers
786- // This is instead of let col_writers = writer.get_column_writers().unwrap();
787786 let col_writers = row_group_writer_factory. create_column_writers ( 0 ) . unwrap ( ) ;
788787
789788 let ( col_writer_tasks, col_array_channels) =
@@ -804,7 +803,6 @@ async fn test_multi_threaded_encrypted_writing() {
804803 } ) ;
805804
806805 // Append the finalized row groups to the SerializedFileWriter
807- // This is instead of arrow_writer.append_row_group(arrow_column_chunks)
808806 while let Some ( task) = serialize_rx. recv ( ) . await {
809807 let ( arrow_column_chunks, _) = task. await . unwrap ( ) . unwrap ( ) ;
810808 let mut row_group_writer = serialized_file_writer. next_row_group ( ) . unwrap ( ) ;
You can’t perform that action at this time.
0 commit comments