Re: flinksql连接kafka，数据里面有个字段名字是time

[leiyanrui]

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/