commit | 6c562f1fe553fb7a6471ab69b9bb480f656b56f1 | [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 | ed82389a860c71e1177f963005693c90f5d33068 | |
parent | a9a19eeaf4bf1054a8d299f9647eef3a1ac4be73 [diff] |
fix the shortestpaths input format
diff --git a/pregelix/pregelix-example/src/main/java/edu/uci/ics/pregelix/example/inputformat/TextShortestPathsInputFormat.java b/pregelix/pregelix-example/src/main/java/edu/uci/ics/pregelix/example/inputformat/TextShortestPathsInputFormat.java index 3ea4a9f..8987393 100644 --- a/pregelix/pregelix-example/src/main/java/edu/uci/ics/pregelix/example/inputformat/TextShortestPathsInputFormat.java +++ b/pregelix/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);