Hey Rong,
I don't think this is about a UDF, i reproduce the same exception with a
simple map['a','b'] where the Pojo has a Map<String,String> property
btw for the UDF i'm already doing it (clazz is based on the specific map im
creating):
@Override
public TypeInformation<?> getResultType(Class<?>[] signature) {
return Types.MAP(Types.STRING, TypeInformation.of(clazz));
}
The table schema looks good but looking at the PojoTypeInfo fields the Map
field is a GenericType<Map> - this causes the exception to be thrown on
TableEnvironment.generateRowConverterFunction
On Thu, Mar 28, 2019 at 8:56 AM Rong Rong <walter...@gmail.com> wrote:
> If your conversion is done using a UDF you need to override the
> getResultType method [1] to explicitly specify the key and value type
> information. As generic erasure will not preseve the <String,String> part
> of your code.
>
> Thanks,
> Rong
>
> [1]
> https://ci.apache.org/projects/flink/flink-docs-release-1.7/dev/table/udfs.html#scalar-functions
>
> On Wed, Mar 27, 2019 at 10:14 AM shkob1 <shahar.kobrin...@gmail.com>
> wrote:
>
>> 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/
>>
>
