diff options
| author | Yin Huai <yhuai@databricks.com> | 2015-08-12 20:03:55 -0700 |
|---|---|---|
| committer | Reynold Xin <rxin@databricks.com> | 2015-08-12 20:03:55 -0700 |
| commit | 4413d0855aaba5cb00f737dc6934a0b92d9bc05d (patch) | |
| tree | 0dfc292631ecf59cedbdb542ae9f73b25e947f7b /sql | |
| parent | 7c35746c916cf0019367850e75a080d7e739dba0 (diff) | |
| download | spark-4413d0855aaba5cb00f737dc6934a0b92d9bc05d.tar.gz spark-4413d0855aaba5cb00f737dc6934a0b92d9bc05d.tar.bz2 spark-4413d0855aaba5cb00f737dc6934a0b92d9bc05d.zip | |
[SPARK-9908] [SQL] When spark.sql.tungsten.enabled is false, broadcast join does not work
https://issues.apache.org/jira/browse/SPARK-9908
Author: Yin Huai <yhuai@databricks.com>
Closes #8149 from yhuai/SPARK-9908.
Diffstat (limited to 'sql')
| -rw-r--r-- | sql/core/src/main/scala/org/apache/spark/sql/execution/joins/HashedRelation.scala | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/joins/HashedRelation.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/joins/HashedRelation.scala index 076afe6e4e..bb333b4d5e 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/execution/joins/HashedRelation.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/execution/joins/HashedRelation.scala @@ -66,7 +66,8 @@ private[joins] final class GeneralHashedRelation( private var hashTable: JavaHashMap[InternalRow, CompactBuffer[InternalRow]]) extends HashedRelation with Externalizable { - private def this() = this(null) // Needed for serialization + // Needed for serialization (it is public to make Java serialization work) + def this() = this(null) override def get(key: InternalRow): Seq[InternalRow] = hashTable.get(key) @@ -88,7 +89,8 @@ private[joins] final class UniqueKeyHashedRelation(private var hashTable: JavaHashMap[InternalRow, InternalRow]) extends HashedRelation with Externalizable { - private def this() = this(null) // Needed for serialization + // Needed for serialization (it is public to make Java serialization work) + def this() = this(null) override def get(key: InternalRow): Seq[InternalRow] = { val v = hashTable.get(key) |