Skip to main content

StreamWorks 6.3.7更新日志

发布时间：2025-07-07​

新增​

FlinkSQL代码辅助自动补全【6.3】【旗舰版】​

  • 背景：提供实时的代码建议和完成，旨在帮助开发人员更轻松的编写SQL。
  • 说明：

    • AI SQL 智能提示,提供实时的代码建议和完成，旨在帮助开发人员更轻松的编写SQL。

    • 代码补全支持DTAI内部开发dt_gptq_qwen_int8模型。

    • 代码补全仅支持FlinkSQL任务，不区分Flink版本。

    • 支持在IDE页面开关自动补全功能。

    • 代码补全支持全部补全、部分补全功能。

    • 支持通过上下文注释内容生成SQL补全。

      AI-返回写插入语句.png

全局告警增加运行超长（超过7天）告警触发方式【6.3】【标准版】​

  • 背景：Gate交付性需求

  • 说明：

    • 全局告警增加运行超长（超过7天）告警触发方式

    • 开始时间计算从任务运行状态为运行中开始时间计算

      告警-运行时长.png

实时采集PG来源写入Kafka支持多对多映射配置【6.3】【标准版】​

  • 背景：Gate交付性需求
  • 说明：

    • 实时采集 来源表PG 目标Kafka，多个PG表写入不同的Topic中，支持通过配置相对应的关系。

    • 需要目标写入Kafka支持自动建Topic。

      pg-kafka-映射.png

数据导出及前端页面添加水印功能【6.3】【标准版】​

  • 背景：Gate交付性需求。数据导出加入水印主要用于溯源追踪、责任认定、版权保护和合规管控，防止数据泄露和滥用。

  • 说明：

    • 实时前端页面添加水印：

      - 实时计算全部页面实现水印功能。
      - 对接公共组件水印管理，是否前端页面开启水印功能。支持自定义、内置两种水印方式。

      水印-1.png

Flink引擎侧适配gaussdb for pg替换成pg驱动【6.2】​

  • 背景：北京军博-定制交付性需求，原使用PG采集无法使用需要新支持GaussDB For PG数据源
  • 说明：
    • 计算引擎Flink1.16 将PG驱动替换成GuassDB FOR PG驱动

实时任务血缘支持FlinkSQL视图语法【6.0】​

  • 背景: 中信建投-定制交付性需求
  • 说明:
    • FlinkSQL1.12、1.16支持Flinksql视图语法
    • 支持验证以下数据源：oushu、mysql、oracel、ob、sr、gp、dm、kafka、hbase

FlinkSQL代码辅助自动补全【6.0】​

  • 背景: 中信建投-定制交付性需求
  • 说明:
    • AI SQL 智能提示,提供实时的代码建议和完成，旨在帮助开发人员更轻松的编写SQL。

实时对接本地DTAI、在线回答、SQL优化、SQL解释、日志智能解析功能【6.0】​

  • 背景: 中信建投-定制交付性需求
  • 说明:
    • 数栈Release6.3版本中实现的AI功能迁移到中信建投定制分支；
    • 对接主流大模型（通义灵码、Deepseek），实现各种AI辅助编程功能，AIAgent平台支持对大模型的快速切换；
    • 支持在线问答功能，通过API与大模型交互，快速输出问答结果；
    • 支持智能SQL优化，可以选定一段SQL要求大模型进行优化；
    • 支持智能SQL代码解释，可以选定一段SQL要求大模型进行解释；
    • 支持智能日志错误日志分析，并给出修改建议。

FlinkSQL1.12、1.16支持AnalyticDB PostgreSQL结果表适配【6.3】【标准版】​

  • 背景: 厦门国际银行-定制交付性需求
  • 说明:

    • 数栈6.0版本「定制」（Flink1.12）

    • 数栈6.3版本「标准」（Flink1.12、Flink1.16）

    • FlinkSQL1.12、1.16支持AnalyticDB PostgreSQL结果表适配

      adb-for-pg.png

优化​

全局告警优化告警抑制周期支持配置不同的分钟级别周期【6.3】【标准版】​

  • 背景: 能增强场景适应性、提升告警有效性、改善用户体验
  • 说明:
    • 修改告警抑制：发送触发时长、抑制发送告警时长
      - 发送触发时长：非空数字类型、大于0的整数、最大值不做限制
      - 抑制发送告警时长：非空数字类型、大于0的整数、最大值不做限制
      告警-1.png

实时产品前端页面整体优化【6.3】【标准版】​

  • 背景: 实时产品前端页面整体优化
  • 说明:
    • 执行提示语句优化 -批处理修改标题--数据重刷
    • 产品首页-表热度添加问号提示框
    • 任务运维-任务健康分在运行中展示，其他状态区分不做展示
    • 任务运维-运维总览-扣分项从统一的入口进去，当前的也是跳转到同一个链接中，无法做到定位数据位置
    • 角色管理-元数据管理权限名修改

FlinkSQL自定义connector使用filesystem支持parquet和orc【6.3】【标准版】​

  • 背景: Gate交付性需求
  • 说明:
    • FlinkSQL自定义connector使用filesystem支持parquet和orc