Hi,
我怀疑还是你的环境不干净导致的，你pip list | grep
apache-flink看下版本是不是确实是这个。因为很多时候用户会在机器上装好几个python环境。
Best,
Xingbo
anfeng 于2020年11月18日周三 上午9:40写道：
> 我是在playgrounds环境跑到, 不过我检查的apache flink 是1.11.2;
> 跟这个会有关系吗
>
>
>
>
> --
> Sent from: http://apache-flink.147419.n8.nabble.com/
>
我是在playgrounds环境跑到, 不过我检查的apache flink 是1.11.2;
跟这个会有关系吗
--
Sent from: http://apache-flink.147419.n8.nabble.com/
Hi,
你说的这个在1.11应该已经修复了[1] ，我在本地没有复现出你这个问题
[1] https://issues.apache.org/jira/browse/FLINK-17753
Best,
Xingbo
anfeng 于2020年11月17日周二 下午5:31写道：
> 使用了你说的DDL的方式 可还是报错
>
> kafka_source_ddl = """CREATE TABLE mysource (createTime STRING,
> type
使用了你说的DDL的方式 可还是报错
kafka_source_ddl = """CREATE TABLE mysource (createTime STRING,
type BIGINT,
uid STRING,
countryId BIGINT,
Hello,
现在的descriptor的方式存在很多bug，社区已经在进行重构了。当前你可以使用DDL[1]的方式来解决问题。
[1]
https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/connectors/#how-to-use-connectors
Best,
Xingbo
刘乘九 于2020年9月29日周二 下午5:46写道：
> 各位大佬，我想尝试下pyflink 进行时间窗口下的指标统计，写了一个demo发现table APi 的group
>
各位大佬，我想尝试下pyflink 进行时间窗口下的指标统计，写了一个demo发现table APi 的group
方法报错，网上搜索了一下相关内容也没有解决问题， 想请各位大佬帮帮忙看一下是哪里写错了？
错误信息：
py4j.protocol.Py4JJavaError: An error occurred while calling o95.select.
: org.apache.flink.table.api.ValidationException: A group window expects a time
attribute for grouping in a
