commit 6894e441cba6018268e8db5387916e0591f6f817
author buyingyi <buyingyi@123451ca-8445-de46-9d55-352943316053> Tue Feb 12 23:48:17 2013 +0000
committer buyingyi <buyingyi@123451ca-8445-de46-9d55-352943316053> Tue Feb 12 23:48:17 2013 +0000
tree 247024ec6ee6ffdf7bcdbbac65385296c3353f71
parent e93e841400256d43723baafad64f5fe9f49bddb1

fix class loader issue in hdfs operators

git-svn-id: https://hyracks.googlecode.com/svn/branches/fullstack_asterix_stabilization@2905 123451ca-8445-de46-9d55-352943316053

pregelix-example/src/main/java/edu/uci/ics/pregelix/example/ReachabilityVertex.java

diff --git a/pregelix-example/src/main/java/edu/uci/ics/pregelix/example/ReachabilityVertex.java b/pregelix-example/src/main/java/edu/uci/ics/pregelix/example/ReachabilityVertex.java
index 2792d88..0895386 100644
--- a/pregelix-example/src/main/java/edu/uci/ics/pregelix/example/ReachabilityVertex.java
+++ b/pregelix-example/src/main/java/edu/uci/ics/pregelix/example/ReachabilityVertex.java
@@ -116,10 +116,10 @@
 
     @Override
     public void compute(Iterator<ByteWritable> msgIterator) {
+        if (sourceId < 0) {
+            sourceId = getContext().getConfiguration().getLong(SOURCE_ID, SOURCE_ID_DEFAULT);
+        }
         if (getSuperstep() == 1) {
-            if (sourceId < 0) {
-                sourceId = getContext().getConfiguration().getLong(SOURCE_ID, SOURCE_ID_DEFAULT);
-            }
             boolean isSource = isSource(getVertexId());
             if (isSource) {
                 tmpVertexValue.set((byte) 1);