@Override
  public void reportRemoteCoronaJobTracker(
      String attempt,
      String host,
      int port,
      String sessionId) throws IOException {
    TaskAttemptID attemptId = TaskAttemptID.forName(attempt);
    synchronized (this) {
      checkAttempt(attemptId);
      initializeClientUnprotected(host, port, sessionId);
      this.notifyAll();
    }
  }
@ Override public void reportRemoteCoronaJobTracker ( String attempt , String host , int port , String sessionId ) throws IOException { TaskAttemptID attemptId = TaskAttemptID . forName ( attempt ) ; synchronized ( this ) { checkAttempt ( attemptId ) ; initializeClientUnprotected ( host , port , sessionId ) ; this . notifyAll ( ) ; } }
///////////////////////////////////////////////////////////////////////////