求教flink自定义python udf时TIMESTAMP类型问题

Fri, 15 May 2020 00:34:29 -0700 

大佬们：
       有没有遇到过使用python udf的时候 DataTypes.TIMESTAMP()类型不匹配的问题啊
       自定义代码是这个：
       @udf(input_types=[DataTypes.INT(), DataTypes.INT(), 
DataTypes.TIMESTAMP()], result_type=DataTypes.INT())
       def add_new(i, j, k):
            return i + j    #k没用我就是测试一下
       使用的时候：
       st_env.from_path("source") \
          .select("a, add_new(b, c, rowtime) as sumbc") \
          .insert_into("sink")
       报这个错误：
       py4j.protocol.Py4JJavaError: An error occurred while calling o80.select.
      : org.apache.flink.table.api.ValidationException: Given parameters do not 
match any signature. 
       Actual: (java.lang.Integer, java.lang.Integer, java.time.LocalDateTime) 
       Expected: (int, int, long)
       或者是不是哪里写错了，求指导：)

回复