Index: core/src/main/java/org/apache/hama/ipc/AsyncRPC.java =================================================================== --- core/src/main/java/org/apache/hama/ipc/AsyncRPC.java (revision 1692599) +++ core/src/main/java/org/apache/hama/ipc/AsyncRPC.java (working copy) @@ -698,7 +698,7 @@ private static String classNameBase(String className) { String[] names = className.split("\\.", -1); - if (names == null || names.length == 0) { + if (names.length == 0) { return className; } return names[names.length - 1]; Index: core/src/main/java/org/apache/hama/ipc/RPC.java =================================================================== --- core/src/main/java/org/apache/hama/ipc/RPC.java (revision 1692599) +++ core/src/main/java/org/apache/hama/ipc/RPC.java (working copy) @@ -574,7 +574,7 @@ private static String classNameBase(String className) { String[] names = className.split("\\.", -1); - if (names == null || names.length == 0) { + if (names.length == 0) { return className; } return names[names.length - 1];