Question

支持 Storm 包含在 flink-storm Maven 模块中。代码驻留在 org.apache.flink.storm 包中。

pom.xml 如果要在 Flink 中执行 Storm 代码，请将以下依赖项添加到您的。

<dependency>
  <groupId>org.apache.flink</groupId>
  <artifactId>flink-storm_2.11</artifactId>
  <version>1.7-SNAPSHOT</version>
</dependency>

请注意 ：不要添加 storm-core 为依赖项。它已包含在内 flink-storm 。

请注意 ： flink-storm 不是提供的二进制 Flink 发行版的一部分。因此，您需要 flink-storm 在提交给 Flink 的 JobManager 的程序 jar（也称为 uber-jar 或 fat-jar）中包含类（及其依赖项）。见 字计数风暴 中 flink-storm-examples/pom.xml 的一个例子，如何正确地打包罐。

如果你想避免大尤伯杯罐子，你可以手动复制 storm-core-0.9.4.jar ， json-simple-1.1.jar 并 flink-storm-1.7-SNAPSHOT.jar 进入 Flink 的 lib/ 每个群集节点的文件夹（ 之前 在启动群集）。对于这种情况，仅将您自己的 Spout 和 Bolt 类（及其内部依赖项）包含在程序 jar 中就足够了。