60' SECOND) as wEnd
from myFlinkTable GROUP BY user,TUMBLE(t, INTERVAL '60' SECOND)
-- 原始邮件 --
*发件人:* "李玥"mailto:liyue2...@gmail.com>>;
*发送时间:* 2018年4月3日(星期二) 中午11:49
*收件人:* "韩宁宁"<453673...@qq.com <mailto:453673...@qq
INTERVAL '60' SECOND)
>
>
>
> -- 原始邮件 --
> *发件人:* "李玥";
> *发送时间:* 2018年4月3日(星期二) 中午11:49
> *收件人:* "韩宁宁"<453673...@qq.com>;
> *抄送:* "user"; "skycrab68";
> *主题:* Re: subuquery ab
The exception logs tells that your table “myFlinkTable” does not contain a
column/field named “t”. Could be something wrong about your table
registration. It would be helpful to show us your table registration code,
like:
// register a Table
tableEnv.registerTable("table1", ...)
