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. |