SQL语法变更

  • 语法变动

    [Over Agg] The window rank function without order by

  • 行为变动
    • [Division to double] | 隐式类型转换，从2.2版本开始生效。
    • [Decimal] DDl decimal type default precision changed to (10, 0) | Decimal的默认精度变更，从2.2版本开始生效。
    • [CEP] pattern不可以贪婪匹配结束。例如，不支持pattern (a b+)。可以通过将(a b+)转换为(a b+ c)，并把c定义为not b的方式，解决不能以贪婪匹配结束的问题。
    • [CEP] within语句不支持动态窗口。

开发接口变更

  • 重构和语义变更

    [StreamTableSink#emitDataStream returns values changes from void to StreamTableSink]

  • Class位置挪动
    • [Parser 继承 com.alibaba.blink.streaming.connectors.common.source.SourceCollector]
    • [Class not found] com/alibaba/blink/exceptions/NotEnoughParamsException
    • [Class not found] com/alibaba/blink/exceptions/UnsupportedTableException
    • [Class not found] org/apache/flink/table/sources/BatchExecTableSource
    • [Class not found] org/apache/flink/table/functions/aggfunctions/DoubleSumWithRetractAggFunction
    • [Class not found] org/apache/flink/table/functions/Monotonicity
    • [Class not found] Lcom/alibaba/blink/cache/Cache
    • [Class not found] org/apache/flink/table/row/GenericRow
  • 实现变更
    • [Method not found] com.alibaba.blink.table.api.RichTableSchema.getColumnTypes
    • [Method not found] Lorg/apache/flink/table/types/DataType.of
    • [Verification] java.lang.VerifyError: class com.koubei.blink.connector.sls.CustomTableFactory overrides final method setClassLoader
    • [Class not found] com/aliyun/odps/OdpsException

Connectors

  • [ODPS] ODPSTableSink stream mode do not support overwrite
  • [ODPS] Only batch mode support overwrite