If either platform does not find a runtime context (topology context in storm and flowprocess in scalding) that matches this specific jobID (i.e. it was somehow not registered during initialization), it will not return a Long=>Unit. Long is the value to increment the metric counter by. I'll comment this so it is more clear.