There's a bug in BSPPeerImpl.
11/11/04 11:46:55 INFO zookeeper.ClientCnxn: Socket connection
established to slave.udanax.org/192.168.123.198:2222, initiating
session
11/11/04 11:46:55 INFO bsp.BSPPeerImpl: >>>>>>>>>>
hdfs://slave.udanax.org:9000/tmp/pi-temp/part-00005
11/11/04 11:46:55 WARN bsp.GroomServer: Error running child
java.lang.NullPointerException
at org.apache.hadoop.fs.Path.makeQualified(Path.java:276)
at org.apache.hama.bsp.BSPPeerImpl.initialize(BSPPeerImpl.java:190)
at org.apache.hama.bsp.BSPPeerImpl.<init>(BSPPeerImpl.java:136)
at
org.apache.hama.bsp.GroomServer$BSPPeerChild.main(GroomServer.java:906)
log4j:WARN No appenders could be found for logger
(org.apache.zookeeper.ClientCnxn).
The dfs should not null.
Index: src/main/java/org/apache/hama/bsp/BSPPeerImpl.java
===================================================================
--- src/main/java/org/apache/hama/bsp/BSPPeerImpl.java (revision 1197384)
+++ src/main/java/org/apache/hama/bsp/BSPPeerImpl.java (working copy)
@@ -122,11 +122,7 @@
this.splitClass = splitClass;
this.split = split;
- FileSystem fs = null;
- if (conf.getBoolean("bsp.checkpoint.enabled", false)) {
- fs = FileSystem.get(conf);
- }
- this.dfs = fs;
+ this.dfs = FileSystem.get(conf);
String bindAddress = conf.get(Constants.PEER_HOST,
Constants.DEFAULT_PEER_HOST);
--
Best Regards, Edward J. Yoon
@eddieyoon
