使用的是Flink哪个版本呢？以及最好也提供一下异常信息 leiyanrui <[email protected]> 于2020年8月7日周五 下午2:18写道：
> CREATE TABLE table1 ( > bg BIGINT, > user_source BIGINT, > bossid BIGINT, > geekid BIGINT, > qq_intent BIGINT, > phone_intent BIGINT, > wechat_intent BIGINT, > `time` BIGINT, > t as to_timestamp(from_unixtime(__ts,'yyyy-MM-dd HH:mm:ss')), > watermark for t as t - interval '5' second > ) WITH ( > ... > ); > > > > -- > Sent from: http://apache-flink.147419.n8.nabble.com/ > -- Best, Benchao Li
