| commit | 0d978e58cdcb6e03455e7e8451fe84c482c2e3f2 | [log] [tgz] |
|---|---|---|
| author | buyingyi <buyingyi@gmail.com> | Sat Sep 28 00:30:18 2013 -0700 |
| committer | buyingyi <buyingyi@gmail.com> | Sat Sep 28 00:30:18 2013 -0700 |
| tree | fa1b2930d5be4f96d21d723d85c7c50ed1e67e9e | |
| parent | f37ba22625590b1c4476b160985b5164fc7fdf35 [diff] |
fix the shortestpaths input format
diff --git a/pregelix-example/src/main/java/edu/uci/ics/pregelix/example/inputformat/TextShortestPathsInputFormat.java b/pregelix-example/src/main/java/edu/uci/ics/pregelix/example/inputformat/TextShortestPathsInputFormat.java index 3ea4a9f..8987393 100644 --- a/pregelix-example/src/main/java/edu/uci/ics/pregelix/example/inputformat/TextShortestPathsInputFormat.java +++ b/pregelix-example/src/main/java/edu/uci/ics/pregelix/example/inputformat/TextShortestPathsInputFormat.java
@@ -73,6 +73,7 @@ vertex.getMsgList().clear(); vertex.getEdges().clear(); + vertex.reset(); Text line = getRecordReader().getCurrentValue(); String[] fields = line.toString().split(separator);