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
RVAL '60' SECOND) as wEnd
from myFlinkTable GROUP BY user,TUMBLE(t, INTERVAL '60' SECOND)
-- --
??: "???h";
: 2018??4??3??(??) 11:49
??: "??"<453673...@qq.com>;
: "us
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", ...)
-- --
??: ""<453673...@qq.com>;
: 2018??4??3??(??) 11:23
??: "user";
: "skycrab68";
: subuquery about flink sql
Deal All
I have a question about subquery
Deal All
I have a question about subquery of flink sql.
My sql like this:
select
user,
count(product),
TUMBLE_START(t, INTERVAL '60' SECOND) as wStart,
TUMBLE_END(t, INTERVAL '60' SECOND) as wEnd
from (
select
distinct(user
