From 4413d0855aaba5cb00f737dc6934a0b92d9bc05d Mon Sep 17 00:00:00 2001
From: Yin Huai <yhuai@databricks.com>
Date: Wed, 12 Aug 2015 20:03:55 -0700
Subject: [PATCH] [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.
---
.../apache/spark/sql/execution/joins/HashedRelation.scala | 6 ++++--
1 file 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)
--
GitLab