private void fix ( ) { Set < String > nodeGroups = appContext . getTaskTrackerManager ( ) . getNodeGroups ( ) ; if ( CollectionUtils . isEmpty ( nodeGroups ) ) { return ; } for ( String nodeGroup : nodeGroups ) { List < JobPo > deadJobPo = appContext . getExecutableJobQueue ( ) . getDeadJob ( nodeGroup , SystemClock . now ( ) - MAX_TIME_OUT ) ; if ( CollectionUtils . isNotEmpty ( deadJobPo ) ) { for ( JobPo jobPo : deadJobPo ) { appContext . getExecutableJobQueue ( ) . resume ( jobPo ) ; LOGGER . info ( "Fix executable job : {} " , JSON . toJSONString ( jobPo ) ) ; } } } }
fix the job that running is true and gmtModified too old