YARN REST API - отправить простую работу

Question

Мне нужна помощь с заполнением заполнения запроса HTTP. Я делаю HTTP-запрос PUT, и я знаю, что я делаю это правильно (в java).

Я хочу, чтобы запустить простую карту уменьшить пример задания - рассчитать PI ... Когда я использую команду:

«Hadoop баночка /usr/hdp/2.2.0.0-2041/hadoop-mapreduce/hadoop-mapreduce -examples-2.6.0.2.2.0.0-2041.jar pi 10 10 "

В терминале hortonworks он работает, я пытаюсь создать и запустить задание, которое делает то же самое.

Я думаю, что проблема в теле запроса (в файле run_mapreducer_M2.txt). Я пытаюсь использовать, если с YARN REST API.

Что мне не хватает? Есть ли у кого-нибудь пример для использования простой работы МР?

Спасибо! Вот файл XML Я использую для тела запроса:

<application-submission-context>  
 
\t <application-id>application_1421661392788_0005</application-id> 
 
    <application-name>pi2</application-name> \t 
 
\t <queue>testqueue</queue> 
 
    <priority>3</priority> 
 
    <am-container-spec>  
 
\t \t <environment> \t \t \t 
 
\t \t \t <entry> \t \t \t 
 
\t \t \t \t <key>CLASSPATH</key> 
 
\t \t \t \t <value>/usr/hdp/2.2.0.0-2041/hadoop/conf&lt;CPS&gt;/usr/hdp/2.2.0.0-2041/hadoop/lib/*&lt;CPS&gt;/usr/hdp/2.2.0.0-2041/hadoop/.//*&lt;CPS&gt;/usr/hdp/2.2.0.0-2041/hadoop-hdfs/./&lt;CPS&gt;/usr/hdp/2.2.0.0-2041/hadoop-hdfs/lib/*&lt;CPS&gt;/usr/hdp/2.2.0.0-2041/hadoop-hdfs/.//*&lt;CPS&gt;/usr/hdp/2.2.0.0-2041/hadoop-yarn/lib/*&lt;CPS&gt;/usr/hdp/2.2.0.0-2041/hadoop-yarn/.//*&lt;CPS&gt;/usr/hdp/2.2.0.0-2041/hadoop-mapreduce/lib/*&lt;CPS&gt;/usr/hdp/2.2.0.0-2041/hadoop-mapreduce/.//*&lt;CPS&gt;&lt;CPS&gt;/usr/share/java/mysql-connector-java-5.1.17.jar&lt;CPS&gt;/usr/share/java/mysql-connector-java.jar&lt;CPS&gt;/usr/hdp/current/hadoop-mapreduce-client/*&lt;CPS&gt;/usr/hdp/current/tez-client/*&lt;CPS&gt;/usr/hdp/current/tez-client/lib/*&lt;CPS&gt;/etc/tez/conf/&lt;CPS&gt;/usr/hdp/2.2.0.0-2041/tez/*&lt;CPS&gt;/usr/hdp/2.2.0.0-2041/tez/lib/*&lt;CPS&gt;/etc/tez/conf</value> 
 
\t \t \t </entry> 
 
\t \t </environment> 
 
\t \t <commands> 
 
\t \t \t <command>hadoop jar /usr/hdp/2.2.0.0-2041/hadoop-mapreduce/hadoop-mapreduce-examples-2.6.0.2.2.0.0-2041.jar pi 10 10</command> 
 
\t \t </commands> 
 
    </am-container-spec> 
 
    <unmanaged-AM>false</unmanaged-AM> 
 
    <max-app-attempts>2</max-app-attempts> 
 
    <resource>  
 
\t \t <memory>1024</memory> 
 
\t \t <vCores>1</vCores> 
 
    </resource>  
 
\t <application-type>MAPREDUCE</application-type> 
 
    <keep-containers-across-application-attempts>false</keep-containers-across-application-attempts> 
 
    <application-tags>  
 
\t \t <tag>Michael</tag>  
 
\t \t <tag>PI example</tag>  
 
\t </application-tags> 
 
</application-submission-context>

Answer 1

Извините, если это поздно, вы, вероятно, нашли ответ уже, но вы хотите использовать запрос POST HTTP вместо PUT.