Как собрать статус TaskTracker Hadoop?

Question

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

Не уверен почему?

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

output

prompt $ / installs / hadoop-0.20.2 // bin / hadoop jar tools.jar tools.MetaInfo

tt tracker_10.0.0.6: localhost / 127.0.0.1: 53256 java.lang.NullPointerException в org.apache.hadoop.mapreduce.server.jobtracker.TaskTracker.getAvailableSlots (TaskTracker.java:90) в tools.MetaInfo. (MetaInfo.java:44) в tools.MetaInfo.main (MetaInfo.java:51) в sun.reflect.NativeMethodAccessorImpl.invoke (Native0) в sun.reflect.NativeMethodAccessorImpl.invoke (NativeMethodAccessorImpl.java:39) в sun.reflect.DelegatingMethodAccessorImpl.invoke (DelegatingMethodAccessorImpl.java:25) в java.lanke.met.jj.jj.jj.jj.apache.hadoop.util.RunJar.main (RunJar.java:186) jabir: CompareHdfs jabir.ahmed $

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

Answer 1

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

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

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

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

Answer 2

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