spark-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Aniket Arun Kulkarni (JIRA)" <>
Subject [jira] [Created] (SPARK-23876) OR condition in joins causes results to come back to driver
Date Thu, 05 Apr 2018 19:01:00 GMT
Aniket Arun Kulkarni created SPARK-23876:

             Summary: OR condition in joins causes results to come back to driver
                 Key: SPARK-23876
             Project: Spark
          Issue Type: Bug
          Components: Spark Core
    Affects Versions: 1.6.2
            Reporter: Aniket Arun Kulkarni

Hello all,

I am trying to implement an 'OR' join, something as shown below,

leftDF.join(rightDF, leftDF(leftJoinKey1) === rightDF(rightJoinKey1) || leftDF(leftJoinKey2)
=== rightDF(rightJoinKey2), joinType)
.select(leftDF.col("*"), rightDF(colToFetchFromRight) as(aliasForRightColumn))

rightDF has around 400 million rows
leftDF has around 200 million rows

When I run this code, I get an error saying

"Total size of serialized results is bigger than spark.driver.maxResultSize"

This means the results are being sent back to the driver even when i did not call actions
such as count or show.

If I remove the or condition, the results are no longer sent to the driver and the job goes

This message was sent by Atlassian JIRA

To unsubscribe, e-mail:
For additional commands, e-mail:

View raw message