MapReduce ジョブを実行しようとしていますが、そのステータスを定期的にポーリングしたいと考えています。次のようにコードで Jobclient クラスの submitJob(jobConf) メソッドを使用しようとしています
JobConf conf = new JobConf(SampleJobClass.class)
JobClient j= new JobClient();
j.setConf(conf);
System.out.println("from conf" +j.getConf().toString());
RunningJob submitJob=j.submitJob(conf);`
j.submitJob(conf)
The error stack isの行でヌル ポインター エラーが発生し続けます。
Exception in thread "main" java.lang.NullPointerException
at org.apache.hadoop.mapred.JobClient.submitJobInternal(JobClient.java:844)
at org.apache.hadoop.mapred.JobClient.submitJob(JobClient.java:818)
私が間違っていることについてのアイデアはありますか?