Author: edwardyoon
Date: Wed Oct 26 01:20:03 2011
New Revision: 1188988

URL: http://svn.apache.org/viewvc?rev=1188988&view=rev
Log:
Reflection bug fix

Modified:
    incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPPeerImpl.java

Modified: 
incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPPeerImpl.java
URL: 
http://svn.apache.org/viewvc/incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPPeerImpl.java?rev=1188988&r1=1188987&r2=1188988&view=diff
==============================================================================
--- 
incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPPeerImpl.java 
(original)
+++ 
incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPPeerImpl.java 
Wed Oct 26 01:20:03 2011
@@ -192,10 +192,10 @@ public class BSPPeerImpl implements BSPP
         Iterable<BSPMessage> messages = entry.getValue();
         BSPMessageBundle bundle = new BSPMessageBundle();
 
-        Combiner combiner = (Combiner) ReflectionUtils.newInstance(
+        if (!conf.getClass("bsp.combiner.class", 
Combiner.class).equals(Combiner.class)) {
+          Combiner combiner = (Combiner) ReflectionUtils.newInstance(
             conf.getClass("bsp.combiner.class", Combiner.class), conf);
 
-        if (combiner != null) {
           bundle = combiner.combine(messages);
         } else {
           for (BSPMessage message : messages) {


Reply via email to