Re: pyflink1.11 window groupby出错

[Xingbo Huang]

Hi,

你说的这个在1.11应该已经修复了[1] ，我在本地没有复现出你这个问题

[1] https://issues.apache.org/jira/browse/FLINK-17753

Best,
Xingbo

anfeng <anf...@akulaku.com> 于2020年11月17日周二 下午5:31写道：

> 使用了你说的DDL的方式   可还是报错
>
>     kafka_source_ddl = """CREATE TABLE mysource (createTime STRING,
>                                                  type BIGINT,
>                                                  uid STRING,
>                                                  countryId BIGINT,
>                                                  data STRING,
>                                                  rowtime as
> TO_TIMESTAMP(createTime),
>                                                  WATERMARK FOR rowtime AS
> rowtime - INTERVAL '2' SECOND
>                                                  ) WITH (...)
>
>
> py4j.protocol.Py4JJavaError: An error occurred while calling o21.select.
> : org.apache.flink.table.api.ValidationException: A group window expects a
> time attribute for grouping in a stream environment.
>
>
>
> --
> Sent from: http://apache-flink.147419.n8.nabble.com/
>