I think the proper solution should not be Types.GENERIC(Map.class) as you
will not be able to do any success processing with the return object.
For example, Map['k', 'v'].get('k') will not work.I think there might be some problem like you suggested that they are handled as GenericType instead of Pojo type, so it is not utilizing the correct serializer. It would be great if you can share the complete code that generates the exception. -- Rong On Thu, Mar 28, 2019 at 1:56 PM shkob1 <shahar.kobrin...@gmail.com> wrote: > Apparently the solution is to force map creating using UDF and to have the > UDF return Types.GENERIC(Map.class) > That makes them compatible and treated both as GenericType > > Thanks! > > > > -- > Sent from: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/ >
