This topic describes the test result of API compatibility between Blink 3.2 and Flink 1.5.1.

Scope

  • 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

Compatibility details

  • flink-core
    The total number of tested methods is 6126, among which only one method is incompatible between Blink 3.2 and Flink 1.5.1.
    No. Severity (high, medium, or low) Old API Change Impact
    1 Medium GenericCsvInputFormat.supportsMultiPaths() The supportsMultiPaths() method is removed from the class, and the returned default value changes. The new default value does not support multiple paths. This change affects the GenericCsvInputFormat subclasses that involve multiple paths.
  • flink-connector-elasticsearch
    The total number of tested methods is 14, among which only one method is incompatible between Blink 3.2 and Flink 1.5.1.
    No. Severity (high, medium, or low) Old API Change Impact
    1 Medium ElasticsearchSink The class is changed from ElasticsearchSinkBase<T> to ElasticsearchSinkBase<T,org.elasticsearch.client.Client>. Flink 1.5.1 does not support the subclasses of the previous class.

flink-json

The total number of tested methods is 34, among which only one method is not compatible between Blink 3.2 and Flink 1.5.1.
No. Severity (high, medium, or low) Old API Change Impact
1 Medium JsonSchemaConverter The class is renamed JsonRowSchemaConverter. Flink 1.5.1 does not support the subclasses of the previous class.

flink-streaming-java

The total number of tested methods is 3031, among which four methods are incompatible between Blink 3.2 and Flink 1.5.1.
No. Severity (high, medium, or low) Old API Change Impact
1 Medium TwoInputStreamOperator.processElement1 or TwoInputStreamOperator.processElement2 The void return type is changed to the TwoInputSelection return type. The endInput1 and endInput2 abstract methods are added to the TwoInputStreamOperator interface. Flink 1.5.1 support TwoInputStreamOperator implementers that are not supported by Blink 3.2.
2 Medium OneInputStreamOperator class The endInput() abstract method is added. Flink 1.5.1 support OneInputStreamOperator implementers that are not supported by Blink 3.2.
3 Medium StreamOperator class The requireState abstract method is added. Flink 1.5.1 support StreamOperator implementers that are not supported by Blink 3.2.
4 Medium OneInputStreamOperator class The endInput() abstract method is added. Flink 1.5.1 support OneInputStreamOperator implementers that are not supported by Blink 3.2.