You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/05/29 15:25:04 UTC
[jira] [Created] (FLINK-6765) PojoSerializer returns wrong
ConvertDeserializer when migration is required
Till Rohrmann created FLINK-6765:
------------------------------------
Summary: PojoSerializer returns wrong ConvertDeserializer when migration is required
Key: FLINK-6765
URL: https://issues.apache.org/jira/browse/FLINK-6765
Project: Flink
Issue Type: Bug
Components: Type Serialization System
Affects Versions: 1.3.0, 1.4.0
Reporter: Till Rohrmann
The {{PojoSerializer}} returns the wrong the ConvertDeserializer when migration is required. The reason is the following line in PojoSerializer.java:698:
{code}
if (compatResult.getConvertDeserializer() != null) {
rebuiltCache.put(previousCachedEntry.getKey(), cachedSerializer);
} else {
return CompatibilityResult.requiresMigration();
}
{code}
which should be imo
{code}
if (compatResult.getConvertDeserializer() != null) {
rebuiltCache.put(previousCachedEntry.getKey(), compatResult.getConvertDeserializer());
} else {
return CompatibilityResult.requiresMigration();
}
{code}
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)