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();
    }
  }
}

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 ( ) ; } } }
checks job execution status .
