Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/19804
Build finished. Test PASSed.
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands,
Github user felixcheung commented on a diff in the pull request:
https://github.com/apache/spark/pull/20977#discussion_r179665313
--- Diff:
core/src/main/scala/org/apache/spark/scheduler/AsyncEventQueue.scala ---
@@ -166,7 +166,7 @@ private class AsyncEventQueue(val name: String,
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/19804
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/2021/
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/19802
Can one of the admins verify this patch?
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional
Github user HyukjinKwon commented on the issue:
https://github.com/apache/spark/pull/20962
LGTM otherwise.
---
-
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/20962#discussion_r179664682
--- Diff: python/pyspark/sql/column.py ---
@@ -450,21 +450,69 @@ def isin(self, *cols):
Returns a sort expression based on the ascending order
Github user asfgit closed the pull request at:
https://github.com/apache/spark/pull/20928
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
Github user asfgit closed the pull request at:
https://github.com/apache/spark/pull/20948
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/20962#discussion_r179664441
--- Diff: python/pyspark/sql/column.py ---
@@ -450,21 +450,69 @@ def isin(self, *cols):
Returns a sort expression based on the ascending order
Github user HyukjinKwon commented on the issue:
https://github.com/apache/spark/pull/20928
Merged to master.
---
-
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/20871
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/2020/
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/20871
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/20871
**[Test build #88964 has
started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/88964/testReport)**
for PR 20871 at commit
Github user kiszk commented on the issue:
https://github.com/apache/spark/pull/20871
retest this please
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail:
Github user rxin commented on the issue:
https://github.com/apache/spark/pull/19881
Maybe instead of "divisor", we just have a "rate" or "factor" that can be
floating point value, and use multiplication rather than division? This way
people can also make it even more aggressive.
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/20990
Can one of the admins verify this patch?
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/20990
Can one of the admins verify this patch?
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional
GitHub user emirot opened a pull request:
https://github.com/apache/spark/pull/20990
Fix typo in docstring
## What changes were proposed in this pull request?
(Please fill in changes proposed in this fix)
## How was this patch tested?
(Please explain how
Github user mridulm commented on the issue:
https://github.com/apache/spark/pull/20987
Thanks for fixing this @squito, LGTM
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands,
Github user mridulm commented on a diff in the pull request:
https://github.com/apache/spark/pull/20987#discussion_r179654822
--- Diff: core/src/main/scala/org/apache/spark/executor/Executor.scala ---
@@ -494,19 +507,6 @@ private[spark] class Executor(
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/20871
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/20871
Test FAILed.
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/2019/
Github user asfgit closed the pull request at:
https://github.com/apache/spark/pull/20886
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
Github user gatorsmile commented on the issue:
https://github.com/apache/spark/pull/20886
Thanks! Merged to master
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail:
Github user HyukjinKwon commented on the issue:
https://github.com/apache/spark/pull/20975
Thanks for the details and confirmation, @barrenlake. I helped me
understand the intention.
---
-
To unsubscribe, e-mail:
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/20871
**[Test build #88963 has
started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/88963/testReport)**
for PR 20871 at commit
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/20989
Kubernetes integration test status failure
URL:
https://amplab.cs.berkeley.edu/jenkins/job/testing-k8s-prb-spark-integration/1981/
---
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/20953
**[Test build #88962 has
started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/88962/testReport)**
for PR 20953 at commit
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/20971
**[Test build #88961 has
started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/88961/testReport)**
for PR 20971 at commit
Github user gatorsmile commented on the issue:
https://github.com/apache/spark/pull/20971
ok to test
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail:
Github user gatorsmile commented on the issue:
https://github.com/apache/spark/pull/20971
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/20988
Test PASSed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berkeley.edu/jenkins//job/SparkPullRequestBuilder/88959/
Test PASSed.
---
Github user jiangxb1987 commented on a diff in the pull request:
https://github.com/apache/spark/pull/20931#discussion_r179651241
--- Diff:
core/src/main/scala/org/apache/spark/internal/io/HadoopMapReduceCommitProtocol.scala
---
@@ -186,7 +186,9 @@ class
Github user gatorsmile commented on the issue:
https://github.com/apache/spark/pull/20953
retest this please
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail:
Github user asfgit closed the pull request at:
https://github.com/apache/spark/pull/20961
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/20988
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/20989
Kubernetes integration test starting
URL:
https://amplab.cs.berkeley.edu/jenkins/job/testing-k8s-prb-spark-integration/1981/
---
Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/20931#discussion_r179651085
--- Diff:
core/src/main/scala/org/apache/spark/internal/io/HadoopMapReduceCommitProtocol.scala
---
@@ -186,7 +186,9 @@ class
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/20989
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/2018/
Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/20931#discussion_r179651049
--- Diff:
core/src/main/scala/org/apache/spark/internal/io/HadoopMapReduceCommitProtocol.scala
---
@@ -186,7 +186,9 @@ class
Github user jiangxb1987 commented on a diff in the pull request:
https://github.com/apache/spark/pull/20931#discussion_r179651037
--- Diff:
core/src/main/scala/org/apache/spark/internal/io/HadoopMapReduceCommitProtocol.scala
---
@@ -186,7 +186,9 @@ class
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/20989
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/20988
**[Test build #88959 has
finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/88959/testReport)**
for PR 20988 at commit
Github user gatorsmile commented on the issue:
https://github.com/apache/spark/pull/20961
Thanks! Merged to master/2.3
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands,
Github user asfgit closed the pull request at:
https://github.com/apache/spark/pull/20970
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/20931#discussion_r179650482
--- Diff:
core/src/main/scala/org/apache/spark/internal/io/HadoopMapReduceCommitProtocol.scala
---
@@ -186,7 +186,9 @@ class
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/20989
**[Test build #88960 has
finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/88960/testReport)**
for PR 20989 at commit
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/20989
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/20989
Test FAILed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berkeley.edu/jenkins//job/SparkPullRequestBuilder/88960/
Test FAILed.
---
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/20989
**[Test build #88960 has
started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/88960/testReport)**
for PR 20989 at commit
Github user jkbradley commented on the issue:
https://github.com/apache/spark/pull/20970
LGTM
Merging with master
Thanks @yogeshg !
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For
Github user foxish commented on the issue:
https://github.com/apache/spark/pull/20989
ok to test
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail:
Github user Ngone51 commented on the issue:
https://github.com/apache/spark/pull/20987
Things I'm concerned about is that does there exists a situation like 'a
task gets killed after it gets a FetchFailure, but re-run (not by resubmit)
later and gets a FetchFailure too without
Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/20931#discussion_r179647871
--- Diff:
core/src/main/scala/org/apache/spark/internal/io/HadoopMapReduceCommitProtocol.scala
---
@@ -186,7 +186,9 @@ class
Github user Ngone51 commented on a diff in the pull request:
https://github.com/apache/spark/pull/20987#discussion_r179647613
--- Diff: core/src/test/scala/org/apache/spark/executor/ExecutorSuite.scala
---
@@ -173,8 +173,26 @@ class ExecutorSuite extends SparkFunSuite with
Github user Ngone51 commented on a diff in the pull request:
https://github.com/apache/spark/pull/20987#discussion_r179647240
--- Diff: core/src/test/scala/org/apache/spark/executor/ExecutorSuite.scala
---
@@ -330,6 +362,15 @@ class FetchFailureHidingRDD(
case t:
Github user cloud-fan commented on the issue:
https://github.com/apache/spark/pull/19193
I feel it's much simpler to just prohibit this case, as we don't allow
nested aggregate function. Users can always use subquery to work around it. Do
other databases support window function
Github user squito commented on the issue:
https://github.com/apache/spark/pull/20987
pinging some potential reviewers: @tgravescs @kayousterhout @zsxwing
@mridulm
---
-
To unsubscribe, e-mail:
Github user cloud-fan commented on the issue:
https://github.com/apache/spark/pull/19222
oh I missed one thing. @kiszk please create a new JIRA for this PR, as the
original JIRA tries to introduce an infrastructure to enable memory accessing
from c++, which is not what this PR did.
Github user asfgit closed the pull request at:
https://github.com/apache/spark/pull/19222
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
Github user cloud-fan commented on the issue:
https://github.com/apache/spark/pull/19222
thanks, merging to master!
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail:
Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/20986#discussion_r179645207
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/codegen/GenerateUnsafeProjection.scala
---
@@ -176,6 +141,23 @@ object
Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/20986#discussion_r179644816
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/codegen/GenerateUnsafeProjection.scala
---
@@ -176,6 +141,23 @@ object
Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/20986#discussion_r179644768
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/codegen/GenerateUnsafeProjection.scala
---
@@ -176,6 +141,23 @@ object
Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/20986#discussion_r179644530
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/codegen/GenerateUnsafeProjection.scala
---
@@ -286,23 +239,32 @@ object
Github user barrenlake commented on the issue:
https://github.com/apache/spark/pull/20975
@HyukjinKwon Oh yes, you are right. This problem was encountered when I
added the small file merge function to the Hive module. When I used select
count(1) to count the merge result file, I
Github user barrenlake closed the pull request at:
https://github.com/apache/spark/pull/20975
---
-
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/20987
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/20987
Test PASSed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berkeley.edu/jenkins//job/SparkPullRequestBuilder/88958/
Test PASSed.
---
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/20987
**[Test build #88958 has
finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/88958/testReport)**
for PR 20987 at commit
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/20961
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/20961
Test PASSed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berkeley.edu/jenkins//job/SparkPullRequestBuilder/88957/
Test PASSed.
---
Github user yogeshg commented on the issue:
https://github.com/apache/spark/pull/20904
lgtm, I'll defer to @jkbradley
---
-
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/20961
**[Test build #88957 has
finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/88957/testReport)**
for PR 20961 at commit
Github user yogeshg commented on a diff in the pull request:
https://github.com/apache/spark/pull/20904#discussion_r179639255
--- Diff: python/pyspark/ml/stat.py ---
@@ -134,6 +134,63 @@ def corr(dataset, column, method="pearson"):
return _java2py(sc,
Github user jose-torres commented on a diff in the pull request:
https://github.com/apache/spark/pull/20828#discussion_r179635730
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/streaming/continuous/ContinuousSuite.scala
---
@@ -53,32 +53,24 @@ class ContinuousSuiteBase
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/20988
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/2017/
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/20988
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/20989
Can one of the admins verify this patch?
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional
Github user madanadit commented on the issue:
https://github.com/apache/spark/pull/20989
@foxish Can you take a look?. Thanks!
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/20989
Can one of the admins verify this patch?
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional
GitHub user madanadit opened a pull request:
https://github.com/apache/spark/pull/20989
[SPARK-23529][K8s] Support mounting hostPath volumes for executors
## What changes were proposed in this pull request?
This PR introduces a new config `spark.kubernetes.executor.volumes`
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/20988
**[Test build #88959 has
started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/88959/testReport)**
for PR 20988 at commit
GitHub user rdblue opened a pull request:
https://github.com/apache/spark/pull/20988
[SPARK-23877][SQL]: Use filter predicates to prune partitions in
metadata-only queries
## What changes were proposed in this pull request?
This updates the OptimizeMetadataOnlyQuery rule
Github user BryanCutler commented on a diff in the pull request:
https://github.com/apache/spark/pull/20968#discussion_r179623749
--- Diff: python/pyspark/ml/feature.py ---
@@ -2342,8 +2342,38 @@ def mean(self):
return self._call_java("mean")
+class
Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/20937#discussion_r179622965
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/json/CreateJacksonParser.scala
---
@@ -39,11 +40,28 @@ private[sql] object
Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/20828#discussion_r179596647
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousMemoryStream.scala
---
@@ -0,0 +1,212 @@
+/*
--- End
Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/20828#discussion_r179603916
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousMemoryStream.scala
---
@@ -0,0 +1,212 @@
+/*
+ *
Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/20828#discussion_r179594450
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/memory.scala
---
@@ -43,8 +45,39 @@ object MemoryStream {
protected val
Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/20828#discussion_r179603105
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousMemoryStream.scala
---
@@ -0,0 +1,212 @@
+/*
+ *
Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/20828#discussion_r179604298
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousMemoryStream.scala
---
@@ -0,0 +1,212 @@
+/*
+ *
Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/20828#discussion_r179602477
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousMemoryStream.scala
---
@@ -0,0 +1,212 @@
+/*
+ *
Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/20828#discussion_r179601495
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousMemoryStream.scala
---
@@ -0,0 +1,212 @@
+/*
--- End
Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/20828#discussion_r179617487
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousMemoryStream.scala
---
@@ -0,0 +1,212 @@
+/*
+ *
Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/20828#discussion_r179617590
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousMemoryStream.scala
---
@@ -0,0 +1,212 @@
+/*
+ *
Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/20828#discussion_r179599245
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/streaming/continuous/ContinuousSuite.scala
---
@@ -53,32 +53,24 @@ class ContinuousSuiteBase extends
Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/20828#discussion_r179617149
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousMemoryStream.scala
---
@@ -0,0 +1,212 @@
+/*
+ *
Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/20828#discussion_r179605302
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousMemoryStream.scala
---
@@ -0,0 +1,212 @@
+/*
+ *
Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/20828#discussion_r179618466
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousMemoryStream.scala
---
@@ -0,0 +1,212 @@
+/*
+ *
Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/20828#discussion_r179606525
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousMemoryStream.scala
---
@@ -0,0 +1,212 @@
+/*
+ *
1 - 100 of 404 matches
Mail list logo
