andygrove commented on code in PR #1192: URL: https://github.com/apache/datafusion-comet/pull/1192#discussion_r1902182688
########## native/core/src/execution/shuffle/shuffle_writer.rs: ########## @@ -1567,17 +1585,41 @@ pub fn write_ipc_compressed<W: Write + Seek>( let mut timer = ipc_time.timer(); let start_pos = output.stream_position()?; - // write ipc_length placeholder - output.write_all(&[0u8; 8])?; + // seek past ipc_length placeholder + output.seek_relative(8)?; + + // write number of columns because JVM side needs to know how many addresses to allocate + let field_count = batch.schema().fields().len(); + output.write_all(&field_count.to_le_bytes())?; Review Comment: This is read in `NativeBatchDecoderIterator` -- 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: github-unsubscr...@datafusion.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org --------------------------------------------------------------------- To unsubscribe, e-mail: github-unsubscr...@datafusion.apache.org For additional commands, e-mail: github-h...@datafusion.apache.org