Oozie - Client Demo

Posted 01 15, 2014 21:03, Filed under: BigData/Oozie


# Oozie Client 데모


원격지의 Oozie 잡을 실행


import java.util.Properties;

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

/**
 * # Oozie Client
 */
public class OozieClientDemo {
    
    public static void main(String[] args) throws     OozieClientException, InterruptedException { 
        OozieClient wc = new OozieClient("http://RemoteHost:11000/oozie");
        Properties conf = wc.createConfiguration();

        /**
         * # Oozie workflow.xml 파일 변수 설정
         */
        conf.setProperty(OozieClient.APP_PATH, "hdfs://RemoteHost:8020/hdfs_dir/examples/apps/map-reduce");
        conf.setProperty("jobTracker", "RemoteHost:8021");
        conf.setProperty("nameNode", "hdfs://RemoteHost:8020");
        conf.setProperty("queueName", "default");
        conf.setProperty("examplesRoot", "examples");
        conf.setProperty("inputDir", "/hdfs_dir/examples/input-data");
        conf.setProperty("outputDir", "/hdfs_dir/examples/output-data");
        
        String jobId = wc.run(conf);
        System.out.println("Work flow submitted - jobId : "+jobId);

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


# Oozie 잡 확인
oozie job -oozie http://i-bd01:11000/oozie -info [잡 아이디]

※ 위 내용은, 여러 자료를 참고하거나 제가 주관적으로 정리한 것입니다.
   잘못된 정보나 보완이 필요한 부분을, 댓글 또는 메일로 보내주시면 많은 도움이 되겠습니다.

"BigData / Oozie" 분류의 다른 글

Oozie - coordinator 잡 실행 (0)2014/02/17
Oozie - Job 실행시 에러 (0)2014/01/15
Oozie - 예제 테스트 (0)2014/01/15
01 15, 2014 21:03 01 15, 2014 21:03


Trackback URL : http://develop.sunshiny.co.kr/trackback/985

Leave a comment

« Previous : 1 : ... 57 : 58 : 59 : 60 : 61 : 62 : 63 : 64 : 65 : ... 648 : Next »

Recent Posts

  1. HDFS - Python Encoding 오류 처리
  2. HP - Vertica ROS Container 관련 오류...
  3. HDFS - Hive 실행시 System Time 오류
  4. HP - Vertica 사용자 쿼리 이력 테이블...
  5. Client에서 HDFS 환경의 데이터 처리시...

Recent Comments

  1. 안녕하세요^^ 배그핵
  2. 안녕하세요^^ 도움이 되셨다니, 저... sunshiny
  3. 정말 큰 도움이 되었습니다.. 감사합... 사랑은
  4. 네, 안녕하세요. 댓글 남겨 주셔서... sunshiny
  5. 감사합니다 많은 도움 되었습니다!ㅎㅎ 프리시퀸스

Recent Trackbacks

  1. how to broadcast your own tv station how to broadcast your own tv station %M
  2. elapsed time clock for operating r... elapsed time clock for operating r... %M
  3. Mysql - mysql 설치후 Character set... 멀고 가까움이 다르기 때문 %M

Calendar

«   12 2019   »
1 2 3 4 5 6 7
8 9 10 11 12 13 14
15 16 17 18 19 20 21
22 23 24 25 26 27 28
29 30 31        

Bookmarks

  1. 위키피디아
  2. MysqlKorea
  3. 오라클 클럽
  4. API - Java
  5. Apache Hadoop API
  6. Apache Software Foundation
  7. HDFS 생태계 솔루션
  8. DNSBL - Spam Database Lookup
  9. Ready System
  10. Solaris Freeware
  11. Linux-Site
  12. 윈디하나의 솔라나라

Site Stats

TOTAL 2780495 HIT
TODAY 78 HIT
YESTERDAY 1360 HIT