是的，对应参数没有填写正确，感谢；
另外请教，udf函数是不是目前不支持python的可变参数，我使用可变参数依然会报错参数不对的问题。
在 2020-06-01 11:01:34，"Dian Fu" <[email protected]> 写道：
>The input types should be as following:
>
>input_types=[DataTypes.STRING(), DataTypes.ARRAY(DataTypes.STRING())]
>
>Regards,
>Dian
>
>> 在 2020年6月1日，上午10:49，刘亚坤 <[email protected]> 写道：
>>
>> 目前在学习使用pyflink的Table api，请教一个pyflink udf函数报错问题：
>>
>> @udf(input_types=[DataTypes.STRING()], result_type=DataTypes.STRING())
>> def drop_fields(message, *fields):
>> import json
>> message = json.loads(message)
>> for field in fields:
>> message.pop(field)
>> return json.dumps(message)
>>
>>
>> st_env \
>> .form_path("source") \
>> .select("drop_fields(message,'x')") \
>> .insert_into("sink")
>>
>> message 格式：
>> {“a”:"1","x","2"}
>>
>> 报错参数类型不匹配：
>> Actual：（java.lang.String, java.lang.String）
>> Expected:(org.apache.flink.table.dataformat.BinaryString)
>>
>> 新手入门，请多指教，感谢。
>
