Please take a look at the following in flink-java/src/main/java/org/apache/flink/api/java/hadoop/mapred/HadoopInputFormat.java
public TypeInformation<Tuple2<K, V>> getProducedType() { return new TupleTypeInfo<>(TypeExtractor.createTypeInfo(keyClass), TypeExtractor.createTypeInfo(valueClass)); FYI On Sun, Aug 13, 2017 at 8:23 AM, AndreaKinn <kinn6...@hotmail.it> wrote: > But I'm using Java primitive type like String, Double plus Date types. > Flink > doesn't know how to handle them? > > > > -- > View this message in context: http://apache-flink-user- > mailing-list-archive.2336050.n4.nabble.com/TypeInformation- > in-Custom-Deserializer-tp14861p14863.html > Sent from the Apache Flink User Mailing List archive. mailing list archive > at Nabble.com. >