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/