Flink 从单个 jar 运行多个作业

Question

我有 2 个作业从 Kafka 中的 2 个主题读取数据。每个作业的业务逻辑都不同，可以并行运行，但它们使用任何常见的库、函数……所以我在一个项目 java 中编写了 2 个作业。我有任何问题要运行以上 2 个作业：

Opt1：上传一个jar（1个主类包含2个stream），运行1个job。

=> 但是使用检查点，作业 1 可能会影响作业 2 并影响性能。

Opt2：上传一个jar（2个主类对应2个流），通过EntryClass运行2个作业：

=> 但是当我运行 2 个作业时，我发现了一个错误org.apache.kafka.common.config.ConfigException: Invalid value org.apache.kafka.common.serialization.StringSerializer for configuration key.serializer: Class org.apache.kafka.common.serialization.StringSerializer could not be found. 如果我只运行 1 个作业，则不会出现错误。我认为部署相同的 2 个文件 jar 时会发生 flink 冲突。

Opt3：每个job构建一个jar，运行2个job对应2个jar：

=> 我认为类似 Opt2。

Answer 1

在您知道确定您遇到问题之前，越简单越好。因此，我首先将一个 jar 与一个工作流程（您的 Opt1）一起使用，并且只有当您遇到问题时，我才会考虑创建两个您在集群（您的 Opt3）上同时运行的 jar（每个都有自己的工作流程） .

顺便说一句，您遇到的 Opt2 问题听起来像是 jar 的包装问题。