Tzu-Li (Gordon) Tai created FLINK-11075:
-------------------------------------------
Summary: Remove redundant code path in CompatibilityUtil
Key: FLINK-11075
URL:
https://issues.apache.org/jira/browse/FLINK-11075 Project: Flink
Issue Type: Improvement
Components: Type Serialization System
Reporter: Tzu-Li (Gordon) Tai
Assignee: Tzu-Li (Gordon) Tai
Fix For: 1.8.0
In {{CompatibilityUtil#resolveCompatibilityResult}}:
```
CompatibilityResult<T> initialResult = resolveCompatibilityResult(
(TypeSerializerSnapshot<T>) precedingSerializerConfigSnapshot,
newSerializer);
if (!initialResult.isRequiresMigration()) {
return initialResult;
} else {
if (precedingSerializer != null && !(precedingSerializer.getClass().equals(dummySerializerClassTag))) {
// if the preceding serializer exists and is not a dummy, use
// that for converting instead of any provided convert deserializer
return CompatibilityResult.requiresMigration((TypeSerializer<T>) precedingSerializer);
} else {
// requires migration (may or may not have a convert deserializer)
return initialResult;
}
```
{{initialResult}} can actually be returned already, since the case where we try to provide a convert deserializer is no longer relevant. We do not need to check if a convert deserializer is provided because that will never be the case.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)