Как Apache Beam использует новую функциональность, встроенную в flink?

#apache-beam

Вопрос:

Например, начиная с flink 1.13, я считаю, что выпущено реактивное масштабирование. https://flink.apache.org/2021/05/06/reactive-mode.html

Может ли задание пакетного луча (ограниченный источник) использовать преимущества кластера flink 1.13?

Комментарии:

1. Пожалуйста, проясните вашу конкретную проблему или предоставьте дополнительные сведения, чтобы точно указать, что вам нужно. Поскольку это написано в настоящее время, трудно точно сказать, о чем вы просите.