Jacek Wislicki created FLINK-34436:
--------------------------------------
Summary: Avro schema evolution and compatibility issues
Key: FLINK-34436
URL: https://issues.apache.org/jira/browse/FLINK-34436
Project: Flink
Issue Type: Bug
Components: Connectors / Pulsar
Affects Versions: 1.17.2
Reporter: Jacek Wislicki
We noticed a couple of critical issues in the Pulsar-Flink connector related to
schema evolution and compatibility. Please see the MRE available at
https://github.com/JacekWislicki/test11. More details are in the project's
README file, here is the summary:
Library versions:
* Pulsar 3.0.1
* Flink 1.17.2
* Pulsar-Flink connector 4.1.0-1.17
Problems:
* Exception thrown when schema's fields are added/removed
* Avro's enum default value is ignored, instead the last known applied
I believe that I observed the same behaviour in the Pulsar itself, still now we
are focusing on the connector, hence I was able to document the problems when
using it.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)