Flink: как контролировать последовательность выполнения задачи - PullRequest
0 голосов
/ 10 июня 2018

Я пытаюсь написать тест Junit, который имеет два ресурса и операторы, первый оператор используется для сохранения данных в состоянии, затем второй оператор извлекает состояние.

Я нашел проводнойдело в том, что второй оператор всегда запускается перед первым оператором, который сохраняет данные в состоянии.

Итак, мой вопрос заключается в том, как контролировать последовательность выполнения задачи в одной и той же программе задания flink?

...