Dylan Adams created FLINK-12175:
-----------------------------------
Summary: TypeExtractor.getMapReturnTypes produces different
TypeInformation than createTypeInformation for classes with parameterized
ancestors
Key: FLINK-12175
URL: https://issues.apache.org/jira/browse/FLINK-12175
Project: Flink
Issue Type: Bug
Components: API / Type Serialization System
Affects Versions: 1.7.2, 1.9.0
Reporter: Dylan Adams
I expect that the {{TypeMapper}} {{createTypeInformation}} and
{{getMapReturnTypes}} would produce equivalent type information for the same
type. But when there is a parameterized superclass, this does not appear to be
the case.
Here's a test case that could be added to {{PojoTypeExtractorTest.java}} that
demonstrates the issue:
{code}
public static class Pojo implements Serializable {
public int digits;
public String letters;
}
public static class ParameterizedParent<T extends Serializable> implements
Serializable {
public T pojoField;
}
public static class ConcreteImpl extends ParameterizedParent<Pojo> {
public double precise;
}
public static class ConcreteMapFunction implements MapFunction<ConcreteImpl,
ConcreteImpl> {
@Override
public ConcreteImpl map(ConcreteImpl value) throws Exception {
return null;
}
}
@Test
public void testMapReturnType() {
final TypeInformation<ConcreteImpl> directTypeInfo =
TypeExtractor.createTypeInfo(ConcreteImpl.class);
Assert.assertTrue(directTypeInfo instanceof PojoTypeInfo);
TypeInformation<?> directPojoFieldTypeInfo = ((PojoTypeInfo)
directTypeInfo).getPojoFieldAt(0).getTypeInformation();
Assert.assertTrue(directPojoFieldTypeInfo instanceof PojoTypeInfo);
final TypeInformation<ConcreteImpl> mapReturnTypeInfo
= TypeExtractor.getMapReturnTypes(new ConcreteMapFunction(),
directTypeInfo);
Assert.assertTrue(mapReturnTypeInfo instanceof PojoTypeInfo);
TypeInformation<?> mapReturnPojoFieldTypeInfo = ((PojoTypeInfo)
mapReturnTypeInfo).getPojoFieldAt(0).getTypeInformation();
Assert.assertTrue(mapReturnPojoFieldTypeInfo instanceof PojoTypeInfo);
Assert.assertEquals(directTypeInfo, mapReturnTypeInfo);
}
{code}
This test case will fail on the last two asserts because {{getMapReturnTypes}}
produces a {{TypeInformation}} for {{ConcreteImpl}} with a {{GenericTypeInfo}}
for the {{pojoField}}, whereas {{createTypeInformation}} correctly produces a
{{PojoTypeInfo}}.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)