click_info的类型是DataStream类型的；
Message我自己定义的POJO；
然后由DataStream转换为table的时候指定字段的代码如下：
转换为table之后在table上执行window算子操作
提交到集群之后一直报这个错：
问题：如何在DataStream[POJO]转换为表，表的schema中定义rowtime字段信息？定义rowtime字段信息后执行window算子将窗口alias 为W，在接下来的SQL查询中无法识别W，这个问题是怎么解决的？感谢大佬
在此基础上我对代码做了修改：
任务是跑起来了但是，文件下的size始终为0，没有输出
麻烦看下是哪出问题了，谢谢！
写回答
你的 rowtime 定义的没有问题，window 写法也没问题， alias 也没有问题。
问题出在你在最后的 select 中，用了 over window 语法, 也就是 clicks.sum over w, impressions.sum over w。over Window 的语法，请参考 https://ci.apache.org/projects/flink/flink-docs-master/dev/table/sql.html 搜索 over window，
如果只是想做 window aggregare， 直接 clicks.sum, impressions.sum即可。
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
