本文为您介绍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实现。