Hangxiang Yu created FLINK-30656:
------------------------------------
Summary: Provide more logs for schema compatibility check
Key: FLINK-30656
URL: https://issues.apache.org/jira/browse/FLINK-30656
Project: Flink
Issue Type: Improvement
Components: API / Type Serialization System
Reporter: Hangxiang Yu
Assignee: Hangxiang Yu
Currently, we have very few logs and exception info when checking schema
compatibility.
It's difficult to see why the compatibility is not compatible, especially for
some complicated nested serializers.
For example, for map serializer, when it's not compatible, we may only see
below without other information:
{code:java}
Caused by: org.apache.flink.util.StateMigrationException: The new state
serializer (org.apache.flink.api.common.typeutils.base.MapSerializer@e95e076a)
must not be incompatible with the old state serializer
(org.apache.flink.api.common.typeutils.base.MapSerializer@c33b100f). {code}
So I think we could add more infos when checking the compatibility.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
