Flink自动缩放和最大并行度
那么有没有？或者javadoc有误导性（或者“动态”是什么意思）？如果没有，有没有这个功能的计划？
共有1个答案
Flink(1.5.0版）还不支持动态缩放。
但是，可以通过获取保存点、停止正在运行的作业并以调整后的（较小或较大）并行度重新启动作业来手动缩放作业（或由外部服务）。然而，新的并行性最多可以是先前配置的max-parallelism。一旦一个作业启动，最大并行度就会在保存点中生成，并且不能再更改了。
对动态缩放的支持已经在路线图上了。自1.5.0版本（2018年5月发布）起，Flink支持来自Yarn和Mesos等资源管理器的动态资源分配。这是迈向动态缩放的重要一步。事实上，该功能的实验版本已经在2018年4月的Flink Forward SF 2018上进行了演示。
-
由于一段时间内突发的高流量，我们经历了节流(429)。为了缓解这个问题，我们目前增加了azure portal中的RU，并在以后降低它。 我想根据指标向上/向下扩展，但是，它不会公开为文档数据库容器创建的物理分区数。 如何获取文档数据库容器的物理分区数 如果这个组中有人解决了自动缩放问题，我很想知道如何解决
-
问题内容： 我需要使用matplotlib获取一个自动拟合数据的图。这是我得到的代码： 这样就创建了一个图，但是无论数据是什么，窗口都始终是相同的（0-〜.8），即使所有数据都在该窗口之外。生成的窗口无法放大，只能放大，因此这是一个主要问题。我找不到在任何地方设置任何类型的大小设置的地方，II也找不到关于默认值的详细信息。我需要一个窗口来自动拟合数据，但是我找不到能执行此操作的任何函数（由于某些原
-
我是Apache Flink的新手，正在尝试了解一些与Kafka一起扩展Flink流媒体作业的最佳实践。我无法找到合适答案的一些问题包括： 您可以/应该运行多少个流作业？运行太多流是否存在可扩展性问题？太多是多少？ 如果我们运行假设2,000个流来满足业务需求，那么管理这些流的最佳方法是什么？ 从一个流读取流数据到另一个流的首选方式是什么？我们可以加入流、执行连续查询等吗...？ 提前感谢您的支持
-
我正在尝试在我的kubernetes集群中设置自动缩放。在部署heapster及其服务之后。我正面临以下错误。 Heapster成功地从pod中提取度量，可在 自动缩放(HPA)中的建议无法获取CPU消耗：无法将对象解封为[]V1ALPHA1类型的Go值。PodMetrics未解决此问题
-
在我的JFrame上，我使用以下代码在面板上显示图像： 我想“自动调整”标签中的图片大小。的确，有时图像大小只有几个像素，有时更多。 是否有一种方法可以设置标签的大小，然后自动调整标签中的图像大小？