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) {