private void setTaskFailed ( String reason ) { m_taskRecord . setProperty ( TaskRecord . PROP_EXECUTOR , m_hostID ) ; m_taskRecord . setProperty ( TaskRecord . PROP_FINISH_TIME , Long . toString ( System . currentTimeMillis ( ) ) ) ; m_taskRecord . setProperty ( TaskRecord . PROP_FAIL_REASON , reason ) ; m_taskRecord . setStatus ( TaskStatus . FAILED ) ; TaskManagerService . instance ( ) . updateTaskStatus ( m_tenant , m_taskRecord , true ) ; }
Update the job status record that shows this job has failed .