Как добавить свойство flowPriority в файл .job azkaban? - PullRequest
0 голосов
/ 07 мая 2019

Я использую Azkaban в распределенной среде.

Есть два кластера (Главный узел, Второй узел).

#my.job
type=command
command=/home/test.sh start

Когда это задание выполняется, задание Azkaban выполняется на втором узле.

Но я хочу выполнить задание на главном узле.

Поэтому я добавил "flowPriority"="PRIOIRTY" в параметрах потока в Азкабане, и это сработало на главном узле.

enter image description here

Но это было временно.

Чтобы сохранить это свойство, я добавил следующее свойство в файл задания.

#my.job
type=command
command=/home/test.sh start
flowPriority=PRIORITY

Но это не сработало. Есть ли способ ее решить?

...