commit e028990f07d65489795704b1ee80563e3fea90c7
author buyingyi <buyingyi@gmail.com> Wed Nov 06 13:54:07 2013 -0800
committer buyingyi <buyingyi@gmail.com> Wed Nov 06 13:54:07 2013 -0800
tree 014eb564b9c1aac6daa3fe235cc63a5dc3c53f55
parent c192c9ea1876c046c9bf7cdb2b6e75a68e92846e

fix an issue found by Sattam

pregelix/pregelix-dataflow/src/main/java/edu/uci/ics/pregelix/dataflow/context/PJobContext.java

diff --git a/pregelix/pregelix-dataflow/src/main/java/edu/uci/ics/pregelix/dataflow/context/PJobContext.java b/pregelix/pregelix-dataflow/src/main/java/edu/uci/ics/pregelix/dataflow/context/PJobContext.java
index ceb085c..9daed12 100644
--- a/pregelix/pregelix-dataflow/src/main/java/edu/uci/ics/pregelix/dataflow/context/PJobContext.java
+++ b/pregelix/pregelix-dataflow/src/main/java/edu/uci/ics/pregelix/dataflow/context/PJobContext.java
@@ -60,8 +60,11 @@
             long superStep = jobIdToSuperStep;
             List<FileReference> files = iterationToFiles.remove(superStep - 1);
             if (files != null) {
-                for (FileReference fileRef : files)
-                    fileRef.delete();
+                for (FileReference fileRef : files) {
+                    if (fileRef != null) {
+                        fileRef.delete();
+                    }
+                }
             }
 
             setProperties(numVertices, numEdges, currentIteration, superStep, false, cl);
@@ -81,8 +84,11 @@
         long superStep = jobIdToSuperStep;
         List<FileReference> files = iterationToFiles.remove(superStep - 1);
         if (files != null) {
-            for (FileReference fileRef : files)
-                fileRef.delete();
+            for (FileReference fileRef : files) {
+                if (fileRef != null) {
+                    fileRef.delete();
+                }
+            }
         }
 
         setProperties(numVertices, numEdges, currentIteration, superStep, true, cl);