Github user shahidki31 commented on a diff in the pull request:
https://github.com/apache/spark/pull/23038#discussion_r234400684
--- Diff:
core/src/main/scala/org/apache/spark/status/AppStatusListener.scala ---
@@ -565,7 +567,11 @@ private[spark] class AppStatusListener(
Github user shahidki31 commented on a diff in the pull request:
https://github.com/apache/spark/pull/23038#discussion_r234399022
--- Diff:
core/src/test/scala/org/apache/spark/status/AppStatusListenerSuite.scala ---
@@ -1275,6 +1275,49 @@ class AppStatusListenerSuite extends
Github user shahidki31 commented on a diff in the pull request:
https://github.com/apache/spark/pull/23038#discussion_r234399018
--- Diff:
core/src/test/scala/org/apache/spark/status/AppStatusListenerSuite.scala ---
@@ -1275,6 +1275,49 @@ class AppStatusListenerSuite extends
Github user shahidki31 commented on a diff in the pull request:
https://github.com/apache/spark/pull/23038#discussion_r234399010
--- Diff:
core/src/test/scala/org/apache/spark/status/AppStatusListenerSuite.scala ---
@@ -1275,6 +1275,49 @@ class AppStatusListenerSuite extends
Github user shahidki31 commented on a diff in the pull request:
https://github.com/apache/spark/pull/23038#discussion_r234399006
--- Diff:
core/src/test/scala/org/apache/spark/status/AppStatusListenerSuite.scala ---
@@ -1275,6 +1275,49 @@ class AppStatusListenerSuite extends
Github user vanzin commented on a diff in the pull request:
https://github.com/apache/spark/pull/23038#discussion_r234382254
--- Diff:
core/src/test/scala/org/apache/spark/status/AppStatusListenerSuite.scala ---
@@ -1275,6 +1275,49 @@ class AppStatusListenerSuite extends
Github user vanzin commented on a diff in the pull request:
https://github.com/apache/spark/pull/23038#discussion_r234382145
--- Diff:
core/src/test/scala/org/apache/spark/status/AppStatusListenerSuite.scala ---
@@ -1275,6 +1275,49 @@ class AppStatusListenerSuite extends
Github user vanzin commented on a diff in the pull request:
https://github.com/apache/spark/pull/23038#discussion_r234382489
--- Diff:
core/src/main/scala/org/apache/spark/status/AppStatusListener.scala ---
@@ -565,7 +567,11 @@ private[spark] class AppStatusListener(
if
Github user vanzin commented on a diff in the pull request:
https://github.com/apache/spark/pull/23038#discussion_r234382208
--- Diff:
core/src/test/scala/org/apache/spark/status/AppStatusListenerSuite.scala ---
@@ -1275,6 +1275,49 @@ class AppStatusListenerSuite extends
Github user vanzin commented on a diff in the pull request:
https://github.com/apache/spark/pull/23038#discussion_r234382183
--- Diff:
core/src/test/scala/org/apache/spark/status/AppStatusListenerSuite.scala ---
@@ -1275,6 +1275,49 @@ class AppStatusListenerSuite extends
Github user shahidki31 commented on a diff in the pull request:
https://github.com/apache/spark/pull/23038#discussion_r234367532
--- Diff: core/src/main/scala/org/apache/spark/status/LiveEntity.scala ---
@@ -376,6 +376,8 @@ private class LiveStage extends LiveEntity {
Github user shahidki31 commented on a diff in the pull request:
https://github.com/apache/spark/pull/23038#discussion_r234340680
--- Diff: core/src/main/scala/org/apache/spark/status/LiveEntity.scala ---
@@ -376,6 +376,8 @@ private class LiveStage extends LiveEntity {
Github user shahidki31 commented on a diff in the pull request:
https://github.com/apache/spark/pull/23038#discussion_r234337780
--- Diff: core/src/main/scala/org/apache/spark/status/LiveEntity.scala ---
@@ -376,6 +376,8 @@ private class LiveStage extends LiveEntity {
Github user vanzin commented on a diff in the pull request:
https://github.com/apache/spark/pull/23038#discussion_r234311257
--- Diff: core/src/main/scala/org/apache/spark/status/LiveEntity.scala ---
@@ -376,6 +376,8 @@ private class LiveStage extends LiveEntity {
val
Github user shahidki31 commented on a diff in the pull request:
https://github.com/apache/spark/pull/23038#discussion_r234072070
--- Diff: core/src/main/scala/org/apache/spark/status/api/v1/api.scala ---
@@ -63,6 +63,7 @@ case class ApplicationAttemptInfo private[spark](
Github user shahidki31 commented on a diff in the pull request:
https://github.com/apache/spark/pull/23038#discussion_r234034325
--- Diff: core/src/main/scala/org/apache/spark/status/api/v1/api.scala ---
@@ -63,6 +63,7 @@ case class ApplicationAttemptInfo private[spark](
Github user vanzin commented on a diff in the pull request:
https://github.com/apache/spark/pull/23038#discussion_r234032990
--- Diff: core/src/main/scala/org/apache/spark/status/api/v1/api.scala ---
@@ -63,6 +63,7 @@ case class ApplicationAttemptInfo private[spark](
Github user shahidki31 commented on a diff in the pull request:
https://github.com/apache/spark/pull/23038#discussion_r234032510
--- Diff: core/src/main/scala/org/apache/spark/status/api/v1/api.scala ---
@@ -63,6 +63,7 @@ case class ApplicationAttemptInfo private[spark](
Github user vanzin commented on a diff in the pull request:
https://github.com/apache/spark/pull/23038#discussion_r234028545
--- Diff: core/src/main/scala/org/apache/spark/status/api/v1/api.scala ---
@@ -63,6 +63,7 @@ case class ApplicationAttemptInfo private[spark](
GitHub user shahidki31 opened a pull request:
https://github.com/apache/spark/pull/23038
[SPARK-25451][CORE][WEBUI]Aggregated metrics table doesn't show the right
number of the total tasks
## What changes were proposed in this pull request?
Total tasks in the aggregated table
20 matches
Mail list logo
