初始化Flink作业
我们正在部署一个新的Flink流处理作业，它的状态（存储）需要使用历史数据进行初始化，并且在开始处理任何新的应用程序事件之前，该数据应该在状态存储中可用。我们不想显着修改Flink作业以同时加载历史数据。我们考虑编写另一个单独的Flink作业来处理历史数据，更新其状态存储并创建一个Savepoint并使用此Savepoint在主Flink作业中初始化状态。看起来状态处理器API仅适用于DataSet API，并想知道任何替代解决方案。谢谢。
共有2个答案
这是一个非常简单的更改（绝对不是“重要的”）来支持作业的预加载模式，其中非历史数据源被空/非终止源替换。我通常使用计数器来确定状态何时已完全填充，然后使用保存点停止，然后在不使用预加载选项的情况下重新启动。
状态处理器API是一个很好的解决方案。它提供了一种保存点连接器，您可以在数据集作业中使用它来读取/修改/更新数据流作业中使用的保存点。
-
我最近遇到了一些关于开发flink作业的问题，它引入了Spring和hibernate，并且作业将在flink集群上运行。所以我需要在运行任务管理器而不是作业管理器上的flink操作符之前初始化Spring资源。但是我找不到任何合适的StreamExecttion环境方法来做到这一点。 我尝试了以下一些方法： 但是，当并行性不止一个的flink作业执行时，spring初始化不会出现在每个任务管理器
-
我们试图构建一个用例，其中来自流的数据通过计算公式运行，但公式本身也应该（很少）是可更新的。从阅读文档来看，在我看来，Flink broadcast state自然适合这种情况。 作为一个实验，我构建了一个简化的版本：假设我有一个整数流，第二个流包含这些整数的乘法因子（我可以随意发送值）。第二个流的频率很低，很容易在事件之间的几天或几周内出现。目前，这两个都实现为简单的套接字服务器，最终产品将使用
-
我已经创建了一个有2个INIT容器的作业荚，我的作业成功完成，但没有INIT容器的迹象 对我来说，作业应该在开始之前等待2个init容器的完成 操作系统为Red Hat Enterprise Linux Server 7.3(Maipo) 提前感谢您的帮助。
-
Initialization 初始化 Although it doesn’t look superficially very different from initialization in C or C++, initialization in Go is more powerful. Complex structures can be built during initialization a
-
初始化是为类、结构体或者枚举准备实例的过程。这个过需要给实例里的每一个存储属性设置一个初始值并且在新实例可以使用之前执行任何其他所必须的配置或初始化。 你通过定义初始化器来实现这个初始化过程，它更像是一个用来创建特定类型新实例的特殊的方法。不同于 Objective-C 的初始化器，Swift 初始化器不返回值。这些初始化器主要的角色就是确保在第一次使用之前某类型的新实例能够正确初始化。 类类型的
-
new iSlider(DOM, DATA, OPTIONS) Name Type Description DOM dom 容器dom节点 DATA Array 数据列表 OPTIONS Object 配置项 DOM new iSlider(DOM, DATA, OPTIONS); {HTMLElement} 容器dom节点 作为第一个参数并不是必须的，会被OPTIONS.dom覆盖，但是这十分必