fixed ValueError: No JSON object could be decoded in guardian spark c…

…hecker
InterestingLab · Jul 6, 2018 · ac151b7 · ac151b7
1 parent 2481273
commit ac151b7
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/spark_checker/streaming_utils.py b/spark_checker/streaming_utils.py
@@ -34,7 +34,11 @@ def streaming_batch_stats(master_url, application_id, status=None, timeout=20):
         if resp.status_code != 200:
             continue
 
-        stats_json = resp.json()
+        try:
+            stats_json = resp.json()
+        except ValueError as e:
+            stats_json = None
+
         break
 
     if stats_json is None: