Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/21404
Merged build finished. Test PASSed.
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/21404
Test PASSed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berkeley.edu/jenkins//job/testing-k8s-prb-make-spark-distribution/3485/
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/21404
**[Test build #91008 has
started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/91008/testReport)**
for PR 21404 at commit
Github user dongjoon-hyun commented on the issue:
https://github.com/apache/spark/pull/21404
Retest this please.
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail:
Github user dongjoon-hyun commented on the issue:
https://github.com/apache/spark/pull/21404
The failures some from `ClassNotFoundException:
org.apache.logging.log4j.util.Strings`.
---
-
To unsubscribe, e-mail:
Github user dongjoon-hyun commented on a diff in the pull request:
https://github.com/apache/spark/pull/21404#discussion_r190101719
--- Diff:
sql/hive/src/main/scala/org/apache/spark/sql/hive/client/HiveShim.scala ---
@@ -1148,3 +1149,128 @@ private[client] class Shim_v2_1 extends
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/21082
Test FAILed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berkeley.edu/jenkins//job/SparkPullRequestBuilder/90996/
Test FAILed.
---
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/21082
Merged build finished. Test FAILed.
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional
Github user LantaoJin commented on the issue:
https://github.com/apache/spark/pull/21396
[#20784](https://github.com/apache/spark/pull/20784) and
[#21343](https://github.com/apache/spark/pull/21343) did the same thing, but
#21343 is much readable. They are all to fix the problem
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/21082
**[Test build #90996 has
finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/90996/testReport)**
for PR 21082 at commit
Github user LantaoJin commented on a diff in the pull request:
https://github.com/apache/spark/pull/21396#discussion_r190100259
--- Diff:
core/src/main/scala/org/apache/spark/deploy/security/HiveDelegationTokenProvider.scala
---
@@ -85,7 +85,10 @@ private[spark] class
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/21069
Test PASSed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berkeley.edu/jenkins//job/testing-k8s-prb-make-spark-distribution/3484/
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/21069
Merged build finished. Test PASSed.
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/21403
Merged build finished. Test FAILed.
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/21403
Test FAILed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berkeley.edu/jenkins//job/SparkPullRequestBuilder/90998/
Test FAILed.
---
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/21403
**[Test build #90998 has
finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/90998/testReport)**
for PR 21403 at commit
Github user asfgit closed the pull request at:
https://github.com/apache/spark/pull/21387
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
Github user jiangxb1987 commented on a diff in the pull request:
https://github.com/apache/spark/pull/21390#discussion_r190098764
--- Diff:
common/network-shuffle/src/test/java/org/apache/spark/network/shuffle/NonShuffleFilesCleanupSuite.java
---
@@ -0,0 +1,222 @@
+/*
+ *
Github user HyukjinKwon commented on the issue:
https://github.com/apache/spark/pull/21387
Merged to master and branch-2.3.
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands,
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/21069
**[Test build #91007 has
started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/91007/testReport)**
for PR 21069 at commit
Github user jiangxb1987 commented on a diff in the pull request:
https://github.com/apache/spark/pull/21390#discussion_r190098624
--- Diff: core/src/main/scala/org/apache/spark/deploy/worker/Worker.scala
---
@@ -732,6 +736,9 @@ private[deploy] class Worker(
Github user huaxingao commented on the issue:
https://github.com/apache/spark/pull/21069
retest this please
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail:
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/21390
Merged build finished. Test PASSed.
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/21390
Test PASSed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berkeley.edu/jenkins//job/testing-k8s-prb-make-spark-distribution/3483/
Github user jiangxb1987 commented on a diff in the pull request:
https://github.com/apache/spark/pull/21390#discussion_r190098033
--- Diff: core/src/main/scala/org/apache/spark/deploy/worker/Worker.scala
---
@@ -97,6 +97,10 @@ private[deploy] class Worker(
private val
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/21404
Test FAILed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berkeley.edu/jenkins//job/SparkPullRequestBuilder/91001/
Test FAILed.
---
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/21404
Merged build finished. Test FAILed.
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/21404
**[Test build #91001 has
finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/91001/testReport)**
for PR 21404 at commit
Github user maropu commented on the issue:
https://github.com/apache/spark/pull/20929
@mengxr Could you check? Thanks!
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands,
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/21390
**[Test build #91006 has
started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/91006/testReport)**
for PR 21390 at commit
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/21401
**[Test build #91005 has
started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/91005/testReport)**
for PR 21401 at commit
Github user maropu commented on the issue:
https://github.com/apache/spark/pull/21401
retest this please
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail:
Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/21404#discussion_r190097176
--- Diff:
sql/hive/src/main/scala/org/apache/spark/sql/hive/client/HiveShim.scala ---
@@ -1148,3 +1149,128 @@ private[client] class Shim_v2_1 extends
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/21394
Merged build finished. Test FAILed.
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/21394
Test FAILed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berkeley.edu/jenkins//job/SparkPullRequestBuilder/90997/
Test FAILed.
---
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/21394
**[Test build #90997 has
finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/90997/testReport)**
for PR 21394 at commit
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/21045
Merged build finished. Test FAILed.
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/21045
**[Test build #91004 has
finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/91004/testReport)**
for PR 21045 at commit
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/21045
Test FAILed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berkeley.edu/jenkins//job/SparkPullRequestBuilder/91004/
Test FAILed.
---
Github user DylanGuedes commented on a diff in the pull request:
https://github.com/apache/spark/pull/21045#discussion_r190095025
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/collectionOperations.scala
---
@@ -127,6 +127,148 @@ case class
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/21045
**[Test build #91004 has
started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/91004/testReport)**
for PR 21045 at commit
Github user DylanGuedes commented on a diff in the pull request:
https://github.com/apache/spark/pull/21045#discussion_r190094810
--- Diff:
sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/expressions/CollectionExpressionsSuite.scala
---
@@ -288,6 +289,88 @@ class
Github user DylanGuedes commented on a diff in the pull request:
https://github.com/apache/spark/pull/21045#discussion_r190094430
--- Diff:
sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/expressions/CollectionExpressionsSuite.scala
---
@@ -288,6 +289,88 @@ class
Github user icexelloss commented on the issue:
https://github.com/apache/spark/pull/21397
Only when udf raises error. In normal case, there is no race because the
writer thread always closes the root and allocator before task completion
listener runs.
---
Github user dongjoon-hyun commented on the issue:
https://github.com/apache/spark/pull/20208
Sorry for the delay. I updated the PR according to the comments,
@gatorsmile .
Could you review this once more?
---
-
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/21404
Merged build finished. Test PASSed.
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/21404
Test PASSed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berkeley.edu/jenkins//job/testing-k8s-prb-make-spark-distribution/3482/
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/21404
**[Test build #91003 has
started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/91003/testReport)**
for PR 21404 at commit
Github user BryanCutler commented on the issue:
https://github.com/apache/spark/pull/21397
One more question, do you only observe this when the python udf raises an
error or have you seen it in normal runtime operation?
---
Github user dongjoon-hyun commented on a diff in the pull request:
https://github.com/apache/spark/pull/21404#discussion_r190088876
--- Diff:
sql/hive/src/main/scala/org/apache/spark/sql/hive/client/package.scala ---
@@ -79,7 +79,12 @@ package object client {
exclusions
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/21385
**[Test build #91002 has
started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/91002/testReport)**
for PR 21385 at commit
Github user jose-torres commented on a diff in the pull request:
https://github.com/apache/spark/pull/21385#discussion_r190088531
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/shuffle/UnsafeRowReceiver.scala
---
@@ -56,20 +62,46 @@
Github user jose-torres commented on the issue:
https://github.com/apache/spark/pull/21385
addressed comments
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail:
Github user jose-torres commented on a diff in the pull request:
https://github.com/apache/spark/pull/21385#discussion_r190088467
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/shuffle/UnsafeRowReceiver.scala
---
@@ -56,20 +62,46 @@
Github user gatorsmile commented on a diff in the pull request:
https://github.com/apache/spark/pull/21404#discussion_r190086082
--- Diff:
sql/hive/src/main/scala/org/apache/spark/sql/hive/client/package.scala ---
@@ -79,7 +79,12 @@ package object client {
exclusions =
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/21404
Test PASSed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berkeley.edu/jenkins//job/testing-k8s-prb-make-spark-distribution/3481/
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/21404
Merged build finished. Test PASSed.
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/20894
Test PASSed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berkeley.edu/jenkins//job/SparkPullRequestBuilder/90993/
Test PASSed.
---
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/20894
Merged build finished. Test PASSed.
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/20894
**[Test build #90993 has
finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/90993/testReport)**
for PR 20894 at commit
Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/21385#discussion_r190082630
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/streaming/continuous/shuffle/ContinuousShuffleReadSuite.scala
---
@@ -161,13 +189,15 @@ class
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/21404
**[Test build #91001 has
started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/91001/testReport)**
for PR 21404 at commit
GitHub user dongjoon-hyun opened a pull request:
https://github.com/apache/spark/pull/21404
[SPARK-24360][SQL] Support Hive 3.0 metastore
## What changes were proposed in this pull request?
Hive 3.0 is released. This PR aims to support Hive 3.0 metastore.
## How
Github user icexelloss commented on the issue:
https://github.com/apache/spark/pull/21397
Yeah this is a bit tricky because of the race. The test does fail on my
machine without the fix.
I have been changing the test data size until I can reproduce it, so it's
not great. If
Github user jose-torres commented on a diff in the pull request:
https://github.com/apache/spark/pull/21385#discussion_r190080895
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/streaming/continuous/shuffle/ContinuousShuffleReadSuite.scala
---
@@ -161,13 +189,15 @@ class
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/21398
Test PASSed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berkeley.edu/jenkins//job/SparkPullRequestBuilder/90994/
Test PASSed.
---
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/21398
Merged build finished. Test PASSed.
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/21398
**[Test build #90994 has
finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/90994/testReport)**
for PR 21398 at commit
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/21399
Test PASSed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berkeley.edu/jenkins//job/testing-k8s-prb-make-spark-distribution/3480/
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/21399
Merged build finished. Test PASSed.
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/21397
Test PASSed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berkeley.edu/jenkins//job/SparkPullRequestBuilder/90991/
Test PASSed.
---
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/21397
Merged build finished. Test PASSed.
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/21397
**[Test build #90991 has
finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/90991/testReport)**
for PR 21397 at commit
Github user liyinan926 commented on the issue:
https://github.com/apache/spark/pull/21260
@andrusha Is this ready for review?
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/21399
**[Test build #91000 has
started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/91000/testReport)**
for PR 21399 at commit
Github user HyukjinKwon commented on the issue:
https://github.com/apache/spark/pull/21399
retest this please
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail:
Github user BryanCutler commented on the issue:
https://github.com/apache/spark/pull/21397
@icexelloss the test you added passes for me without the fix, but I did see
a message of a suppressed exception in the finally block
"java.lang.IllegalStateException: ArrowBuf[3] refCnt has
Github user gatorsmile commented on a diff in the pull request:
https://github.com/apache/spark/pull/21295#discussion_r190076831
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/parquet/ParquetQuerySuite.scala
---
@@ -879,6 +879,18 @@ class
Github user jiangxb1987 commented on a diff in the pull request:
https://github.com/apache/spark/pull/21390#discussion_r190074813
--- Diff:
common/network-common/src/main/java/org/apache/spark/network/util/JavaUtils.java
---
@@ -157,10 +172,10 @@ private static void
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/21372
Test PASSed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berkeley.edu/jenkins//job/testing-k8s-prb-make-spark-distribution/3479/
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/21372
Merged build finished. Test PASSed.
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/21372
**[Test build #90999 has
started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/90999/testReport)**
for PR 21372 at commit
Github user dongjoon-hyun commented on a diff in the pull request:
https://github.com/apache/spark/pull/21372#discussion_r190073105
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/orc/OrcSourceSuite.scala
---
@@ -169,6 +170,14 @@ abstract class
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/21403
Test PASSed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berkeley.edu/jenkins//job/testing-k8s-prb-make-spark-distribution/3478/
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/21403
Merged build finished. Test PASSed.
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional
Github user viirya commented on the issue:
https://github.com/apache/spark/pull/21193
Thanks for your review @hvanhovell @cloud-fan @kiszk @maropu @mgaido91
@ueshin @rednaxelafx
---
-
To unsubscribe, e-mail:
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/21403
**[Test build #90998 has
started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/90998/testReport)**
for PR 21403 at commit
Github user mgaido91 commented on the issue:
https://github.com/apache/spark/pull/21403
cc @cloud-fan @dilipbiswal @gatorsmile @juliuszsompolski: it is currently a
WIP since I think the UTs have to be formalized a bit better. But I wanted to
share with you this in order to understand
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/21331
Test FAILed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berkeley.edu/jenkins//job/SparkPullRequestBuilder/90995/
Test FAILed.
---
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/21331
Merged build finished. Test FAILed.
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/21331
**[Test build #90995 has
finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/90995/testReport)**
for PR 21331 at commit
GitHub user mgaido91 opened a pull request:
https://github.com/apache/spark/pull/21403
[SPARK-24313][WIP][SQL] Support IN subqueries with struct type
## What changes were proposed in this pull request?
Using struct types in subqueries with the `IN` clause can generate
Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/21385#discussion_r190061592
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/shuffle/UnsafeRowReceiver.scala
---
@@ -56,20 +62,46 @@
Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/21385#discussion_r190069654
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/streaming/continuous/shuffle/ContinuousShuffleReadSuite.scala
---
@@ -181,4 +211,80 @@ class
Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/21385#discussion_r190059433
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/shuffle/UnsafeRowReceiver.scala
---
@@ -56,20 +62,46 @@
Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/21385#discussion_r190069533
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/streaming/continuous/shuffle/ContinuousShuffleReadSuite.scala
---
@@ -115,17 +124,36 @@ class
Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/21385#discussion_r190056646
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/shuffle/UnsafeRowReceiver.scala
---
@@ -56,20 +62,46 @@
Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/21385#discussion_r190069145
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/streaming/continuous/shuffle/ContinuousShuffleReadSuite.scala
---
@@ -161,13 +189,15 @@ class
Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/21385#discussion_r190060224
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/shuffle/UnsafeRowReceiver.scala
---
@@ -56,20 +62,46 @@
Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/21385#discussion_r190058882
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/shuffle/UnsafeRowReceiver.scala
---
@@ -41,11 +44,14 @@
101 - 200 of 832 matches
Mail list logo
