SQL syntax changes
- Syntax changes
[Over Agg] The window rank function without order by
- Behavior changes
- [Division to double] | As of Blink 2.2, the division data type can be implicitly converted to the double data type.
- [Decimal] DDL decimal type default precision changed to (10, 0) | As of Blink 2.2, the default precision for the decimal data type changes.
- [CEP] A pattern cannot end with a portion that is used for greedy matching. For example, the (a b+) pattern is not supported. To resolve this issue, you can change the pattern to (a b+ c) and define c as not b.
- [CEP] The WITHIN clause does not support dynamic windows.
Interface changes
- Code refactoring and semantic changes
[StreamTableSink#emitDataStream returns values changes from void to StreamTableSink]
- Class relocation
- [Parser inherited 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
- Implementation changes
- [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