carloea2 opened a new issue, #8171: URL: https://github.com/apache/texera/issues/8171
### Root cause The Scala range shuffle converts `DOUBLE` keys to `Long` before calculating their bucket. Fractional values are truncated toward zero, so negative decimals near a bucket boundary can be sent to a different worker than the Python range shuffle. ### Reproduction Use two receivers over the inclusive range -10 to 9 and partition a `DOUBLE` key of -0.5. Before: Scala bucket 1, Python bucket 0 After: Scala bucket 0, Python bucket 0 A key of 0.0 remains in bucket 1, confirming the actual boundary is unchanged. ### Expected behavior Both execution engines preserve decimal values while choosing the range bucket. ### Version Current `main` at 70c21145887920528d7d5540e3fb790b43e8b759. -- 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]
