Flink connector 版本发布
发布说明
使用文档:
源码下载地址:starrocks-connector-for-apache-flink
JAR 包命名规则:
- Flink 1.15 及之后:
flink-connector-starrocks-${connector_version}_flink-${flink_version}.jar
- Flink 1.15 之前:
flink-connector-starrocks-${connector_version}_flink-${flink_version}_${scala_version}.jar
JAR 包获取方式:
您可以通过以下方式获取 Flink connector 的 JAR 包:
- 从 Maven Central Repository 直接下载编译好的 JAR 包。
- 在 Maven 项目的 pom 文件添加 Flink connector 为依赖项,作为依赖下载。具体方式,参见使用文档。
- 使用源码手动编译成 JAR 包。具体方式,参见使用文档。
版本要求:
Connector | Flink | StarRocks | Java | Scala |
---|---|---|---|---|
1.2.9 | 1.15 ~ 1.18 | 2.1 及以上 | 8 | 2.11、2.12 |
1.2.8 | 1.13 ~ 1.17 | 2.1 及以上 | 8 | 2.11、2.12 |
1.2.7 | 1.11 ~ 1.15 | 2.1 及以上 | 8 | 2.11、2.12 |
注意
最新版本的 Flink connector 只维护最近3个版本的 Flink。
发布记录
1.2
1.2.9
本版本发布包含如下新增特性和问题修复。值得注意的变化是,Flink connector 已与 Flink CDC 3.0 集成,可轻松地从 CDC 数据源(如 MySQL、Kafka)构建流式 ELT 管道到 StarRocks。更多信息,您参见 Flink CDC 同步(支持 schema change)。
新增特性
- 实现 catalog 以支持 Flink CDC 3.0。#295
- 实现 FLP-191中的新 Sink API,以支持Flink CDC 3.0。#301
- 支持 Flink 1.18。#305
问题修复