Как собрать статус контролера отслеживания hadoop?

Question

Я пытаюсь собрать различные показатели для активных tasttrackers, но это исключает исключение

Не знаете, почему?

for(String s: jc.getClusterStatus(true).getActiveTrackerNames()){ 
      System.out.println("tt "+s); 
      System.out.println(""+ new org.apache.hadoop.mapreduce.server.jobtracker.TaskTracker(s).getAvailableSlots(TaskType.MAP)); } 

выход

строки $ /installs/hadoop-0.20.2//bin/hadoop банки tools.jar tools.MetaInfo

тт tracker_10.0.0.6: локальный/127.0.0.1 : 53256 java.lang.NullPointerException at org.apache.hadoop.mapreduce.server.jobtracker.TaskTracker.getAvailableSlots (TaskTracker.java:90) в tools.MetaInfo. (MetaInfo.java:44) в tools.MetaInfo.main (MetaInfo .java: 51) at sun.reflect.NativeMethodAccessorImpl.invoke0 (собственный метод) на sun.reflect.NativeMethodAccessorImpl.invoke (NativeMethodAccessorImpl.java:39) на sun.reflect.DelegatingMethodAccessorImpl.invoke (Делегат ingMethodAccessorImpl.java:25) в java.lang.reflect.Method.invoke (Method.java:597) в org.apache.hadoop.util.RunJar.main (RunJar.java:186) jabir: CompareHdfs jabir.ahmed $

Не знаю, почему оно не отображает доступные слоты, но отображает сообщение об ошибке

Answer 1

Я пытаюсь собрать различные метрики для активных tasttrackers, но он бросает исключение

new TaskTracker() создаст новый TaskTracker, который разве вы не хотели этого делать.

Проверьте классы JobCounter и классы TaskCounter для различных встроенных счетчиков в системе Hadoop. Это tutorial поможет получить счетчики. Помимо встроенных счетчиков, custom counters также может быть создан для любых конкретных приложений для любых дополнительных данных, относящихся к инфраструктуре Hadoop.

Также разделите линии на несколько строк. С(). B(). C(). D(). E(), очень сложно узнать, когда появился NPE.

Answer 2

Вы также можете найти текущее состояние, в чем дело делать с TaskTracker http://x.x.x.x:50060/tasktracker.jsp