本文为您介绍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
  • Deployment创建页面支持三种视图
    • Standard
    • Advanced
    • Yaml
  • 扩展Deployment和Job的Status，返回更多信息
    • Job
      • live status
      • restarts count
    • Deployment
      • ClusterUnreachable
      • JobFailing
      • JobUnstable

主要缺陷修复

修复Flink1.8和Flink1.9镜像中oss log appender在debug log Level占用资源过大的问题。建议您使用新增的1.8.1-stream3-scala_2.11和1.9.0-stream3-scala_2.11镜像替换之前的镜像。