Java 类org.apache.hadoop.mapreduce.server.tasktracker.userlogs.UserLogManager 实例源码

项目：hadoop-2.6.0-cdh5.4.3 文件：TestJvmManager.java

public TestJvmManager() throws Exception {
  user = UserGroupInformation.getCurrentUser().getShortUserName();
  tt = new TaskTracker();
  ttConf = new JobConf();
  ttConf.setLong("mapred.tasktracker.tasks.sleeptime-before-sigkill", 2000);
  tt.setConf(ttConf);
  tt.setMaxMapSlots(MAP_SLOTS);
  tt.setMaxReduceSlots(REDUCE_SLOTS);
  TaskController dtc;
  tt.setTaskController((dtc = new DefaultTaskController()));
  Configuration conf = new Configuration();
  dtc.setConf(conf);
  LocalDirAllocator ldirAlloc =
      new LocalDirAllocator(JobConf.MAPRED_LOCAL_DIR_PROPERTY);
  tt.getTaskController().setup(ldirAlloc, new LocalStorage(ttConf.getLocalDirs()));
  JobID jobId = new JobID("test", 0);
  jvmManager = new JvmManager(tt);
  tt.setJvmManagerInstance(jvmManager);
  tt.setUserLogManager(new UserLogManager(ttConf));
  tt.setCleanupThread(new InlineCleanupQueue());
}

项目：hadoop-on-lustre 文件：TestJvmManager.java

public TestJvmManager() throws Exception {
  user = UserGroupInformation.getCurrentUser().getShortUserName();
  tt = new TaskTracker();
  ttConf = new JobConf();
  ttConf.setLong("mapred.tasktracker.tasks.sleeptime-before-sigkill", 2000);
  tt.setConf(ttConf);
  tt.setMaxMapSlots(MAP_SLOTS);
  tt.setMaxReduceSlots(REDUCE_SLOTS);
  TaskController dtc;
  tt.setTaskController((dtc = new DefaultTaskController()));
  Configuration conf = new Configuration();
  dtc.setConf(conf);
  LocalDirAllocator ldirAlloc =
      new LocalDirAllocator(JobConf.MAPRED_LOCAL_DIR_PROPERTY);
  tt.getTaskController().setup(ldirAlloc, new LocalStorage(ttConf.getLocalDirs()));
  JobID jobId = new JobID("test", 0);
  jvmManager = new JvmManager(tt);
  tt.setJvmManagerInstance(jvmManager);
  tt.setUserLogManager(new UserLogManager(ttConf));
  tt.setCleanupThread(new InlineCleanupQueue());
}

项目：hanoi-hadoop-2.0.0-cdh 文件：TestJvmManager.java

public TestJvmManager() throws Exception {
  user = UserGroupInformation.getCurrentUser().getShortUserName();
  tt = new TaskTracker();
  ttConf = new JobConf();
  ttConf.setLong("mapred.tasktracker.tasks.sleeptime-before-sigkill", 2000);
  tt.setConf(ttConf);
  tt.setMaxMapSlots(MAP_SLOTS);
  tt.setMaxReduceSlots(REDUCE_SLOTS);
  TaskController dtc;
  tt.setTaskController((dtc = new DefaultTaskController()));
  Configuration conf = new Configuration();
  dtc.setConf(conf);
  LocalDirAllocator ldirAlloc =
      new LocalDirAllocator(JobConf.MAPRED_LOCAL_DIR_PROPERTY);
  tt.getTaskController().setup(ldirAlloc, new LocalStorage(ttConf.getLocalDirs()));
  JobID jobId = new JobID("test", 0);
  jvmManager = new JvmManager(tt);
  tt.setJvmManagerInstance(jvmManager);
  tt.setUserLogManager(new UserLogManager(ttConf));
  tt.setCleanupThread(new InlineCleanupQueue());
}

项目：hortonworks-extension 文件：TestJvmManager.java

public TestJvmManager() throws Exception {
  user = UserGroupInformation.getCurrentUser().getShortUserName();
  tt = new TaskTracker();
  ttConf = new JobConf();
  ttConf.setLong("mapred.tasktracker.tasks.sleeptime-before-sigkill", 2000);
  tt.setConf(ttConf);
  tt.setMaxMapSlots(MAP_SLOTS);
  tt.setMaxReduceSlots(REDUCE_SLOTS);
  TaskController dtc;
  tt.setTaskController((dtc = new DefaultTaskController()));
  Configuration conf = new Configuration();
  dtc.setConf(conf);
  LocalDirAllocator ldirAlloc =
      new LocalDirAllocator(JobConf.MAPRED_LOCAL_DIR_PROPERTY);
  tt.getTaskController().setup(ldirAlloc, new LocalStorage(ttConf.getLocalDirs()));
  JobID jobId = new JobID("test", 0);
  jvmManager = new JvmManager(tt);
  tt.setJvmManagerInstance(jvmManager);
  tt.setUserLogManager(new UserLogManager(ttConf));
  tt.setCleanupThread(new InlineCleanupQueue());
}

项目：hortonworks-extension 文件：TestJvmManager.java

public TestJvmManager() throws Exception {
  user = UserGroupInformation.getCurrentUser().getShortUserName();
  tt = new TaskTracker();
  ttConf = new JobConf();
  ttConf.setLong("mapred.tasktracker.tasks.sleeptime-before-sigkill", 2000);
  tt.setConf(ttConf);
  tt.setMaxMapSlots(MAP_SLOTS);
  tt.setMaxReduceSlots(REDUCE_SLOTS);
  TaskController dtc;
  tt.setTaskController((dtc = new DefaultTaskController()));
  Configuration conf = new Configuration();
  dtc.setConf(conf);
  LocalDirAllocator ldirAlloc =
      new LocalDirAllocator(JobConf.MAPRED_LOCAL_DIR_PROPERTY);
  tt.getTaskController().setup(ldirAlloc, new LocalStorage(ttConf.getLocalDirs()));
  JobID jobId = new JobID("test", 0);
  jvmManager = new JvmManager(tt);
  tt.setJvmManagerInstance(jvmManager);
  tt.setUserLogManager(new UserLogManager(ttConf));
  tt.setCleanupThread(new InlineCleanupQueue());
}

项目：hadoop-on-lustre 文件：TestTaskEnvironment.java

public TestTaskEnvironment() throws Exception {
  tt = new TaskTracker();
  ttConf = new JobConf();
  ttConf.setLong("mapred.tasktracker.tasks.sleeptime-before-sigkill", 2000);
  tt.setConf(ttConf);
  tt.setMaxMapSlots(MAP_SLOTS);
  tt.setMaxReduceSlots(REDUCE_SLOTS);
  tt.setTaskController(new DefaultTaskController());
  jvmManager = new JvmManager(tt);
  tt.setJvmManagerInstance(jvmManager);
  tt.setUserLogManager(new UserLogManager(ttConf));
}

项目：hortonworks-extension 文件：TestTaskEnvironment.java

public TestTaskEnvironment() throws Exception {
  tt = new TaskTracker();
  ttConf = new JobConf();
  ttConf.setLong("mapred.tasktracker.tasks.sleeptime-before-sigkill", 2000);
  tt.setConf(ttConf);
  tt.setMaxMapSlots(MAP_SLOTS);
  tt.setMaxReduceSlots(REDUCE_SLOTS);
  tt.setTaskController(new DefaultTaskController());
  jvmManager = new JvmManager(tt);
  tt.setJvmManagerInstance(jvmManager);
  tt.setUserLogManager(new UserLogManager(ttConf));
}

项目：hortonworks-extension 文件：TestTaskEnvironment.java

public TestTaskEnvironment() throws Exception {
  tt = new TaskTracker();
  ttConf = new JobConf();
  ttConf.setLong("mapred.tasktracker.tasks.sleeptime-before-sigkill", 2000);
  tt.setConf(ttConf);
  tt.setMaxMapSlots(MAP_SLOTS);
  tt.setMaxReduceSlots(REDUCE_SLOTS);
  tt.setTaskController(new DefaultTaskController());
  jvmManager = new JvmManager(tt);
  tt.setJvmManagerInstance(jvmManager);
  tt.setUserLogManager(new UserLogManager(ttConf));
}