Flink 的插件机制会在启动时动态加载一次，使用 Java SPI 机制实现插件，方便扩展和管理，使 Flink 可以专注于计算。

Flink 插件代码在 Flink 的 plugins 文件夹中。

plugin

  1. 文件系统插件

    文件系统的插件机制在 Flink version 1.9 中引入，从 1.10 开始，s3 插件必须通过插件机制加载

  2. connector 插件

    引用站外地址，不保证站点的可用性和安全性
    Flink SQL 原理之 Connector 插件机制
    墨天轮

  3. 资源插件

    引用站外地址，不保证站点的可用性和安全性
    扩展资源框架
    Flink