小编ser*_*lor的帖子

我目前正在研究Flink的可扩展性.从1.2.0版开始,引入了动态重新缩放.我正在寻找扩展从Kafka源读取数据的长期工作.

有关动态重新缩放的问题.

1. 要扩展我的flink应用程序,例如:添加新的任务管理器,我必须重新启动作业/纱线会话以使用新添加的资源吗？
2. 我认为可以编写Yarn客户端来部署新的任务管理器并使其与作业管理器进行通信,这是否已经在现有的flink yarn客户端应用程序中可用？

请原谅我,如果这些问题太基础了,我确实通过了文件,我不得不承认我最近没有能够将这些概念与纱线上的一些测试部署完全结合起来.