Если бы это было более стабильно, если разные задания могут выполняться в разных процессах у одного и того же работника? - PullRequest
0 голосов
/ 01 июня 2018

Из Flink среды выполнения мы знаем, что «Каждый работник (TaskManager) является процессом JVM и может выполнять одну или несколько подзадач в отдельных потоках»

Это означает, что существует только одинпроцесс для TaskManager, поэтому, если в одном TaskManager запланировано два задания (то есть оба они выполняются в одном и том же процессе), они будут влиять друг на друга.Иными словами, STW GC одного задания также может вызвать паузу для другого задания, а фатальная ошибка одного задания, которая вызвала завершение процесса, повлияет на все остальные задания, так почему бы не позволить различным заданиям, выполняющимся на разделенномразличные процессы, чтобы избежать проблем, упомянутых выше?

...