实时计算Flink半托管(基于ACK)版本支持丰富的上下游存储,包括Flink开源版本所支持的上下游存储和阿里云所支持的上下游存储。

支持开源的上下游存储

实时计算Flink半托管(基于ACK)版本支持Flink1.8、Flink1.9和Flink1.10三个版本,对应的版本支持所有开源的上下游存储(Connector)。各版本所支持的具体Connector信息,请参见Flink开源社区:

支持阿里云的上下游存储

实时计算Flink半托管(基于ACK)版本也支持阿里云的上下游存储(Connector)。您在Flink1.8、Flink1.9和Flink1.10三个版本中均可以使用以下阿里云产品:
  • 源表(Source)
    • 数据总线DataHub
    • 日志服务SLS
  • 结果表(Sink)
    • 云数据库HBase版
    • 数据总线DataHub
    • 日志服务SLS
说明 对应存储的代码已上传至GitHub,您可以自行下载、编译和使用。如果您的Connector为日志服务SLS,则建议您使用OpenService的依赖,并采用Shade打包方式后重定位,避免产生包冲突问题。