CadyLinn commented on code in PR #23490:
URL: https://github.com/apache/datafusion/pull/23490#discussion_r3792341216
##########
datafusion/datasource/src/write/orchestration.rs:
##########
@@ -173,20 +235,32 @@ pub(crate) async fn stateless_serialize_and_write_files(
// if true, we may not have a guarantee that all written data was cleaned
up.
let mut any_abort_errors = false;
let mut join_set = JoinSet::new();
- while let Some((data_rx, serializer, writer)) = rx.recv().await {
+ while let Some((data_rx, serializer, writer, bytes_written)) =
rx.recv().await {
Review Comment:
Good point, thanks. I renamed the per-writer counter to byte_counter to
avoid shadowing the accumulated bytes_written value. Addressed in commit
0b1b4888b.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
