更新时间:2022-09-30 GMT+08:00

概述

本章节内容适用于MRS 3.x及后续版本。

Flink从0.10.0版本开始提供了一套API可以将使用Storm API编写的业务平滑迁移到Flink平台上,只需要极少的改动即可完成。通过这项转换可以覆盖大部分的业务场景。

Flink支持两种方式的业务迁移:

  1. 完整迁移Storm业务:转换并运行完整的由Storm API开发的Storm拓扑。
  2. 嵌入式迁移Storm业务:在Flink的DataStream中嵌入Storm的代码,如使用Storm API编写的Spout/Bolt。

Flink提供了flink-storm包用来完成上述转换。