Github user viirya commented on a diff in the pull request:
https://github.com/apache/spark/pull/21772#discussion_r204618927
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/execution/joins/HashedRelationSuite.scala
---
@@ -278,6 +278,39 @@ class HashedRelationSuite extends
Github user viirya commented on a diff in the pull request:
https://github.com/apache/spark/pull/21772#discussion_r204618745
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/execution/joins/HashedRelationSuite.scala
---
@@ -278,6 +278,39 @@ class HashedRelationSuite extends
Github user viirya commented on a diff in the pull request:
https://github.com/apache/spark/pull/21772#discussion_r204618320
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/execution/joins/HashedRelationSuite.scala
---
@@ -278,6 +278,39 @@ class HashedRelationSuite extends
Github user viirya commented on a diff in the pull request:
https://github.com/apache/spark/pull/21772#discussion_r204617884
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/joins/HashedRelation.scala
---
@@ -772,6 +772,8 @@ private[execution] final class
Github user liutang123 commented on a diff in the pull request:
https://github.com/apache/spark/pull/21772#discussion_r204613880
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/execution/joins/HashedRelationSuite.scala
---
@@ -278,6 +278,39 @@ class HashedRelationSuite
Github user viirya commented on a diff in the pull request:
https://github.com/apache/spark/pull/21772#discussion_r204276973
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/execution/joins/HashedRelationSuite.scala
---
@@ -278,6 +278,39 @@ class HashedRelationSuite extends
Github user viirya commented on a diff in the pull request:
https://github.com/apache/spark/pull/21772#discussion_r204276886
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/joins/HashedRelation.scala
---
@@ -770,8 +771,10 @@ private[execution] final class
Github user viirya commented on a diff in the pull request:
https://github.com/apache/spark/pull/21772#discussion_r204276788
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/joins/HashedRelation.scala
---
@@ -726,9 +726,10 @@ private[execution] final class
Github user liutang123 commented on a diff in the pull request:
https://github.com/apache/spark/pull/21772#discussion_r203365167
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/joins/HashedRelation.scala
---
@@ -726,8 +726,9 @@ private[execution] final class
Github user viirya commented on a diff in the pull request:
https://github.com/apache/spark/pull/21772#discussion_r203252809
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/joins/HashedRelation.scala
---
@@ -726,8 +726,9 @@ private[execution] final class
Github user liutang123 commented on a diff in the pull request:
https://github.com/apache/spark/pull/21772#discussion_r203241485
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/joins/HashedRelation.scala
---
@@ -726,8 +726,9 @@ private[execution] final class
Github user viirya commented on a diff in the pull request:
https://github.com/apache/spark/pull/21772#discussion_r203204659
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/joins/HashedRelation.scala
---
@@ -726,8 +726,9 @@ private[execution] final class
GitHub user liutang123 opened a pull request:
https://github.com/apache/spark/pull/21772
[SPARK-24809] [SQL] Serializing LongHashedRelation in executor may result
in data error
When join key is long or int in broadcast join, Spark will use
LongHashedRelation as the broadcast
13 matches
Mail list logo
