onstepstarting event is fired whenever a job is submitted to hadoop and begun its execution . concode_field_sep StatsWriteService statsWriteService concode_elem_sep int totalNumberOfJobs concode_elem_sep MapReduceHelper mapReduceHelper concode_elem_sep Set<String> completedStepNames concode_elem_sep int runningJobs concode_elem_sep String currentFlowId concode_elem_sep Log LOG concode_elem_sep Map<String,DAGNode<CascadingJob>> nodesByName concode_field_sep boolean onThrowable concode_elem_sep DAGNode<CascadingJob> updateNode concode_elem_sep void onCompleted concode_elem_sep void onStepStopping concode_elem_sep void onStarting concode_elem_sep void onStepCompleted concode_elem_sep void onStepRunning concode_elem_sep StatsWriteService getStatsWriteService concode_elem_sep boolean onStepThrowable concode_elem_sep DAGNode<CascadingJob> getNode concode_elem_sep void onStopping
void function ( FlowStep arg0 ) { runningJobs ++ ; try { DAGNode < CascadingJob > loc0 = updateNode ( arg0 ) ; AmbroseUtils . pushEvent ( statsWriteService , currentFlowId , new Event . JobStartedEvent ( loc0 ) ) ; } catch ( Exception loc0 ) { LOG . error ( "srini_string" , loc0 ) ; } }