Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/15432
**[Test build #66738 has
finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/66738/consoleFull)**
for PR 15432 at commit
Github user hellertime commented on the issue:
https://github.com/apache/spark/pull/12933
Fixed scala style error
---
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/15433
Test FAILed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berkeley.edu/jenkins//job/SparkPullRequestBuilder/66742/
Test FAILed.
---
Github user falaki commented on a diff in the pull request:
https://github.com/apache/spark/pull/15421#discussion_r82814431
--- Diff: R/pkg/DESCRIPTION ---
@@ -11,7 +11,8 @@ Authors@R: c(person("Shivaram", "Venkataraman", role =
c("aut", "cre"),
email =
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/15434
**[Test build #66744 has
started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/66744/consoleFull)**
for PR 15434 at commit
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/15421
**[Test build #66745 has
started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/66745/consoleFull)**
for PR 15421 at commit
Github user mridulm commented on a diff in the pull request:
https://github.com/apache/spark/pull/15408#discussion_r82816160
--- Diff:
core/src/main/java/org/apache/spark/io/NioBufferedFileInputStream.java ---
@@ -0,0 +1,129 @@
+/*
+ * Licensed under the Apache License,
Github user squito commented on the issue:
https://github.com/apache/spark/pull/15249
@kayousterhout good idea about running performance tests, I hadn't run them
on a recent rev. I confirmed that the issue in
https://github.com/apache/spark/pull/14871 was no longer present (just to
Github user sethah commented on the issue:
https://github.com/apache/spark/pull/9
@MLnick Good questions. For the setting of params - I'm sure it varies in
some cases, but for example, why would you want to use the same `maxIter` when
training with an initial model vs without? I
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/12064
**[Test build #66743 has
finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/66743/consoleFull)**
for PR 12064 at commit
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/12064
Test PASSed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berkeley.edu/jenkins//job/SparkPullRequestBuilder/66743/
Test PASSed.
---
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/12064
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 tgravescs commented on the issue:
https://github.com/apache/spark/pull/15410
while I understand the problem, the issue here is that what you are
printing might not be accurate either. We only pull for new logs every X
number of seconds (default is 10s, user could change
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/15433
Merged build finished. Test FAILed.
---
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/15421
**[Test build #66746 has
started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/66746/consoleFull)**
for PR 15421 at commit
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/14719
**[Test build #66747 has
started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/66747/consoleFull)**
for PR 14719 at commit
GitHub user cloud-fan opened a pull request:
https://github.com/apache/spark/pull/15434
[SPARK-17873][SQL] ALTER TABLE RENAME TO should allow users to specify
database in destination table name
## What changes were proposed in this pull request?
In #14955 , we forbid users
Github user cloud-fan commented on the issue:
https://github.com/apache/spark/pull/15434
cc @yhuai @gatorsmile
---
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
Github user sethah commented on the issue:
https://github.com/apache/spark/pull/15342
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 k-yokoshi commented on a diff in the pull request:
https://github.com/apache/spark/pull/13036#discussion_r82816487
--- Diff: python/pyspark/sql/dataframe.py ---
@@ -470,7 +470,7 @@ def sampleBy(self, col, fractions, seed=None):
+---+-+
Github user dilipbiswal commented on a diff in the pull request:
https://github.com/apache/spark/pull/15423#discussion_r82817760
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/SQLQueryTestSuite.scala ---
@@ -207,6 +208,7 @@ class SQLQueryTestSuite extends QueryTest with
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/15433
**[Test build #66742 has
finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/66742/consoleFull)**
for PR 15433 at commit
Github user dilipbiswal commented on a diff in the pull request:
https://github.com/apache/spark/pull/15423#discussion_r82818691
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/SparkSqlParser.scala ---
@@ -168,17 +168,7 @@ class SparkSqlAstBuilder(conf: SQLConf)
Github user shivaram commented on the issue:
https://github.com/apache/spark/pull/15433
@techaddict Thanks for the PR. The test failures seem related to this patch
-- Could you check why they are failing ?
---
If your project is set up for it, you can reply to this email and have
Github user MechCoder commented on the issue:
https://github.com/apache/spark/pull/7963
Thanks for the reviews @holdenk . Unfortunately I will not be able to work
on this anytime soon. Feel free to cherry-pick the commits, (if you wish)
---
If your project is set up for it, you can
Github user yhuai commented on the issue:
https://github.com/apache/spark/pull/15434
Can you update the description to explain if `ALTER TABLE db1.tbl RENAME TO
db2.tbl2` is allowed (I guess it is not allowed)?
---
If your project is set up for it, you can reply to this email and
Github user hellertime commented on the issue:
https://github.com/apache/spark/pull/12933
@tnachen rebased with master
---
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 SparkQA commented on the issue:
https://github.com/apache/spark/pull/12933
**[Test build #66741 has
started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/66741/consoleFull)**
for PR 12933 at commit
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/15432
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/15432
Test PASSed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berkeley.edu/jenkins//job/SparkPullRequestBuilder/66738/
Test PASSed.
---
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/15432
**[Test build #66737 has
finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/66737/consoleFull)**
for PR 15432 at commit
GitHub user techaddict opened a pull request:
https://github.com/apache/spark/pull/15433
[SPARK-17822] Use weak reference in JVMObjectTracker.objMap because it may
leak JVM objects
## What changes were proposed in this pull request?
Use weak reference in JVMObjectTracker.objMap
Github user yanboliang commented on the issue:
https://github.com/apache/spark/pull/15431
cc @felixcheung @jkbradley
---
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 yanboliang commented on the issue:
https://github.com/apache/spark/pull/15430
cc @jkbradley
---
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 AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/12933
Merged build finished. Test FAILed.
---
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/12933
Merged build finished. Test FAILed.
---
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/15433
**[Test build #66742 has
started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/66742/consoleFull)**
for PR 15433 at commit
Github user vijoshi commented on a diff in the pull request:
https://github.com/apache/spark/pull/15410#discussion_r82789161
--- Diff:
core/src/main/scala/org/apache/spark/deploy/history/FsHistoryProvider.scala ---
@@ -316,24 +320,41 @@ private[history] class
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/15432
Test PASSed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berkeley.edu/jenkins//job/SparkPullRequestBuilder/66737/
Test PASSed.
---
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/15432
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 YuhuWang2002 commented on a diff in the pull request:
https://github.com/apache/spark/pull/15297#discussion_r82779299
--- Diff: core/src/main/scala/org/apache/spark/MapOutputTracker.scala ---
@@ -138,13 +138,16 @@ private[spark] abstract class MapOutputTracker(conf:
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/12064
**[Test build #66743 has
started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/66743/consoleFull)**
for PR 12064 at commit
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/15405
**[Test build #3323 has
finished](https://amplab.cs.berkeley.edu/jenkins/job/NewSparkPullRequestBuilder/3323/consoleFull)**
for PR 15405 at commit
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/12933
Test FAILed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berkeley.edu/jenkins//job/SparkPullRequestBuilder/66740/
Test FAILed.
---
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/12933
**[Test build #66740 has
started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/66740/consoleFull)**
for PR 12933 at commit
Github user YuhuWang2002 commented on a diff in the pull request:
https://github.com/apache/spark/pull/15297#discussion_r82779060
--- Diff: core/src/main/scala/org/apache/spark/MapOutputTracker.scala ---
@@ -687,18 +691,21 @@ private[spark] object MapOutputTracker extends
Logging
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/12933
**[Test build #66740 has
finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/66740/consoleFull)**
for PR 12933 at commit
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/12933
**[Test build #66741 has
finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/66741/consoleFull)**
for PR 12933 at commit
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/12933
Test FAILed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berkeley.edu/jenkins//job/SparkPullRequestBuilder/66741/
Test FAILed.
---
Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/15423#discussion_r82797867
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/SQLQueryTestSuite.scala ---
@@ -207,6 +208,7 @@ class SQLQueryTestSuite extends QueryTest with
Github user ericl commented on a diff in the pull request:
https://github.com/apache/spark/pull/14690#discussion_r82875191
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/DataSourceScanExec.scala
---
@@ -225,13 +225,16 @@ case class FileSourceScanExec(
}
Github user jodersky commented on a diff in the pull request:
https://github.com/apache/spark/pull/15338#discussion_r82866433
--- Diff: sbin/spark-daemon.sh ---
@@ -122,6 +123,35 @@ if [ "$SPARK_NICENESS" = "" ]; then
export SPARK_NICENESS=0
fi
Github user jodersky commented on a diff in the pull request:
https://github.com/apache/spark/pull/15338#discussion_r82874206
--- Diff: sbin/spark-daemon.sh ---
@@ -146,13 +176,11 @@ run_command() {
case "$mode" in
(class)
- nohup nice -n
Github user gatorsmile commented on the issue:
https://github.com/apache/spark/pull/15190
Added them to your test cases. : )
---
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/15436
Merged build finished. Test FAILed.
---
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/15438
cc @thunterdb, @hvanhovell, @davies
---
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 SparkQA commented on the issue:
https://github.com/apache/spark/pull/14959
**[Test build #66758 has
finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/66758/consoleFull)**
for PR 14959 at commit
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/14959
Test PASSed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berkeley.edu/jenkins//job/SparkPullRequestBuilder/66758/
Test PASSed.
---
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/14959
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 falaki commented on a diff in the pull request:
https://github.com/apache/spark/pull/11336#discussion_r82887849
--- Diff: R/pkg/R/column.R ---
@@ -32,35 +34,65 @@ setOldClass("jobj")
#' @export
#' @note Column since 1.4.0
setClass("Column",
-
Github user falaki commented on a diff in the pull request:
https://github.com/apache/spark/pull/11336#discussion_r82887445
--- Diff: R/pkg/R/DataFrame.R ---
@@ -1035,10 +1035,17 @@ setMethod("dim",
c(count(x), ncol(x))
})
-#' Collects all
Github user falaki commented on a diff in the pull request:
https://github.com/apache/spark/pull/11336#discussion_r82888061
--- Diff: R/pkg/R/column.R ---
@@ -32,35 +34,65 @@ setOldClass("jobj")
#' @export
#' @note Column since 1.4.0
setClass("Column",
-
Github user falaki commented on a diff in the pull request:
https://github.com/apache/spark/pull/11336#discussion_r82888215
--- Diff: R/pkg/inst/tests/testthat/test_sparkSQL.R ---
@@ -2252,6 +2252,31 @@ test_that("Method str()", {
Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/15307#discussion_r82855608
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamExecution.scala
---
@@ -516,12 +563,127 @@ class StreamExecution(
Github user koeninger commented on a diff in the pull request:
https://github.com/apache/spark/pull/15307#discussion_r82857280
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamMetrics.scala
---
@@ -0,0 +1,244 @@
+/*
+ * Licensed to the
Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/15307#discussion_r82858522
--- Diff: python/pyspark/sql/streaming.py ---
@@ -189,6 +189,282 @@ def resetTerminated(self):
self._jsqm.resetTerminated()
+class
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/14719
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/15421
**[Test build #66755 has
started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/66755/consoleFull)**
for PR 15421 at commit
Github user falaki commented on a diff in the pull request:
https://github.com/apache/spark/pull/15421#discussion_r82864117
--- Diff: core/src/main/scala/org/apache/spark/api/r/SerDe.scala ---
@@ -125,15 +125,24 @@ private[spark] object SerDe {
}
def
Github user wangmiao1981 commented on the issue:
https://github.com/apache/spark/pull/15421
@falaki I saw the exception on Mac too. But I don't find the root cause of
negative length in the input stream. Catching the exception will solve the
problem. Do you want to explore the reason
Github user falaki commented on the issue:
https://github.com/apache/spark/pull/15421
@wangmiao1981 thanks for testing on Windows. I added a check for this.
Would you please try again and let me know? Unfortunately, I don't have access
to a windows box for testing.
---
If your
Github user wangmiao1981 commented on the issue:
https://github.com/apache/spark/pull/15421
I think we should find out the root cause of the negative length of "NA"
field. Yesterday, I debugged R side and I have not found out the reason yet.
---
If your project is set up for it,
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/14788
**[Test build #66728 has
finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/66728/consoleFull)**
for PR 14788 at commit
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/14847
**[Test build #66730 has
finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/66730/consoleFull)**
for PR 14847 at commit
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/14788
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/14788
Test PASSed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berkeley.edu/jenkins//job/SparkPullRequestBuilder/66728/
Test PASSed.
---
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/14847
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/14847
Test PASSed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berkeley.edu/jenkins//job/SparkPullRequestBuilder/66730/
Test PASSed.
---
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/15429
**[Test build #66732 has
finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/66732/consoleFull)**
for PR 15429 at commit
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/15429
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/15429
Test PASSed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berkeley.edu/jenkins//job/SparkPullRequestBuilder/66732/
Test PASSed.
---
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/12064
**[Test build #66739 has
started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/66739/consoleFull)**
for PR 12064 at commit
Github user jiangxb1987 commented on the issue:
https://github.com/apache/spark/pull/15417
Yes - there are several tens of test sql that fails checkAnalysis, should
we update them all?
---
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/12064
Test FAILed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berkeley.edu/jenkins//job/SparkPullRequestBuilder/66739/
Test FAILed.
---
Github user zhengruifeng commented on the issue:
https://github.com/apache/spark/pull/15402
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 SparkQA commented on the issue:
https://github.com/apache/spark/pull/12064
**[Test build #66739 has
finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/66739/consoleFull)**
for PR 12064 at commit
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/12064
Merged build finished. Test FAILed.
---
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/15431
**[Test build #66736 has
finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/66736/consoleFull)**
for PR 15431 at commit
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/15431
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/15431
Test PASSed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berkeley.edu/jenkins//job/SparkPullRequestBuilder/66736/
Test PASSed.
---
Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/15307#discussion_r82890125
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamExecution.scala
---
@@ -176,7 +184,9 @@ class StreamExecution(
//
Github user olarayej commented on the issue:
https://github.com/apache/spark/pull/11336
@falaki Thanks for your comments. Yeah, before removing collect/show, I
just wanted to rebase to current upstream master. I'm getting a build error
which is actually a warning, not even an R
Github user davies commented on a diff in the pull request:
https://github.com/apache/spark/pull/15389#discussion_r82890280
--- Diff: python/pyspark/rdd.py ---
@@ -2029,7 +2028,15 @@ def coalesce(self, numPartitions, shuffle=False):
>>> sc.parallelize([1, 2, 3, 4, 5],
Github user SparkQA commented on the issue:
https://github.com/apache/spark/pull/15438
**[Test build #66762 has
started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/66762/consoleFull)**
for PR 15438 at commit
Github user brkyvz commented on a diff in the pull request:
https://github.com/apache/spark/pull/15307#discussion_r82890127
--- Diff: python/pyspark/sql/streaming.py ---
@@ -189,6 +189,282 @@ def resetTerminated(self):
self._jsqm.resetTerminated()
Github user brkyvz commented on a diff in the pull request:
https://github.com/apache/spark/pull/15307#discussion_r82890465
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamExecution.scala
---
@@ -105,11 +105,21 @@ class StreamExecution(
var
Github user brkyvz commented on a diff in the pull request:
https://github.com/apache/spark/pull/15307#discussion_r82890581
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamExecution.scala
---
@@ -516,12 +563,127 @@ class StreamExecution(
Github user davies commented on the issue:
https://github.com/apache/spark/pull/15389
Did not release that we already merged this, should we left a message here
or in the JIRA so we can know who merge this?
---
If your project is set up for it, you can reply to this email and have
Github user brkyvz commented on a diff in the pull request:
https://github.com/apache/spark/pull/15307#discussion_r82890911
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamMetrics.scala
---
@@ -0,0 +1,244 @@
+/*
+ * Licensed to the Apache
Github user rxin commented on the issue:
https://github.com/apache/spark/pull/15389
@felixcheung merged it I believe.
@felixcheung please make sure you leave a msg saying it's merged (along
with the branch) when you merge prs.
---
If your project is set up for it, you can
1 - 100 of 661 matches
Mail list logo
