Re: pyflink1.11 window groupby出错

[anfeng]

使用了你说的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/