2016-09-23 15 views
0

distcp 작업을 수행하는 작업 흐름이 있습니다. 워크 플로우 파일은 다음과 같습니다 :oconf distcp 작업 실행

<workflow-app xmlns="uri:oozie:workflow:0.3" name="distcp-wf"> 
<start to="distcp-node"/> 
<action name="distcp-node"> 
    <distcp xmlns="uri:oozie:distcp-action:0.1"> 
     <job-tracker>${jobtracker}</job-tracker> 
     <name-node>${namenode}</name-node> 
     <prepare> 
      <delete path="${namenode}/tmp/mohit/"/> 
     </prepare> 
     <configuration> 
      <property> 
       <name>mapred.job.queue.name</name> 
       <value>${queue_name}</value> 
      </property> 
     </configuration> 
     <arg>-m 1</arg> 
     <arg>${number_of_mapper}</arg> 
     <arg>-skipcrccheck</arg> 
     <arg>${namenode}/tmp/mohit/data.txt</arg> 
     </distcp> 
    <ok to="end"/> 
    <error to="fail"/> 
</action> 
<kill name="fail"> 
    <message>DistCP failed, error message[${wf:errorMessage(wf:lastErrorNode())}]</message> 
</kill> 
<end name="end"/> 

내가 distcp을 사용하여 -m 사용 매퍼의 수를 설정합니다. 내가 내가

<arg>-m 1</arg> 

<arg>1<arg> 

으로 시도했지만 나를 위해 일하지 않았다는 것을 어떻게 할 수 있습니다. I가 얻고 오류 아래 :

Failing Oozie Launcher, Main class [org.apache.oozie.action.hadoop.DistcpMain], main() threw exception, Returned value from distcp is non-zero (-1) 
     java.lang.RuntimeException: Returned value from distcp is non-zero (-1) 
+0

' -m '과 같은 것을 시도 했습니까? – YoungHobbit

+0

예. 나는 또한 그것을 시도했다. –

답변

1

인수는 입/출력되는 첫 번째 인수는 입력 및 제 ARG를 나타내는 documentation

에 기술 된 바와 같이 출력을 나타낸다

,172 :

생산자의 수를 변경/듀서는 예를 들어 configuration를 사용

+0

firstJobReducers 값은 숫자이며 속성 파일에 설정해야합니다. 맞습니까? –

+0

@MohitRane 당신은 wf 액션 안에 설정할 수 있습니다 - 예제에서했던 것처럼 또는 전체 wf에 대한 속성 파일을 사용하십시오 – Mzf