各位大佬,我使用flink读取实时数据时,设置窗口长度为1小时进行逻辑计算,12:00~12:59时间段内的数据可以读进flink,但是无法进入窗内计算,其他时间段正常,请问各位知道如何解决吗? 部分代码如下: env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime); .timeWindow(Time.hours(1))
急求解决方案,谢谢!*来自志愿者整理的flink
可以检查一下,指定的事件时间,是否格式化有问题,不出意外应该是选用的12小时制,改成24小时制就好了……*来自志愿者整理的flink
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。