Github user asfgit closed the pull request at:
https://github.com/apache/spark/pull/22341
---
-
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/22341#discussion_r216741392
--- Diff: core/src/main/scala/org/apache/spark/status/LiveEntity.scala ---
@@ -538,6 +538,10 @@ private class LiveRDD(val info: RDDInfo) extends
LiveEntity
Github user viirya commented on a diff in the pull request:
https://github.com/apache/spark/pull/22341#discussion_r216574255
--- Diff:
core/src/main/scala/org/apache/spark/status/AppStatusListener.scala ---
@@ -646,7 +647,47 @@ private[spark] class AppStatusListener(
}
Github user vanzin commented on a diff in the pull request:
https://github.com/apache/spark/pull/22341#discussion_r216523989
--- Diff:
core/src/main/scala/org/apache/spark/status/AppStatusListener.scala ---
@@ -646,7 +647,47 @@ private[spark] class AppStatusListener(
}
Github user vanzin commented on a diff in the pull request:
https://github.com/apache/spark/pull/22341#discussion_r216523824
--- Diff: core/src/main/scala/org/apache/spark/status/LiveEntity.scala ---
@@ -538,6 +538,14 @@ private class LiveRDD(val info: RDDInfo) extends
LiveEntity
Github user viirya commented on a diff in the pull request:
https://github.com/apache/spark/pull/22341#discussion_r216514947
--- Diff:
core/src/main/scala/org/apache/spark/status/AppStatusListener.scala ---
@@ -646,7 +647,47 @@ private[spark] class AppStatusListener(
}
Github user viirya commented on a diff in the pull request:
https://github.com/apache/spark/pull/22341#discussion_r216513548
--- Diff: core/src/main/scala/org/apache/spark/status/LiveEntity.scala ---
@@ -538,6 +538,14 @@ private class LiveRDD(val info: RDDInfo) extends
LiveEntity
Github user vanzin commented on a diff in the pull request:
https://github.com/apache/spark/pull/22341#discussion_r216513137
--- Diff: core/src/main/scala/org/apache/spark/status/LiveEntity.scala ---
@@ -538,6 +538,14 @@ private class LiveRDD(val info: RDDInfo) extends
LiveEntity
Github user viirya commented on a diff in the pull request:
https://github.com/apache/spark/pull/22341#discussion_r216512185
--- Diff:
core/src/main/scala/org/apache/spark/status/AppStatusListener.scala ---
@@ -646,7 +647,47 @@ private[spark] class AppStatusListener(
}
Github user viirya commented on a diff in the pull request:
https://github.com/apache/spark/pull/22341#discussion_r216511718
--- Diff: core/src/main/scala/org/apache/spark/status/LiveEntity.scala ---
@@ -538,6 +538,14 @@ private class LiveRDD(val info: RDDInfo) extends
LiveEntity
Github user vanzin commented on a diff in the pull request:
https://github.com/apache/spark/pull/22341#discussion_r216406188
--- Diff:
core/src/main/scala/org/apache/spark/status/AppStatusListener.scala ---
@@ -646,7 +647,47 @@ private[spark] class AppStatusListener(
}
Github user vanzin commented on a diff in the pull request:
https://github.com/apache/spark/pull/22341#discussion_r216404844
--- Diff:
core/src/main/scala/org/apache/spark/status/AppStatusListener.scala ---
@@ -23,6 +23,7 @@ import java.util.function.Function
import
Github user vanzin commented on a diff in the pull request:
https://github.com/apache/spark/pull/22341#discussion_r216405553
--- Diff:
core/src/main/scala/org/apache/spark/status/AppStatusListener.scala ---
@@ -646,7 +647,47 @@ private[spark] class AppStatusListener(
}
Github user vanzin commented on a diff in the pull request:
https://github.com/apache/spark/pull/22341#discussion_r216407616
--- Diff: core/src/main/scala/org/apache/spark/status/LiveEntity.scala ---
@@ -538,6 +538,14 @@ private class LiveRDD(val info: RDDInfo) extends
LiveEntity
Github user vanzin commented on a diff in the pull request:
https://github.com/apache/spark/pull/22341#discussion_r216406902
--- Diff:
core/src/main/scala/org/apache/spark/status/AppStatusListener.scala ---
@@ -646,7 +647,47 @@ private[spark] class AppStatusListener(
}
Github user viirya commented on a diff in the pull request:
https://github.com/apache/spark/pull/22341#discussion_r216257678
--- Diff:
core/src/main/scala/org/apache/spark/status/AppStatusListener.scala ---
@@ -646,7 +647,47 @@ private[spark] class AppStatusListener(
}
Github user cfangplus commented on a diff in the pull request:
https://github.com/apache/spark/pull/22341#discussion_r216127013
--- Diff:
core/src/main/scala/org/apache/spark/status/AppStatusListener.scala ---
@@ -646,7 +647,47 @@ private[spark] class AppStatusListener(
}
Github user xuanyuanking commented on a diff in the pull request:
https://github.com/apache/spark/pull/22341#discussion_r215318105
--- Diff: core/src/main/scala/org/apache/spark/storage/RDDInfo.scala ---
@@ -55,7 +55,7 @@ class RDDInfo(
}
private[spark] object
Github user viirya commented on a diff in the pull request:
https://github.com/apache/spark/pull/22341#discussion_r215300948
--- Diff: core/src/main/scala/org/apache/spark/storage/RDDInfo.scala ---
@@ -55,7 +55,7 @@ class RDDInfo(
}
private[spark] object RDDInfo {
Github user xuanyuanking commented on a diff in the pull request:
https://github.com/apache/spark/pull/22341#discussion_r215285275
--- Diff: core/src/main/scala/org/apache/spark/storage/RDDInfo.scala ---
@@ -55,7 +55,7 @@ class RDDInfo(
}
private[spark] object
GitHub user viirya opened a pull request:
https://github.com/apache/spark/pull/22341
[SPARK-24889][Core] Update block info when unpersist rdds
## What changes were proposed in this pull request?
We will update block info coming from executors, at the timing like caching
a
21 matches
Mail list logo
