Проблема при выполнении одновременных заданий в одном потоке в Азкабане?

Привет, я создал простой поток Azkaban и у меня есть два независимых задания одного типа и с разными аргументами. Когда я запускаю выполнение, я обнаруживаю, что при выполнении обоих заданий b и c передается один и тот же аргумент 'bbb' - т.е. когда задание экземпляра c создается с правильными параметрами, когда вызывается метод run(), он выбирает параметры из задания b (Я зарегистрировал идентификатор работы, чтобы подтвердить). Более того, когда я перераспределяю своих исполнителей, это не происходит при первом запуске, а затем начинает происходить снова. Любая идея относительно того, что может происходить или что может пойти не так под одеялом? Или я ошибаюсь в спецификации?

workflow ('a') {job ('b') {'type': 'myType', 'args': 'bbb'} job ('c') {'type': 'myType', 'args': ' ccc '}... цели'b', 'c' }

0 ответов

Другие вопросы по тегам