Skip to content

Commit ef92999

Browse files
maropugatorsmile
authored andcommitted
[SPARK-22600][SQL][FOLLOW-UP] Fix a compilation error in TPCDS q75/q77
## What changes were proposed in this pull request? This pr fixed a compilation error of TPCDS `q75`/`q77` caused by apache#19813; ``` java.util.concurrent.ExecutionException: org.codehaus.commons.compiler.CompileException: File 'generated.java', Line 371, Column 16: failed to compile: org.codehaus.commons.compiler.CompileException: File 'generated.java', Line 371, Column 16: Expression "bhj_matched" is not an rvalue at com.google.common.util.concurrent.AbstractFuture$Sync.getValue(AbstractFuture.java:306) at com.google.common.util.concurrent.AbstractFuture$Sync.get(AbstractFuture.java:293) at com.google.common.util.concurrent.AbstractFuture.get(AbstractFuture.java:116) at com.google.common.util.concurrent.Uninterruptibles.getUninterruptibly(Uninterruptibles.java:135) ``` ## How was this patch tested? Manually checked `q75`/`q77` can be properly compiled Author: Takeshi Yamamuro <[email protected]> Closes apache#19969 from maropu/SPARK-22600-FOLLOWUP.
1 parent a83e8e6 commit ef92999

File tree

2 files changed

+1
-2
lines changed

2 files changed

+1
-2
lines changed

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/codegen/ExpressionCodegen.scala

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,6 @@ package org.apache.spark.sql.catalyst.expressions.codegen
2020
import scala.collection.mutable
2121

2222
import org.apache.spark.sql.catalyst.expressions._
23-
import org.apache.spark.sql.types.DataType
2423

2524
/**
2625
* Defines util methods used in expression code generation.

sql/core/src/main/scala/org/apache/spark/sql/execution/joins/BroadcastHashJoinExec.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -192,7 +192,7 @@ case class BroadcastHashJoinExec(
192192
| $value = ${ev.value};
193193
|}
194194
""".stripMargin
195-
ExprCode(code, isNull, value)
195+
ExprCode(code, isNull, value, inputRow = matched)
196196
}
197197
}
198198
}

0 commit comments

Comments
 (0)