Как совместное использование слотов помогает Flink?

Question

Читая о Flink, каковы преимущества совместного использования слотов, например, почему я хотел бы изолировать слоты в задании Flink?

Я думаю, что если предположить 4GB диспетчер задач JVM, еслиЯ разделил это на два слота задач, один называется ts1, а другой, ts2, я могу поместить очень интенсивную оконную операцию в ts1, в то время как некоторые map, filter и т. Д. Могут перейти в ts2?

Answer 1

Совместное использование слота означает, что в одном и том же слоте запланировано более одной подзадачи, или, другими словами, экземпляры этих операторов в конечном итоге совместно используют ресурсы. Это имеет следующие преимущества:

• Лучшее использование ресурсов. В противном случае вы можете легко получить несколько слотов, выполняющих очень мало работы, в то время как другие довольно заняты.
• Снижение сетевого трафика.
• Количество слотов в итоге становится самой высокой степенью параллелизма в работе. Запуск каждого слота по одному параллельному фрагменту задания упрощает анализ того, что происходит во время выполнения.

Возможно, вы сочтете целесообразным отключить совместное использование слотов, если, как вы указали, хотите выделить больше ресурсов дорогому оператору. С другой стороны, вы можете оставить совместное использование слотов и дать каждому слоту больше ядер и / или памяти.