simenliuxing

生成watermark的字段目前只支持long和timestramp类型，TO_TIMESTAMP返回的不是这两种类型。你可以按如下方式来定义： 1.ctime是long或者timestramp类型，不需要TO_TIMESTAMP转换了，直接定义watermark就行。 2.自定义一个udf函数，如下： public class TimeParse extends ScalarFunction { public static Map dateTimeFormatterMap = new ConcurrentHashMap(); /** * 统一返回该格式 long格式的timestramp * * @param timStr * @param format * @return */...