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)

Reply via email to