Description
While looking into https://issues.apache.org/jira/browse/SPARK-12319 I noticed that the row size is incorrectly calculated.
The "sizeReduction" value is calculated in words:
// The number of words we can reduce when we concat two rows together.
// The only reduction comes from merging the bitset portion of the two rows, saving 1 word.
val sizeReduction = bitset1Words + bitset2Words - outputBitsetWords
but then it is subtracted from the size of the row in bytes:
out.pointTo(buf, ${schema1.size + schema2.size}, sizeInBytes - $sizeReduction); |
Attachments
Issue Links
- is related to
-
SPARK-12647 1.6 branch test failure o.a.s.sql.execution.ExchangeCoordinatorSuite.determining the number of reducers: aggregate operator
- Resolved
- links to