本文为您介绍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() 该override方法从该类中删除,返回的默认值发生变化,新的默认值不支持multiPath。 所有GenericCsvInputFormat子类涉及multiPath的功能会受到影响。 - flink-connector-elasticsearch
总计方法个数:14;不兼容数量:1。
序号 严重程度(高、中或低) Old API Change Effect 1 中 ElasticsearchSink 父类从ElasticsearchSinkBase<T>变为了ElasticsearchSinkBase<T,org.elasticsearch.client.Client>。 子类不兼容。
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方法。 | 不兼容所有的TwoInputStreamOperator实现。 |
2 | 中 | OneInputStreamOperator类 | 添加endInput() abstract方法。 | 不兼容所有的OneInputStreamOperator实现。 |
3 | 中 | StreamOperator类 | 添加requireState abstract方法。 | 不兼容所有的StreamOperator实现。 |
4 | 中 | OneInputStreamOperator类 | 添加了endInput() abstract方法。 | 不兼容所有的OneInputStreamOperator实现。 |
在文档使用中是否遇到以下问题
更多建议
匿名提交