Hi Steve, Thanks for reaching out to the Flink community. I am pulling in Timo who might be able to help you with this question.
Best, Jark On Mon, 26 Oct 2020 at 23:10, Steve Whelan <swhe...@jwplayer.com> wrote: > Hi, > > I have a column of type *RAW('java.util.Map', ?)* that I want to pass to > a scalar function UDF. I'm using DataTypeHints but hitting an exception. > What would be the proper DataTypeHint and data type param to achieve this? > > @FunctionHint( > input = {@DataTypeHint("RAW"), @DataTypeHint("STRING")}, > output = @DataTypeHint("STRING") > ) > public static String eval(final Object map, final String key) { > // business logic > } > > > *Exception:* > > Caused by: org.apache.flink.table.api.ValidationException: Invalid input > arguments. Expected signatures are: > MAP_VALUE(RAW('java.lang.Object', '...'), STRING) > at > org.apache.flink.table.types.inference.TypeInferenceUtil.createInvalidInputException(TypeInferenceUtil.java:190) > at > org.apache.flink.table.planner.functions.inference.TypeInferenceOperandChecker.checkOperandTypesOrError(TypeInferenceOperandChecker.java:131) > at > org.apache.flink.table.planner.functions.inference.TypeInferenceOperandChecker.checkOperandTypes(TypeInferenceOperandChecker.java:89) > ... 50 more > Caused by: org.apache.flink.table.api.ValidationException: Invalid > argument type at position 0. Data type RAW('java.lang.Object', '...') > expected but RAW('java.util.Map', ?) passed. > at > org.apache.flink.table.types.inference.TypeInferenceUtil.adaptArguments(TypeInferenceUtil.java:137) > at > org.apache.flink.table.types.inference.TypeInferenceUtil.adaptArguments(TypeInferenceUtil.java:102) > at > org.apache.flink.table.planner.functions.inference.TypeInferenceOperandChecker.checkOperandTypesOrError(TypeInferenceOperandChecker.java:126) > ... 51 more > > > Thank you, > > Steve >