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