Addressed comment

apache · Nov 29, 2016 · c11d2e5 · c11d2e5
1 parent aa8af9c
commit c11d2e5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/python/pyspark/sql/streaming.py b/python/pyspark/sql/streaming.py
@@ -104,7 +104,7 @@ def lastProgress(self):
         Returns the most recent :class:`StreamingQueryProgress` update of this streaming query.
         :return: a map
         """
-        return json.loads(self._jsq.lastProgress().toString())
+        return json.loads(self._jsq.lastProgress().json())
 
     @since(2.0)
     def processAllAvailable(self):