Fix bug when bytes_read is None

cemsbr · Oct 31, 2016 · e8fd99d · e8fd99d
1 parent 845c022
commit e8fd99d
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/sparklogstats/logparser.py b/sparklogstats/logparser.py
@@ -209,7 +209,8 @@ def end(self):
 
     @property
     def bytes_read(self):
-        return sum(t.metrics.bytes_read for t in self.successful_tasks)
+        return sum(t.metrics.bytes_read for t in self.successful_tasks
+                   if t.metrics.bytes_read)
 
     @property
     def bytes_written(self):