exécution d'un flux de travail oozie à l'aide de code java

Question

Je suis novice en Java et j'ai quelques difficultés à exécuter un job oozie en utilisant du code Java. Je n'arrive pas à comprendre le problème dans le code. Une aide serait vraiment appréciée. Voici mon code

import java.util.Properties;

import org.apache.oozie.client.OozieClient;
import org.apache.oozie.client.WorkflowJob;

public class oozie {

public static void main(String[] args) {
    OozieClient wc = new OozieClient("http://host:11000/oozie");

    Properties conf = wc.createConfiguration();

    conf.setProperty(OozieClient.APP_PATH, "hdfs://cluster/user/apps/merge-psp-logs/merge-wf/workflow.xml");
    conf.setProperty("jobTracker", "jobtracker.bigdata.com:8021");
    conf.setProperty("nameNode", "hdfs://namenode.bigdata.com:8020");
    conf.setProperty("queueName", "jobtracker.bigdata.com:8021");
    conf.setProperty("appsRoot", "hdfs://namenode.bigdata.com:8020/user/workspace/apps");
    conf.setProperty("appLibLoc", "hdfs://namenode.bigdata.com:8020/user/workspace/lib");
    conf.setProperty("rawlogsLoc", "hdfs://namenode.bigdata.com:8020/user/workspace/");
    conf.setProperty("mergedlogsLoc", "jobtracker.bigdata.com:8021");
    try {
        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 (Exception r) {
        System.out.println("Errors");
    }
}
}

Bien que je sois en mesure de lancer le travail à l'aide de la ligne de commande

Answer 1

Sans plus d'informations, je dirais que c'est la cause probable de vos erreurs d'exécution :

conf.setProperty(OozieClient.APP_PATH, 
    "hdfs://cluster/user/apps/merge-psp-logs/merge-wf/workflow.xml");
conf.setProperty("jobTracker", "jobtracker.bigdata.com:8021");
conf.setProperty("nameNode", "hdfs://namenode.bigdata.com:8020");
conf.setProperty("queueName", "jobtracker.bigdata.com:8021");

A moins que vous n'ayez deux clusters, je pense que vous vouliez que APP_PATH pointe vers la même instance HDFS que celle nommée dans votre propriété nameNode, dans ce cas essayez :

conf.setProperty(OozieClient.APP_PATH, 
    "hdfs://namenode.bigdata.com:8020/user/apps/merge-psp-logs/merge-wf/workflow.xml");

Vous pouvez également remplacer queueName par un nom de file d'attente réel (probablement "default", à moins que jobtracker.bigdata.com:8021 est le nom réel de votre file d'attente) :

conf.setProperty("queueName", "default");

En dehors de ces observations, essayez d'afficher l'erreur d'exécution que vous rencontrez.