链接错了。重发下。 1) 所谓时间属性，不是指 timestamp 类型的字段，而是一个特殊概念。可以看下文档如果声明时间属性： https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/table/streaming/time_attributes.html <https://ci.apache.org/projects/flink/flink-docs-release-1).12/dev/table/streaming/time_attributes.html> 2) 你的代码好像也不对。 L45: Table orders = tEnv.from("Orders"); 没看到你有注册过 "Orders" 表。这一行应该执行不成功把。
Best, Jark On Thu, 10 Dec 2020 at 11:09, Jark Wu <imj...@gmail.com> wrote: > 1). 所谓时间属性，不是指 timestamp 类型的字段，而是一个特殊概念。可以看下文档如果声明时间属性： > https://ci.apache.org/projects/flink/flink-docs-release-1).12/dev/table/streaming/time_attributes.html > 2. 你的代码好像也不对。 L45: Table orders = tEnv.from("Orders"); 没看到你有注册过 "Orders" > 表。这一行应该执行不成功把。 > > Best, > Jark > > On Wed, 9 Dec 2020 at 15:44, Appleyuchi <appleyu...@163.com> wrote: > >> 代码是: >> https://paste.ubuntu.com/p/gVGrj2V7ZF/ >> 报错: >> A group window expects a time attribute for grouping in a stream >> environment. >> 但是代码的数据源中已经有时间属性了. >> 请问应该怎么修改代码? >> 谢谢 >> >> >> >> >> >> >> > >
