When leftPitKey or rightPitKey id a double type the interpreted code path produces wrong results.
The problem is in this code
tolerance > 0 && (
leftRowPITKey
.getLong(0) - rightRowPITKey.getLong(0) > tolerance
)
|
.getLong(0) - rightRowPITKey.getLong(0) > tolerance |
When
leftPitKeyorrightPitKeyid a double type the interpreted code path produces wrong results.The problem is in this code
spark-pit/scala/src/main/scala/execution/PITJoinExec.scala
Line 726 in 452dee7