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

好的 我去看下 谢谢哈 -- Sent from: http://apache-flink.147419.n8.nabble.com/

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

1.10的确是存在一个这样的bug[1]，这个已经在1.10.1和1.11.0中修复了，可以尝试下1.10.1或者1.11.1版本。 [1] https://issues.apache.org/jira/browse/FLINK-16068 leiyanrui <1150693...@qq.com> 于2020年8月7日周五 下午2:32写道： > 1.10 > > > > > -- > Sent from:

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

-- Sent from: http://apache-flink.147419.n8.nabble.com/

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

1.10 -- Sent from: http://apache-flink.147419.n8.nabble.com/

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

使用的是Flink哪个版本呢？以及最好也提供一下异常信息 leiyanrui <1150693...@qq.com> 于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, >

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

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,'-MM-dd HH:mm:ss')), watermark for t as t - interval '5'

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

可以提供一下你使用的Flink版本以及DDL么？ leiyanrui <1150693...@qq.com> 于2020年8月7日周五 上午11:58写道： > 使用flinksql连接kafka，kafka的数据格式内部有个字段叫time，我在create > table的时候将time字段加了反单引号还是不行，报错，有什么别的方法吗 > > > > > -- > Sent from: http://apache-flink.147419.n8.nabble.com/ -- Best, Benchao Li

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

使用flinksql连接kafka，kafka的数据格式内部有个字段叫time，我在create table的时候将time字段加了反单引号还是不行，报错，有什么别的方法吗 -- Sent from: http://apache-flink.147419.n8.nabble.com/