requestNextInputSplit() is called by RPC, right? So for now it should be good enough to trigger a event inside of requestNextInputSplit(), since its already running on the JobManager.