0

javacode を使用して Oozie ジョブを起動しようとしていますが、同じことができません。次のコードは、次のような数行で「unhandled type oozieClientException」という例外を発生させます

String jobId = wc.run(conf);

私はJavaが初めてで、助けを求めています。ここに私のコードがあります:

    OozieClient wc = new OozieClient("http://host.com:11000/oozie");

    Properties conf = wc.createConfiguration();
    conf.setProperty(....)
    ...
    String jobId = wc.run(conf);
    System.out.println("Workflow job submitted");

    while (wc.getJobInfo(jobId).getStatus() == WorkflowJob.Status.RUNNING) {
       System.out.println("Workflow job running ...");
       Thread.sleep(10 * 1000);
    }
    System.out.println("Workflow job completed ...");


    System.out.println(wc.getJobInfo(jobId));
4

1 に答える 1

0

try catch ブロックでコードを閉じる必要があります

try{
    OozieClient wc = new OozieClient("http://host.com:11000/oozie");

    Properties conf = wc.createConfiguration();
    conf.setProperty(....)
    ...
    String jobId = wc.run(conf);
    System.out.println("Workflow job submitted");

    while (wc.getJobInfo(jobId).getStatus() == WorkflowJob.Status.RUNNING) {
       System.out.println("Workflow job running ...");
       Thread.sleep(10 * 1000);
    }
    System.out.println("Workflow job completed ...");


    System.out.println(wc.getJobInfo(jobId)); 
}catch(OozieClientException oozieClientException){
    oozieClientException.printStackTrace();
}

OozieClientException - ジョブを送信できなかった場合にスローされる

于 2012-10-11T11:47:21.567 に答える