1. 包列表
  2. 类列表
  3. org.apache.hadoop.mapred.TaskAttemptListenerImpl

Java 类org.apache.hadoop.mapred.TaskAttemptListenerImpl 实例源码

项目：hadoop    文件：TestFail.java    
@Override
protected TaskAttemptListener createTaskAttemptListener(AppContext context) {
  //This will create the TaskAttemptListener with TaskHeartbeatHandler
  //RPC servers are not started
  //task time out is reduced
  //when attempt times out, heartbeat handler will send the lost event
  //leading to Attempt failure
  return new TaskAttemptListenerImpl(getContext(), null, null, null) {
    @Override
    public void startRpcServer(){};
    @Override
    public void stopRpcServer(){};
    @Override
    public InetSocketAddress getAddress() {
      return NetUtils.createSocketAddr("localhost", 1234);
    }

    protected void serviceInit(Configuration conf) throws Exception {
      conf.setInt(MRJobConfig.TASK_TIMEOUT, 1*1000);//reduce timeout
      conf.setInt(MRJobConfig.TASK_TIMEOUT_CHECK_INTERVAL_MS, 1*1000);
      super.serviceInit(conf);
    }
  };
}
项目：aliyun-oss-hadoop-fs    文件：TestFail.java    
@Override
protected TaskAttemptListener createTaskAttemptListener(
    AppContext context, AMPreemptionPolicy policy) {
  //This will create the TaskAttemptListener with TaskHeartbeatHandler
  //RPC servers are not started
  //task time out is reduced
  //when attempt times out, heartbeat handler will send the lost event
  //leading to Attempt failure
  return new TaskAttemptListenerImpl(getContext(), null, null, policy) {
    @Override
    public void startRpcServer(){};
    @Override
    public void stopRpcServer(){};
    @Override
    public InetSocketAddress getAddress() {
      return NetUtils.createSocketAddr("localhost", 1234);
    }

    protected void serviceInit(Configuration conf) throws Exception {
      conf.setInt(MRJobConfig.TASK_TIMEOUT, 1*1000);//reduce timeout
      conf.setInt(MRJobConfig.TASK_TIMEOUT_CHECK_INTERVAL_MS, 1*1000);
      super.serviceInit(conf);
    }
  };
}
项目：big-c    文件：TestFail.java    
@Override
protected TaskAttemptListener createTaskAttemptListener(AppContext context) {
  //This will create the TaskAttemptListener with TaskHeartbeatHandler
  //RPC servers are not started
  //task time out is reduced
  //when attempt times out, heartbeat handler will send the lost event
  //leading to Attempt failure
  return new TaskAttemptListenerImpl(getContext(), null, null, null) {
    @Override
    public void startRpcServer(){};
    @Override
    public void stopRpcServer(){};
    @Override
    public InetSocketAddress getAddress() {
      return NetUtils.createSocketAddr("localhost", 1234);
    }

    protected void serviceInit(Configuration conf) throws Exception {
      conf.setInt(MRJobConfig.TASK_TIMEOUT, 1*1000);//reduce timeout
      conf.setInt(MRJobConfig.TASK_TIMEOUT_CHECK_INTERVAL_MS, 1*1000);
      super.serviceInit(conf);
    }
  };
}
项目：hadoop-2.6.0-cdh5.4.3    文件：TestFail.java    
@Override
protected TaskAttemptListener createTaskAttemptListener(AppContext context) {
  //This will create the TaskAttemptListener with TaskHeartbeatHandler
  //RPC servers are not started
  //task time out is reduced
  //when attempt times out, heartbeat handler will send the lost event
  //leading to Attempt failure
  return new TaskAttemptListenerImpl(getContext(), null, null) {
    @Override
    public void startRpcServer(){};
    @Override
    public void stopRpcServer(){};
    @Override
    public InetSocketAddress getAddress() {
      return NetUtils.createSocketAddr("localhost", 1234);
    }

    protected void serviceInit(Configuration conf) throws Exception {
      conf.setInt(MRJobConfig.TASK_TIMEOUT, 1*1000);//reduce timeout
      conf.setInt(MRJobConfig.TASK_TIMEOUT_CHECK_INTERVAL_MS, 1*1000);
      super.serviceInit(conf);
    }
  };
}
项目：hadoop-plus    文件：TestFail.java    
@Override
protected TaskAttemptListener createTaskAttemptListener(AppContext context) {
  //This will create the TaskAttemptListener with TaskHeartbeatHandler
  //RPC servers are not started
  //task time out is reduced
  //when attempt times out, heartbeat handler will send the lost event
  //leading to Attempt failure
  return new TaskAttemptListenerImpl(getContext(), null, null) {
    @Override
    public void startRpcServer(){};
    @Override
    public void stopRpcServer(){};
    @Override
    public InetSocketAddress getAddress() {
      return NetUtils.createSocketAddr("localhost", 1234);
    }

    protected void serviceInit(Configuration conf) throws Exception {
      conf.setInt(MRJobConfig.TASK_TIMEOUT, 1*1000);//reduce timeout
      conf.setInt(MRJobConfig.TASK_TIMEOUT_CHECK_INTERVAL_MS, 1*1000);
      super.serviceInit(conf);
    }
  };
}
项目：FlexMap    文件：TestFail.java    
@Override
protected TaskAttemptListener createTaskAttemptListener(AppContext context) {
  //This will create the TaskAttemptListener with TaskHeartbeatHandler
  //RPC servers are not started
  //task time out is reduced
  //when attempt times out, heartbeat handler will send the lost event
  //leading to Attempt failure
  return new TaskAttemptListenerImpl(getContext(), null, null) {
    @Override
    public void startRpcServer(){};
    @Override
    public void stopRpcServer(){};
    @Override
    public InetSocketAddress getAddress() {
      return NetUtils.createSocketAddr("localhost", 1234);
    }

    protected void serviceInit(Configuration conf) throws Exception {
      conf.setInt(MRJobConfig.TASK_TIMEOUT, 1*1000);//reduce timeout
      conf.setInt(MRJobConfig.TASK_TIMEOUT_CHECK_INTERVAL_MS, 1*1000);
      super.serviceInit(conf);
    }
  };
}
项目：hops    文件：TestFail.java    
@Override
protected TaskAttemptListener createTaskAttemptListener(AppContext context) {
  //This will create the TaskAttemptListener with TaskHeartbeatHandler
  //RPC servers are not started
  //task time out is reduced
  //when attempt times out, heartbeat handler will send the lost event
  //leading to Attempt failure
  return new TaskAttemptListenerImpl(getContext(), null, null, null) {
    @Override
    public void startRpcServer(){};
    @Override
    public void stopRpcServer(){};
    @Override
    public InetSocketAddress getAddress() {
      return NetUtils.createSocketAddr("localhost", 1234);
    }

    protected void serviceInit(Configuration conf) throws Exception {
      conf.setInt(MRJobConfig.TASK_TIMEOUT, 1*1000);//reduce timeout
      conf.setInt(MRJobConfig.TASK_TIMEOUT_CHECK_INTERVAL_MS, 1*1000);
      super.serviceInit(conf);
    }
  };
}
项目：hadoop-TCP    文件：TestFail.java    
@Override
protected TaskAttemptListener createTaskAttemptListener(AppContext context) {
  //This will create the TaskAttemptListener with TaskHeartbeatHandler
  //RPC servers are not started
  //task time out is reduced
  //when attempt times out, heartbeat handler will send the lost event
  //leading to Attempt failure
  return new TaskAttemptListenerImpl(getContext(), null, null) {
    @Override
    public void startRpcServer(){};
    @Override
    public void stopRpcServer(){};
    @Override
    public InetSocketAddress getAddress() {
      return NetUtils.createSocketAddr("localhost", 1234);
    }

    protected void serviceInit(Configuration conf) throws Exception {
      conf.setInt(MRJobConfig.TASK_TIMEOUT, 1*1000);//reduce timeout
      conf.setInt(MRJobConfig.TASK_TIMEOUT_CHECK_INTERVAL_MS, 1*1000);
      super.serviceInit(conf);
    }
  };
}
项目：hardfs    文件：TestFail.java    
@Override
protected TaskAttemptListener createTaskAttemptListener(AppContext context) {
  //This will create the TaskAttemptListener with TaskHeartbeatHandler
  //RPC servers are not started
  //task time out is reduced
  //when attempt times out, heartbeat handler will send the lost event
  //leading to Attempt failure
  return new TaskAttemptListenerImpl(getContext(), null, null) {
    @Override
    public void startRpcServer(){};
    @Override
    public void stopRpcServer(){};
    @Override
    public InetSocketAddress getAddress() {
      return NetUtils.createSocketAddr("localhost", 1234);
    }

    protected void serviceInit(Configuration conf) throws Exception {
      conf.setInt(MRJobConfig.TASK_TIMEOUT, 1*1000);//reduce timeout
      conf.setInt(MRJobConfig.TASK_TIMEOUT_CHECK_INTERVAL_MS, 1*1000);
      super.serviceInit(conf);
    }
  };
}
项目：hadoop-on-lustre2    文件：TestFail.java    
@Override
protected TaskAttemptListener createTaskAttemptListener(AppContext context) {
  //This will create the TaskAttemptListener with TaskHeartbeatHandler
  //RPC servers are not started
  //task time out is reduced
  //when attempt times out, heartbeat handler will send the lost event
  //leading to Attempt failure
  return new TaskAttemptListenerImpl(getContext(), null, null) {
    @Override
    public void startRpcServer(){};
    @Override
    public void stopRpcServer(){};
    @Override
    public InetSocketAddress getAddress() {
      return NetUtils.createSocketAddr("localhost", 1234);
    }

    protected void serviceInit(Configuration conf) throws Exception {
      conf.setInt(MRJobConfig.TASK_TIMEOUT, 1*1000);//reduce timeout
      conf.setInt(MRJobConfig.TASK_TIMEOUT_CHECK_INTERVAL_MS, 1*1000);
      super.serviceInit(conf);
    }
  };
}
项目：aliyun-oss-hadoop-fs    文件：MRAppMaster.java    
protected TaskAttemptListener createTaskAttemptListener(AppContext context,
    AMPreemptionPolicy preemptionPolicy) {
  TaskAttemptListener lis =
      new TaskAttemptListenerImpl(context, jobTokenSecretManager,
          getRMHeartbeatHandler(), preemptionPolicy, encryptedSpillKey);
  return lis;
}
项目：hadoop    文件：MRAppMaster.java    
protected TaskAttemptListener createTaskAttemptListener(AppContext context) {
  TaskAttemptListener lis =
      new TaskAttemptListenerImpl(context, jobTokenSecretManager,
          getRMHeartbeatHandler(), encryptedSpillKey);
  return lis;
}
项目：big-c    文件：MRAppMaster.java    
protected TaskAttemptListener createTaskAttemptListener(AppContext context) {
  TaskAttemptListener lis =
      new TaskAttemptListenerImpl(context, jobTokenSecretManager,
          getRMHeartbeatHandler(), encryptedSpillKey);
  return lis;
}
项目：hadoop-2.6.0-cdh5.4.3    文件：MRAppMaster.java    
protected TaskAttemptListener createTaskAttemptListener(AppContext context) {
  TaskAttemptListener lis =
      new TaskAttemptListenerImpl(context, jobTokenSecretManager,
          getRMHeartbeatHandler());
  return lis;
}
项目：hadoop-plus    文件：MRAppMaster.java    
protected TaskAttemptListener createTaskAttemptListener(AppContext context) {
  TaskAttemptListener lis =
      new TaskAttemptListenerImpl(context, jobTokenSecretManager,
          getRMHeartbeatHandler());
  return lis;
}
项目：FlexMap    文件：MRAppMaster.java    
protected TaskAttemptListener createTaskAttemptListener(AppContext context) {
  TaskAttemptListener lis =
      new TaskAttemptListenerImpl(context, jobTokenSecretManager,
          getRMHeartbeatHandler());
  return lis;
}
项目：hops    文件：MRAppMaster.java    
protected TaskAttemptListener createTaskAttemptListener(AppContext context) {
  TaskAttemptListener lis =
      new TaskAttemptListenerImpl(context, jobTokenSecretManager,
          getRMHeartbeatHandler(), encryptedSpillKey);
  return lis;
}
项目：hadoop-TCP    文件：MRAppMaster.java    
protected TaskAttemptListener createTaskAttemptListener(AppContext context) {
  TaskAttemptListener lis =
      new TaskAttemptListenerImpl(context, jobTokenSecretManager,
          getRMHeartbeatHandler());
  return lis;
}
项目：hardfs    文件：MRAppMaster.java    
protected TaskAttemptListener createTaskAttemptListener(AppContext context) {
  TaskAttemptListener lis =
      new TaskAttemptListenerImpl(context, jobTokenSecretManager,
          getRMHeartbeatHandler());
  return lis;
}
项目：hadoop-on-lustre2    文件：MRAppMaster.java    
protected TaskAttemptListener createTaskAttemptListener(AppContext context) {
  TaskAttemptListener lis =
      new TaskAttemptListenerImpl(context, jobTokenSecretManager,
          getRMHeartbeatHandler());
  return lis;
}