Hi Shilpa,
Shuiqiang is right. Currently, we recommend to use SQL DDL until the
connect API is updated. See here:
https://ci.apache.org/projects/flink/flink-docs-master/docs/dev/table/sql/create/#create-table
Especially the WATERMARK section shows how to declare a rowtime attribute.
Regards,
Hi Shilpa,
There might be something wrong when defining the rowtime field with the
Connector descriptor, it’s recommended to use SQL DDL to create tables, and
do queries with table API.
Best,
Shuiqiang
Shilpa Shankar 于2021年3月4日周四 下午9:29写道：
> Hello,
>
> We are using pyflink's datastream api v1.
Hello,
We are using pyflink's datastream api v1.12.1 to consume from kafka and
want to use one of the fields to act as the "rowtime" for windowing.
We realize we need to convert BIGINT to TIMESTAMP before we use it as
"rowtime".
py4j.protocol.Py4JJavaError: An error occurred while calling o91.sel
