Skip to main content

StreamWorks 6.3.2更新日志

发布时间:2024-11-25

新增

FLinkSQL维表、结果表支持Hologres数据源【6.3】【标准版】

  • 背景: FLinkSQL维表、结果表支持Hologres数据源
  • 说明:
    • FLinkSQL1.16版本维表、结果表支持Hologres数据源
    • 支持主键表、非分区表、分区表 hologres-1.png

FLinkState状态信息可视化【6.3】【标准版】

  • 背景: 基于FLink在StateProcessorAPI,通过SQL方式查询出FLink所有状态元数据信息和值信息,达到state可视化同时大幅度降低使用门槛。
  • 说明:
    • 在CK展示页面增加状态探查按钮,支持通过存储路径进行探查结果的运行、展示、输出结果等操作
    • 支持记录探查运行的状态、结果等信息
    • 任务状态探查中不支持下线任务,探查结束后允许下线任务,再次提交后不记录上一次的探查记录,需要重新探查 状态探查-2.png

数据开发-任务支持自定义任务参数【6.3】【标准版】

  • 背景: 自定义变量参数在实际的开发过程中运用场景较多需要补齐功能。
  • 说明:
    • 自定义变量参数:仅支持在对应的单个任务下使用
    • 包括任务支持生效范围:FLinkSQL的DDL、FLinkJar的命令行参数、实时采集脚本模式的JSON、PyFLink向导模式的PyFLink入参
    • 使用格式${参数名} 自定义参数-1.png

FLinkSQL支持动态cep【6.3】【标准版】

  • 背景: FLinkSQL支持动态cep满足客户对于CEP Pattern的动态更新只需更新数据库信息而不需要重新启动任务
  • 说明:
    • 脚本模式支持FLinkSQL:任务语法检查、运行、调试数据 cep-2.png

运维管理中告警规则支持对应多个告警指标【7.0】【标准版】

  • 背景: 运维管理告警支持单个告警配置多个告警指标减少配置工作
  • 说明:
    • 优化历史任务告警
    • 对相似的告警配置统一处理
    • 支持同一维度下配置多个触发告警的规则
    • 多个告警规则满足任意一个规则就触发告警 告警合并-1.png

优化

FLinkSQL Kafka Format OGG-json 支持delete操作需要同步到结果表StarRocks【6.0】【标准版】

  • 背景: FLinkSQL Kafka Format OGG-json 支持delete操作需要同步到结果表StarRocks
  • 说明:
    • FLinkSQL1.16版本支持源表kafka Format 为OGG-JSON 写入StarRocks op_type为Delete时删除数据

FLinkSQL SR3.x支持FE节点失败切换节点【6.0】【标准版】

  • 背景: FLinkSQL StarRocks3.x支持FE节点失败切换节点
  • 说明:
    • FLinkSQL1.16版本解决源表、维表、结果表在节点失败后这主动切换正常的结果

FLinkSQL支持FLinkCDC数据源可视化【6.3】【旗舰版】

  • 背景: FLinkSQL支持FLinkCDC数据源可视化
  • 说明:
    • 向导模式可视化的数据源:
      • Postgre-CDC
      • SqlServer-CDC
    • FLinkCDC目前仅在旗舰版支持使用 Flinkcdc-1.png