incubator-hama-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Edward J. Yoon" <edwardy...@apache.org>
Subject Small patch
Date Fri, 04 Nov 2011 02:57:38 GMT
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

Mime
View raw message