question: private void checkStatus ( HadoopJobId jobId , boolean complete ) throws Exception { for ( int i = 0 ; i < gridCount ( ) ; i ++ ) { IgniteKernal kernal = ( IgniteKernal ) grid ( i ) ; Hadoop hadoop = kernal . hadoop ( ) ; HadoopJobStatus stat = hadoop . status ( jobId ) ; assert stat != null ; IgniteInternalFuture < ? > fut = hadoop . finishFuture ( jobId ) ; if ( ! complete ) assertFalse ( fut . isDone ( ) ) ; else { info ( "Waiting for status future completion on node [idx=" + i + ", nodeId=" + kernal . getLocalNodeId ( ) + ']' ) ; fut . get ( ) ; } } }
target:  Checks job execution status.