本文为您介绍Flink半托管/ACK2.1.3版本的重大功能变更和主要修复缺陷。
版本重大功能变更
- 支持自定义Flink Pod Label。
详情请参见Flink Pod Label。
- 支持Flink 1.10镜像。
- 支持Flink 1.10用户包隔离功能。
- 支持Flink Configuration里使用占位符,动态填入配置信息。
详情请参见Deployment Defaults。
- Flink 1.10 默认使用阿里自研的Gemini State Backend。
在作业启动时,系统会自动添加以下配置,默认启动阿里自研的Gemini State Backend。
state.backend: com.alibaba.flink.statebackend.GeminiStateBackendFactory
fs.oss.impl: org.apache.hadoop.fs.aliyun.oss.AliyunOSSFileSystem
state.backend.gemini.snapshot.close.file: true
说明 如果需要使用您自己的State Backend,请在state.backend配置项中或者代码中指定State Backend。您可以使用Namespaced Defaults来设置Flink配置项默认值。 - API优化
- DeploymentTarget:新增spec.kind字段。
DeploymentTarget: metadata: ... spec: kind: kubernetes kubernetes: namespaces: vvp
- Job:新增job.spec.deploymentTarget.kind=kubernetes字段。
Job: metadata: ... spec: deploymentTarget: kind: kubernetes kubernetes: namespace: vvp
- DeploymentTarget:新增spec.kind字段。
- Deployment创建页面支持三种视图
- Standard
- Advanced
- Yaml
- 扩展Deployment和Job的Status,返回更多信息
- Job
- live status
- restarts count
- Deployment
- ClusterUnreachable
- JobFailing
- JobUnstable
- Job
主要缺陷修复
修复Flink1.8和Flink1.9镜像中oss log appender在debug log Level占用资源过大的问题。建议您使用新增的1.8.1-stream3-scala_2.11和1.9.0-stream3-scala_2.11镜像替换之前的镜像。
在文档使用中是否遇到以下问题
更多建议
匿名提交