Details
-
Bug
-
Status: Closed
-
Major
-
Resolution: Fixed
-
None
-
None
-
None
Description
When final merge is disabled (without pipelining), wrong stats was sent out in the last event.
It was based on numRecordsPerPartition which contains the overall partition data. It should be ideally be based on the spill result and its buffers.
Also, finalSpill was unncessarily sending events when no data was present (i.e, when currentBuffer didn't have any data). This can be optimized to reduce the number of events being sent across.