diff options
| author | Daemoen <daemoen@ct-unlimited.com> | 2013-08-15 12:19:14 -0700 |
|---|---|---|
| committer | Daemoen <daemoen@ct-unlimited.com> | 2013-08-15 12:19:14 -0700 |
| commit | ad2e8b512654314d68f4b7c149950756943992be (patch) | |
| tree | a707e5bdb32c210f23c94e5c881fce3b8f342cae /core | |
| parent | 044a088c0db68220aae2dad425886b618bb0023f (diff) | |
| download | spark-ad2e8b512654314d68f4b7c149950756943992be.tar.gz spark-ad2e8b512654314d68f4b7c149950756943992be.tar.bz2 spark-ad2e8b512654314d68f4b7c149950756943992be.zip | |
Updated json output to allow for display of worker state
Ops teams need to ensure that the cluster is functional and performant. Having to scrape the html source for worker state won't work reliably, and will be slow. By exposing the state in the json output, ops teams are able to ensure a fully functional environment by querying for the json output and parsing for dead nodes.
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/spark/deploy/JsonProtocol.scala | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/core/src/main/scala/spark/deploy/JsonProtocol.scala b/core/src/main/scala/spark/deploy/JsonProtocol.scala index bd1db7c294..9901bb8a8c 100644 --- a/core/src/main/scala/spark/deploy/JsonProtocol.scala +++ b/core/src/main/scala/spark/deploy/JsonProtocol.scala @@ -33,7 +33,8 @@ private[spark] object JsonProtocol { ("cores" -> obj.cores) ~ ("coresused" -> obj.coresUsed) ~ ("memory" -> obj.memory) ~ - ("memoryused" -> obj.memoryUsed) + ("memoryused" -> obj.memoryUsed) ~ + ("state" -> obj.getState) } def writeApplicationInfo(obj: ApplicationInfo) = { |