Wie setze ich den Warteschlangennamen für Pig on Tez?

Question

Wie setze ich einen Warteschlangennamen von einer Befehlszeile aus, wenn ich Pig auf TEZ starte?

Ich möchte ein Schwein Skript von der Kommandozeile ausgeführt werden wie zum Beispiel:

pig -useHCatalog -p INPUT=input_dir \ 
           -p 'OUT_FILE=out_file \ 
           -p UDF_PATH=udf.py \ 
           -f ./script_name.pig \ 
           -Dmapred.job.queue.name=my_queue_name \ 
           -x tez; 

ich folgende Einstellungen ausprobiert:

-tez.job.queue.name=my_queue_name 
-q mapreduce.job.queuename=my_queue_name 
-Dmapred.job.queue.name=my_queue_name 
-q my_queue_name 

jedoch meinen Job nicht ausgeführt wird in der Warteschlange I angegeben.

Vielen Dank!

Answer 1

Die Eigenschaft ist tez.queue.name.

<property> 
    <name>tez.queue.name</name> 
    <value>myqueue</value> 
</property> 

versuchen So

-tez.queue.name=my_queue_name 

Answer 2

In meiner Version von Schwein (0.16.0.2.5.3.0-37) ich nicht diesen Parameter in der Befehlszeile festlegen können.

Statt Zugabe

SET tez.queue.name 'my_queue';

an den Anfang des PIG-Skripts hat funktioniert.