Github user cfangplus commented on a diff in the pull request:
https://github.com/apache/spark/pull/22335#discussion_r216123919
--- Diff: core/src/main/scala/org/apache/spark/status/LiveEntity.scala ---
@@ -33,7 +29,9 @@ import org.apache.spark.storage.RDDInfo
import
Github user cfangplus commented on a diff in the pull request:
https://github.com/apache/spark/pull/22335#discussion_r216123864
--- Diff:
core/src/main/scala/org/apache/spark/status/AppStatusListener.scala ---
@@ -646,8 +646,17 @@ private[spark] class AppStatusListener(
}
Github user cfangplus commented on a diff in the pull request:
https://github.com/apache/spark/pull/22335#discussion_r216123775
--- Diff:
core/src/main/scala/org/apache/spark/status/AppStatusListener.scala ---
@@ -710,9 +719,21 @@ private[spark] class AppStatusListener(
Github user kiszk commented on a diff in the pull request:
https://github.com/apache/spark/pull/22335#discussion_r215452975
--- Diff:
core/src/main/scala/org/apache/spark/status/AppStatusListener.scala ---
@@ -646,8 +646,17 @@ private[spark] class AppStatusListener(
}
Github user vanzin commented on a diff in the pull request:
https://github.com/apache/spark/pull/22335#discussion_r215359589
--- Diff: core/src/main/scala/org/apache/spark/status/LiveEntity.scala ---
@@ -509,6 +507,10 @@ 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/22335#discussion_r215360659
--- Diff:
core/src/main/scala/org/apache/spark/status/AppStatusListener.scala ---
@@ -710,9 +719,21 @@ private[spark] class AppStatusListener(
val
Github user vanzin commented on a diff in the pull request:
https://github.com/apache/spark/pull/22335#discussion_r215360036
--- Diff: core/src/main/scala/org/apache/spark/storage/BlockManager.scala
---
@@ -1549,7 +1549,7 @@ private[spark] class BlockManager(
// TODO:
Github user vanzin commented on a diff in the pull request:
https://github.com/apache/spark/pull/22335#discussion_r215359111
--- Diff: core/src/main/scala/org/apache/spark/status/LiveEntity.scala ---
@@ -120,7 +118,7 @@ private class LiveTask(
stageAttemptId: Int,
Github user vanzin commented on a diff in the pull request:
https://github.com/apache/spark/pull/22335#discussion_r215358096
--- Diff:
core/src/main/scala/org/apache/spark/status/AppStatusListener.scala ---
@@ -646,8 +646,17 @@ private[spark] class AppStatusListener(
}
Github user kiszk commented on a diff in the pull request:
https://github.com/apache/spark/pull/22335#discussion_r215149786
--- Diff:
core/src/main/scala/org/apache/spark/status/AppStatusListener.scala ---
@@ -646,8 +646,17 @@ private[spark] class AppStatusListener(
}
Github user kiszk commented on a diff in the pull request:
https://github.com/apache/spark/pull/22335#discussion_r215147974
--- Diff: core/src/main/scala/org/apache/spark/status/LiveEntity.scala ---
@@ -33,7 +29,9 @@ import org.apache.spark.storage.RDDInfo
import
GitHub user cfangplus opened a pull request:
https://github.com/apache/spark/pull/22335
[SPARK-25091][SQL] reduce the storage memory in Executor Tab when â¦
â¦unpersist rdd
@zsxwing
@vanzin
@attilapiros
## What changes were proposed in this pull request?
12 matches
Mail list logo