更新时间:2025-12-17 GMT+08:00
Flink企业级能力增强
- Flink SQL语法增强
- 多流Join场景支持配置表级别的TTL时间
- 配置Flink SQL Client支持SQL校验功能
- Flink作业大小表Join能力增强
- FlinkSQL OVER窗口支持超期退窗
- FlinkSQL Kafka和upsert-kafka Connector支持限流读
- FlinkSQL Kafka Connector支持消费drs-json格式数据
- FlinkSQL写入JDBC数据支持ignoreDelete
- FlinkSQL支持JTL(Join-To-Live)
- FlinkSQL算子并行度
- FlinkSQL JSON_VALUE函数性能优化
- FlinkSQL Lookup算子复用
- FlinkSQL Function增强
- FlinkSQL支持MultiJoin算子
- FlinkSQL Lookup Join支持PROCTIME()语法
- FlinkSQL Kafka Connector支持offset从group组中恢复,状态从CheckPoint恢复
- FlinkSQL支持RowKind过滤能力
- FlinkSql支持双流join过滤join产生的回撤
- FlinkSQL HBase支持Batch Lookup Join
- FlinkSQL 使用RocksDB Merge Operator提升Join算子性能
- FlinkSQL 使用PreState提升Join算子、TopN算子性能
- FlinkSQL SPLIT_INDEX函数性能优化
- FlinkSQL 使用Object复用特性提升FlinkSQL计算性能
- FlinkSQL支持使用Processing Time Temporal Join
- Flink Decimal计算精度增强
父主题: 使用Flink