Major Description
Inside the RTNode.process(Object input) method, when input is null and an exception is caught, the act of logging the input causes another NullPointerException when it attempts to do input.toString().
Omiting the toString should fix the problem:
LOG.info(String.format("Crunch exception in '%s' for input: %s", nodeName, input), e);