本文为您介绍Blink 3.2与Flink 1.5.1版本API兼容性测试的结果。
校验范围
- flink-clients
- flink-core
- flink-java
- flink-java8
- flink-optimizer
- flink-scala
- flink-scala-shell
- flink-streaming-java
- flink-streaming-scala
- flink-yarn
- flink-connectors
- flink-filesystems
- flink-formats
- flink-metrics
- flink-queryable-state
- flink-state-backends
兼容性详情
- flink-core
总计方法个数：6126。不兼容数量：1。
序号 严重程度（高、中或低） Old API Change Effect 1 中 GenericCsvInputFormat.supportsMultiPaths() supportsMultiPaths()方法从该类中删除，返回的默认值发生变化，新的默认值不支持multiPath。 所有GenericCsvInputFormat子类涉及multiPath的功能会受到影响。 - flink-connector-elasticsearch
总计方法个数：14；不兼容数量：1。
序号 严重程度（高、中或低） Old API Change Effect 1 中 ElasticsearchSink 父类从ElasticsearchSinkBase<T>变为了ElasticsearchSinkBase<T,org.elasticsearch.client.Client>。 Flink 1.5.1不兼容ElasticsearchSinkBase<T>父类的子类。
flink-json
总计方法个数：34；不兼容数量：1。
| 序号 | 严重程度（高、中、低） | Old API | Change | Effect |
|---|---|---|---|---|
| 1 | 中 | JsonSchemaConverter | 类名重命名成了JsonRowSchemaConverter。 | 子类不兼容。 |
flink-streaming-java
总计方法个数：3031。不兼容数量：4。
| 序号 | 严重程度（高、中、低） | Old API | Change | Effect |
|---|---|---|---|---|
| 1 | 中 | TwoInputStreamOperator.processElement1 or TwoInputStreamOperator.processElement2 | 返回类型从void变成TwoInputSelection。TwoInputStreamOperator中新增endInput1和endInput2 abstract方法。 | Blink 3.2不兼容所有的TwoInputStreamOperator实现，而Flink 1.5.1兼容所有的TwoInputStreamOperator实现。 |
| 2 | 中 | OneInputStreamOperator类 | 添加endInput() abstract方法。 | 不兼容所有的OneInputStreamOperator实现。 |
| 3 | 中 | StreamOperator类 | 添加requireState abstract方法。 | 不兼容所有的StreamOperator实现。 |
| 4 | 中 | OneInputStreamOperator类 | 添加了endInput() abstract方法。 | 不兼容所有的OneInputStreamOperator实现。 |