0

我们有一个简单的状态函数作业,调用 HTTP 端点(在 AWS 上通过弹性负载均衡器)并将结果推送到 Kafka。

  • 创建了一个要部署在独立集群(它不是 docker Image)上的 jar 文件,仅包括 module.yaml 文件。我们statefun-flink distribution在该 jar 文件中添加了 3.0.0 版本作为依赖项。

  • 将我们的作业配置中的 Entry 类设置为,org.apache.flink.statefun.flink.core.StatefulFunctionsJob并在资源文件夹中简单地保留一个 module.yaml 文件,用于 jar 文件中的模块配置。

我想在运行时通过命令行或任何其他允许在启动作业时传递所需模块定义(例如,module_dev_env.yaml)的方式设置模块定义。有可能这样做还是我应该选择不同的选择?

4

0 回答 0