Hi Folks. I have a question. I am using flink for my table api job.And I create my function named "mysplit".I want to get array result for input like "1;2;3" with my function.But I get a error: What's wrong with my sql job?:

create view dataset_v as

SELECT a.id as dataset_id,a.dataset_name_zh ,a.dataset_name_en ,a.introduction,

(SELECT c.level_path from dict_detail c WHERE c.id  in mysplit(a.industry_type_ids,";")) as level_path,

FROM dataset_info a

left join usage_statistics b on a.id=b.dataset_info_id

This is my funcion:

@FunctionHint(output = @DataTypeHint("ARRAY<f1 INT>"))
public static class MySplit extends TableFunction<List<Integer>> {
    public void eval(String str,String delimiter){
        List<Integer> ss=new ArrayList<>();
        for (String s : str.split(delimiter)) {
            ss.add( Integer.parseInt(s));
        }
        collect(ss);
    }
}