Github user vanzin closed the pull request at:
https://github.com/apache/spark/pull/19750
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
Github user vanzin commented on a diff in the pull request:
https://github.com/apache/spark/pull/19750#discussion_r151288363
--- Diff: core/src/main/scala/org/apache/spark/SparkStatusTracker.scala ---
@@ -89,39 +83,33 @@ class SparkStatusTracker private[spark] (sc:
SparkContext) {
Github user ajbozarth commented on a diff in the pull request:
https://github.com/apache/spark/pull/19750#discussion_r151288247
--- Diff:
core/src/main/scala/org/apache/spark/deploy/history/FsHistoryProvider.scala ---
@@ -315,48 +315,43 @@ private[history] class
Github user ajbozarth commented on a diff in the pull request:
https://github.com/apache/spark/pull/19750#discussion_r151288302
--- Diff:
core/src/main/scala/org/apache/spark/status/AppStatusListener.scala ---
@@ -563,7 +575,7 @@ private[spark] class AppStatusListener(
/**
Github user vanzin commented on a diff in the pull request:
https://github.com/apache/spark/pull/19750#discussion_r151287944
--- Diff: core/src/main/scala/org/apache/spark/TestUtils.scala ---
@@ -232,6 +232,30 @@ private[spark] object TestUtils {
}
}
+
Github user vanzin commented on a diff in the pull request:
https://github.com/apache/spark/pull/19750#discussion_r151287705
--- Diff:
core/src/main/scala/org/apache/spark/deploy/history/FsHistoryProvider.scala ---
@@ -315,48 +315,43 @@ private[history] class
Github user vanzin commented on a diff in the pull request:
https://github.com/apache/spark/pull/19750#discussion_r151287617
--- Diff:
core/src/main/scala/org/apache/spark/status/AppStatusListener.scala ---
@@ -563,7 +575,7 @@ private[spark] class AppStatusListener(
/**
Github user ajbozarth commented on a diff in the pull request:
https://github.com/apache/spark/pull/19750#discussion_r151283135
--- Diff:
core/src/main/scala/org/apache/spark/status/AppStatusListener.scala ---
@@ -563,7 +575,7 @@ private[spark] class AppStatusListener(
/**
Github user ajbozarth commented on a diff in the pull request:
https://github.com/apache/spark/pull/19750#discussion_r151281491
--- Diff: core/src/main/scala/org/apache/spark/SparkStatusTracker.scala ---
@@ -89,39 +83,33 @@ class SparkStatusTracker private[spark] (sc:
Github user ajbozarth commented on a diff in the pull request:
https://github.com/apache/spark/pull/19750#discussion_r151281951
--- Diff: core/src/main/scala/org/apache/spark/TestUtils.scala ---
@@ -232,6 +232,30 @@ private[spark] object TestUtils {
}
}
+
Github user ajbozarth commented on a diff in the pull request:
https://github.com/apache/spark/pull/19750#discussion_r151282422
--- Diff:
core/src/main/scala/org/apache/spark/deploy/history/FsHistoryProvider.scala ---
@@ -315,48 +315,43 @@ private[history] class
GitHub user vanzin opened a pull request:
https://github.com/apache/spark/pull/19750
[SPARK-20650][core] Remove JobProgressListener.
The only remaining use of this class was the SparkStatusTracker, which
was modified to use the new status store. The test code to wait for
12 matches
Mail list logo
