flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From shkob1 <shahar.kobrin...@gmail.com>
Subject Calcite SQL Map to Pojo Map
Date Wed, 27 Mar 2019 17:06:29 GMT
Im trying to convert a SQL query that has a select map[..] into a pojo with
Map (using tableEnv.toRestractedStream )
It seems to fail when the field requestedTypeInfo is GenericTypeInfo with
GenericType<java.util.Map> while the field type itself is MapTypeInfo with
Map<String,String>


Exception in thread "main" org.apache.flink.table.api.TableException: Result
field does not match requested type. Requested: GenericType<java.util.Map>;
Actual: Map<String, String>

Any suggestion? 
Shahar



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Mime
View raw message