校验范围

  • 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 processElement2 void返回值变成了TwoInputSelection。TwoInputStreamOperator中新增endInput1和endInput2 abstract方法。 不兼容所有的TwoInputStreamOperator实现兼。
2 OneInputStreamOperator类 添加endInput() abstract方法。 不兼容所有的OneInputStreamOperator实现。
3 StreamOperator类 添加requireState abstract方法。 不兼容所有的StreamOperator实现。
4 OneInputStreamOperator类 添加了endInput() abstract方法。 不兼容所有的OneInputStreamOperator实现。