Github user gatorsmile commented on the issue:
https://github.com/apache/spark/pull/15937
LGTM
Sorry, I did not catch this.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this
Github user gatorsmile commented on a diff in the pull request:
https://github.com/apache/spark/pull/15929#discussion_r88774814
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/predicates.scala
---
@@ -452,15 +444,7 @@ case class EqualNullSafe(left:
Github user gatorsmile commented on a diff in the pull request:
https://github.com/apache/spark/pull/15929#discussion_r88774467
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/codegen/CodeGenerator.scala
---
@@ -481,8 +481,13 @@ class
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/15937
**[Test build #68882 has
started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/68882/consoleFull)**
for PR 15937 at commit
GitHub user rxin opened a pull request:
https://github.com/apache/spark/pull/15937
[SQL] Fix documentation error for DateDiff
## What changes were proposed in this pull request?
The previous documentation and example for DateDiff was wrong.
## How was this patch tested?
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/15901
Merged build finished. Test PASSed.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/15901
Test PASSed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berkeley.edu/jenkins//job/SparkPullRequestBuilder/68881/
Test PASSed.
---
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/15901
**[Test build #68881 has
finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/68881/consoleFull)**
for PR 15901 at commit
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/15870
Merged build finished. Test PASSed.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/15870
Test PASSed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berkeley.edu/jenkins//job/SparkPullRequestBuilder/68879/
Test PASSed.
---
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/15870
**[Test build #68879 has
finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/68879/consoleFull)**
for PR 15870 at commit
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/15901
**[Test build #68881 has
started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/68881/consoleFull)**
for PR 15901 at commit
Github user viirya commented on the issue:
https://github.com/apache/spark/pull/15620
Looks like it is not flaky test. The test failure is due to compilation
error of janino: A local variable can not be accessed in the generated function.
---
If your project is set up for it, you
Github user wzhfy closed the pull request at:
https://github.com/apache/spark/pull/15637
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
Github user wzhfy commented on the issue:
https://github.com/apache/spark/pull/15637
Since the JIRA is closed, I'm closing this PR too.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this
Github user viirya commented on a diff in the pull request:
https://github.com/apache/spark/pull/15901#discussion_r88770786
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/objects/objects.scala
---
@@ -82,8 +148,8 @@ case class StaticInvoke(
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/15874
Test PASSed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berkeley.edu/jenkins//job/SparkPullRequestBuilder/68880/
Test PASSed.
---
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/15874
**[Test build #68880 has
finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/68880/consoleFull)**
for PR 15874 at commit
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/15874
Merged build finished. Test PASSed.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
Github user wzhfy commented on a diff in the pull request:
https://github.com/apache/spark/pull/15877#discussion_r88770530
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/CountMinSketchAgg.scala
---
@@ -0,0 +1,150 @@
+/*
+ *
Github user gatorsmile commented on a diff in the pull request:
https://github.com/apache/spark/pull/15929#discussion_r88770432
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/codegen/CodeGenerator.scala
---
@@ -481,8 +481,13 @@ class
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/15901
Merged build finished. Test PASSed.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/15901
Test PASSed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berkeley.edu/jenkins//job/SparkPullRequestBuilder/68877/
Test PASSed.
---
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/15901
**[Test build #68877 has
finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/68877/consoleFull)**
for PR 15901 at commit
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/13065
Test PASSed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berkeley.edu/jenkins//job/SparkPullRequestBuilder/68876/
Test PASSed.
---
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/13065
Merged build finished. Test PASSed.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/13065
**[Test build #68876 has
finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/68876/consoleFull)**
for PR 13065 at commit
Github user viirya closed the pull request at:
https://github.com/apache/spark/pull/15596
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
Github user viirya commented on the issue:
https://github.com/apache/spark/pull/15596
I'd close this now.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so,
Github user viirya commented on the issue:
https://github.com/apache/spark/pull/15837
ping @cloud-fan @hvanhovell @kiszk Can you help review this? Thanks.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project
Github user gatorsmile commented on the issue:
https://github.com/apache/spark/pull/15880
The [official Hive
document](https://cwiki.apache.org/confluence/display/Hive/LanguageManual+Types#LanguageManualTypes-AllowedImplicitConversions)
explains the implicit type casting rules.
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/15874
**[Test build #68880 has
started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/68880/consoleFull)**
for PR 15874 at commit
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/15870
**[Test build #68879 has
started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/68879/consoleFull)**
for PR 15870 at commit
Github user Yunni commented on the issue:
https://github.com/apache/spark/pull/15874
Hi @sethah, grouping to a number of buckets does not really affect the
independence since p is a mach larger prime. For example, in
http://people.csail.mit.edu/mip/papers/kwise-lb/kwise-lb.pdf, they
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/15935
Merged build finished. Test PASSed.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/15935
Test PASSed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berkeley.edu/jenkins//job/SparkPullRequestBuilder/68874/
Test PASSed.
---
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/15935
**[Test build #68874 has
finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/68874/consoleFull)**
for PR 15935 at commit
Github user dbtsai commented on a diff in the pull request:
https://github.com/apache/spark/pull/15893#discussion_r88767607
--- Diff:
mllib/src/main/scala/org/apache/spark/ml/classification/LogisticRegression.scala
---
@@ -586,15 +577,24 @@ class LogisticRegression
Github user JoshRosen commented on a diff in the pull request:
https://github.com/apache/spark/pull/15923#discussion_r88767299
--- Diff:
core/src/main/scala/org/apache/spark/storage/ShuffleBlockFetcherIterator.scala
---
@@ -305,40 +312,82 @@ final class
Github user JoshRosen commented on a diff in the pull request:
https://github.com/apache/spark/pull/15923#discussion_r88767669
--- Diff:
core/src/main/scala/org/apache/spark/storage/ShuffleBlockFetcherIterator.scala
---
@@ -305,40 +312,82 @@ final class
Github user JoshRosen commented on a diff in the pull request:
https://github.com/apache/spark/pull/15923#discussion_r88767018
--- Diff:
core/src/main/scala/org/apache/spark/storage/ShuffleBlockFetcherIterator.scala
---
@@ -56,8 +59,10 @@ final class ShuffleBlockFetcherIterator(
Github user JoshRosen commented on a diff in the pull request:
https://github.com/apache/spark/pull/15923#discussion_r88767390
--- Diff:
core/src/main/scala/org/apache/spark/storage/ShuffleBlockFetcherIterator.scala
---
@@ -305,40 +312,82 @@ final class
Github user JoshRosen commented on a diff in the pull request:
https://github.com/apache/spark/pull/15923#discussion_r88767352
--- Diff:
core/src/main/scala/org/apache/spark/storage/ShuffleBlockFetcherIterator.scala
---
@@ -305,40 +312,82 @@ final class
Github user dbtsai commented on the issue:
https://github.com/apache/spark/pull/15893
Only minor naming. LGTM. My interest can not access ssh to merge the code,
will merge later tonight. Thanks.
---
If your project is set up for it, you can reply to this email and have your
reply
Github user dongjoon-hyun commented on the issue:
https://github.com/apache/spark/pull/15891
Maybe, could you close this? @hvanhovell ;)
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this
Github user viirya commented on the issue:
https://github.com/apache/spark/pull/15916
@hvanhovell @rxin What do you think? Please let me know if we need this or
not. Thanks.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/13065
Merged build finished. Test PASSed.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/13065
Test PASSed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berkeley.edu/jenkins//job/SparkPullRequestBuilder/68875/
Test PASSed.
---
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/13065
**[Test build #68875 has
finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/68875/consoleFull)**
for PR 13065 at commit
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/15820
Merged build finished. Test PASSed.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
Github user JoshRosen commented on the issue:
https://github.com/apache/spark/pull/14854
Another advantage of this PR's approach is straggler-resilience: imagine
that you're going to have to compute all partitions anyways and also assume
that some small number of partitions will
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/15820
Test PASSed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berkeley.edu/jenkins//job/SparkPullRequestBuilder/68878/
Test PASSed.
---
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/15820
**[Test build #68878 has
finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/68878/consoleFull)**
for PR 15820 at commit
Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/15820#discussion_r88765764
--- Diff:
external/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/CachedKafkaConsumer.scala
---
@@ -47,40 +51,190 @@ private[kafka010] case class
Github user asfgit closed the pull request at:
https://github.com/apache/spark/pull/15933
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
Github user asfgit closed the pull request at:
https://github.com/apache/spark/pull/15934
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
Github user lw-lin commented on the issue:
https://github.com/apache/spark/pull/15870
@zsxwing thanks. I'm rebasing right now.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
Github user rxin commented on the issue:
https://github.com/apache/spark/pull/15933
Merging in master/branch-2.1.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and
Github user lw-lin closed the pull request at:
https://github.com/apache/spark/pull/15828
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
Github user tdas commented on the issue:
https://github.com/apache/spark/pull/15934
Seems like this is a correctness bug as aggregation will give wrong results
when using aggregations.
---
If your project is set up for it, you can reply to this email and have your
reply appear on
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/15934
Merged build finished. Test PASSed.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
Github user JoshRosen commented on the issue:
https://github.com/apache/spark/pull/14854
I thought of one significant UX improvement offered by the approach in this
withdrawn PR: when the current "multiple jobs" limit executes, there's no way
for the end user to know how much work
Github user marmbrus commented on the issue:
https://github.com/apache/spark/pull/15933
LGTM
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/15934
Test PASSed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berkeley.edu/jenkins//job/SparkPullRequestBuilder/68873/
Test PASSed.
---
Github user felixcheung commented on the issue:
https://github.com/apache/spark/pull/15932
Great!
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if
Github user tdas commented on the issue:
https://github.com/apache/spark/pull/15934
Merging to master, 2.1 and 2.0
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/15933
Test PASSed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berkeley.edu/jenkins//job/SparkPullRequestBuilder/68872/
Test PASSed.
---
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/15934
**[Test build #68873 has
finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/68873/consoleFull)**
for PR 15934 at commit
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/15933
Merged build finished. Test PASSed.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
Github user maropu commented on the issue:
https://github.com/apache/spark/pull/14812
@gatorsmile Do u have time to check this? Thanks!
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/15933
**[Test build #68872 has
finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/68872/consoleFull)**
for PR 15933 at commit
Github user felixcheung commented on a diff in the pull request:
https://github.com/apache/spark/pull/15910#discussion_r88764190
--- Diff: R/pkg/inst/tests/testthat/test_mllib.R ---
@@ -674,6 +674,16 @@ test_that("spark.logit", {
expect_error(summary(blr_model2))
Github user hvanhovell commented on a diff in the pull request:
https://github.com/apache/spark/pull/15929#discussion_r88764135
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/codegen/CodeGenerator.scala
---
@@ -481,8 +481,13 @@ class
Github user felixcheung commented on a diff in the pull request:
https://github.com/apache/spark/pull/15910#discussion_r88764104
--- Diff: R/pkg/inst/tests/testthat/test_mllib.R ---
@@ -637,31 +637,31 @@ test_that("spark.isotonicRegression", {
test_that("spark.logit", {
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/15820
**[Test build #68878 has
started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/68878/consoleFull)**
for PR 15820 at commit
Github user felixcheung commented on a diff in the pull request:
https://github.com/apache/spark/pull/15888#discussion_r88763342
--- Diff: R/pkg/R/sparkR.R ---
@@ -373,8 +373,13 @@ sparkR.session <- function(
overrideEnvs(sparkConfigMap, paramMap)
}
+
Github user gatorsmile commented on the issue:
https://github.com/apache/spark/pull/15868
LGTM
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the
Github user asfgit closed the pull request at:
https://github.com/apache/spark/pull/15911
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
Github user felixcheung commented on the issue:
https://github.com/apache/spark/pull/15888
looks good. We don't have this but how about adding tests for
`sparkCheckInstall`? we could at least check for the error cases it has right
now?
---
If your project is set up for it, you can
Github user gatorsmile commented on a diff in the pull request:
https://github.com/apache/spark/pull/15929#discussion_r88763155
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/codegen/CodeGenerator.scala
---
@@ -481,8 +481,13 @@ class
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/15868
Test PASSed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berkeley.edu/jenkins//job/SparkPullRequestBuilder/68871/
Test PASSed.
---
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/15868
Merged build finished. Test PASSed.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/15868
**[Test build #68871 has
finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/68871/consoleFull)**
for PR 15868 at commit
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/15901
**[Test build #68877 has
started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/68877/consoleFull)**
for PR 15901 at commit
Github user sethah commented on the issue:
https://github.com/apache/spark/pull/15874
@jkbradley Thanks for checking that, that is the conclusion I drew as well.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your
Github user tdas commented on the issue:
https://github.com/apache/spark/pull/15911
LGTM. Merging to master, 2.1, and 2.0
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled
Github user sethah commented on a diff in the pull request:
https://github.com/apache/spark/pull/15874#discussion_r88753014
--- Diff: mllib/src/main/scala/org/apache/spark/ml/feature/MinHashLSH.scala
---
@@ -31,36 +31,40 @@ import org.apache.spark.sql.types.StructType
/**
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/13065
**[Test build #68876 has
started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/68876/consoleFull)**
for PR 13065 at commit
Github user davies commented on a diff in the pull request:
https://github.com/apache/spark/pull/15923#discussion_r88759884
--- Diff:
core/src/main/scala/org/apache/spark/storage/ShuffleBlockFetcherIterator.scala
---
@@ -305,40 +312,82 @@ final class ShuffleBlockFetcherIterator(
Github user davies commented on a diff in the pull request:
https://github.com/apache/spark/pull/15923#discussion_r88759763
--- Diff:
core/src/main/scala/org/apache/spark/storage/ShuffleBlockFetcherIterator.scala
---
@@ -305,40 +312,82 @@ final class ShuffleBlockFetcherIterator(
Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/15820#discussion_r88759061
--- Diff:
external/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaSourceSuite.scala
---
@@ -223,52 +228,184 @@ class KafkaSourceSuite
Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/15820#discussion_r88759005
--- Diff:
external/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaSourceSuite.scala
---
@@ -223,52 +228,184 @@ class KafkaSourceSuite
Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/15820#discussion_r88758879
--- Diff:
external/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaSourceSuite.scala
---
@@ -223,52 +228,184 @@ class KafkaSourceSuite
Github user cmirash commented on the issue:
https://github.com/apache/spark/pull/15594
Thanks Luciano. I am looking at the changes and will add them soon.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project
Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/15820#discussion_r88758556
--- Diff:
external/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaSourceSuite.scala
---
@@ -626,3 +776,106 @@ class KafkaSourceStressSuite
Github user kayousterhout commented on a diff in the pull request:
https://github.com/apache/spark/pull/15644#discussion_r88757732
--- Diff:
core/src/test/scala/org/apache/spark/scheduler/TaskSchedulerImplSuite.scala ---
@@ -282,6 +316,211 @@ class TaskSchedulerImplSuite extends
Github user kayousterhout commented on a diff in the pull request:
https://github.com/apache/spark/pull/15644#discussion_r88758268
--- Diff:
core/src/test/scala/org/apache/spark/scheduler/TaskSchedulerImplSuite.scala ---
@@ -282,6 +316,211 @@ class TaskSchedulerImplSuite extends
Github user kayousterhout commented on a diff in the pull request:
https://github.com/apache/spark/pull/15644#discussion_r88755426
--- Diff:
core/src/test/scala/org/apache/spark/scheduler/TaskSchedulerImplSuite.scala ---
@@ -282,6 +316,211 @@ class TaskSchedulerImplSuite extends
Github user kayousterhout commented on a diff in the pull request:
https://github.com/apache/spark/pull/15644#discussion_r88758327
--- Diff:
core/src/test/scala/org/apache/spark/scheduler/TaskSetManagerSuite.scala ---
@@ -992,6 +994,47 @@ class TaskSetManagerSuite extends
Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/15820#discussion_r88758444
--- Diff:
external/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/CachedKafkaConsumer.scala
---
@@ -47,40 +51,191 @@ private[kafka010] case class
1 - 100 of 405 matches
Mail list logo
