You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by zs...@apache.org on 2017/09/06 22:48:54 UTC
spark git commit: [SPARK-21901][SS] Define toString for
StateOperatorProgress
Repository: spark
Updated Branches:
refs/heads/master acdf45fb5 -> fa0092bdd
[SPARK-21901][SS] Define toString for StateOperatorProgress
## What changes were proposed in this pull request?
Just `StateOperatorProgress.toString` + few formatting fixes
## How was this patch tested?
Local build. Waiting for OK from Jenkins.
Author: Jacek Laskowski <ja...@japila.pl>
Closes #19112 from jaceklaskowski/SPARK-21901-StateOperatorProgress-toString.
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/fa0092bd
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/fa0092bd
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/fa0092bd
Branch: refs/heads/master
Commit: fa0092bddf695a757f5ddaed539e55e2dc9fccb7
Parents: acdf45f
Author: Jacek Laskowski <ja...@japila.pl>
Authored: Wed Sep 6 15:48:48 2017 -0700
Committer: Shixiong Zhu <zs...@gmail.com>
Committed: Wed Sep 6 15:48:48 2017 -0700
----------------------------------------------------------------------
.../src/main/scala/org/apache/spark/sql/streaming/progress.scala | 2 ++
1 file changed, 2 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/fa0092bd/sql/core/src/main/scala/org/apache/spark/sql/streaming/progress.scala
----------------------------------------------------------------------
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/streaming/progress.scala b/sql/core/src/main/scala/org/apache/spark/sql/streaming/progress.scala
index 3000c42..cedc1dc 100644
--- a/sql/core/src/main/scala/org/apache/spark/sql/streaming/progress.scala
+++ b/sql/core/src/main/scala/org/apache/spark/sql/streaming/progress.scala
@@ -55,6 +55,8 @@ class StateOperatorProgress private[sql](
("numRowsUpdated" -> JInt(numRowsUpdated)) ~
("memoryUsedBytes" -> JInt(memoryUsedBytes))
}
+
+ override def toString: String = prettyJson
}
/**
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org