中午十二点的数据无法进入窗口计算

[赫里斯汀的树]

Hi,All


我使用flink读取实时数据时，设置窗口长度为1小时进行逻辑计算，12:00~12:59时间段内的数据可以读进flink，但是无法进入窗内计算，其他时间段正常，请问各位知道如何解决吗？
部分代码如下：
  env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime);
    .timeWindow(Time.hours(1))
       
急求解决方案，谢谢！

[熊云昆]

无法进入窗口计算是说窗口没有输出结果还是窗口里面的aggregateFunction都无法执行？代码贴全一点看一下


| |
熊云昆
|
|
邮箱：[hidden email]
|

签名由 网易邮箱大师 定制

在2020年10月15日 15:47，赫里斯汀的树 写道：
Hi,All


我使用flink读取实时数据时，设置窗口长度为1小时进行逻辑计算，12:00~12:59时间段内的数据可以读进flink，但是无法进入窗内计算，其他时间段正常，请问各位知道如何解决吗？
部分代码如下：
  env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime);
    .timeWindow(Time.hours(1))
     
急求解决方案，谢谢！

[x_gothicist]

可以检查一下，指定的事件时间，是否格式化有问题，不出意外应该是选用的12小时制，改成24小时制就好了……




------------ 原始邮件 ------------------
发件人:                                                                                                                        "user-zh"                                                                                    <[hidden email]&gt;;
发送时间:&nbsp;2020年10月15日(星期四) 下午3:47
收件人:&nbsp;"user-zh"<[hidden email]&gt;;

主题:&nbsp;中午十二点的数据无法进入窗口计算



Hi,All


我使用flink读取实时数据时，设置窗口长度为1小时进行逻辑计算，12:00~12:59时间段内的数据可以读进flink，但是无法进入窗内计算，其他时间段正常，请问各位知道如何解决吗？
部分代码如下：
&amp;nbsp; env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime);
&amp;nbsp; &amp;nbsp; .timeWindow(Time.hours(1))
       
急求解决方案，谢谢！

[x_gothicist]

可以检查一下，指定的事件时间，是否格式化有问题，不出意外应该是选用的12小时制，改成24小时制就好了……




------------------&nbsp;原始邮件&nbsp;------------------
发件人:                                                                                                                        "user-zh"                                                                                    <[hidden email]&gt;;
发送时间:&nbsp;2020年10月16日(星期五) 上午7:27
收件人:&nbsp;"赫里斯汀的树"<[hidden email]&gt;;
抄送:&nbsp;"user-zh"<[hidden email]&gt;;
主题:&nbsp;回复：中午十二点的数据无法进入窗口计算



无法进入窗口计算是说窗口没有输出结果还是窗口里面的aggregateFunction都无法执行？代码贴全一点看一下


| |
熊云昆
|
|
邮箱：[hidden email]
|

签名由 网易邮箱大师 定制

在2020年10月15日 15:47，赫里斯汀的树 写道：
Hi,All


我使用flink读取实时数据时，设置窗口长度为1小时进行逻辑计算，12:00~12:59时间段内的数据可以读进flink，但是无法进入窗内计算，其他时间段正常，请问各位知道如何解决吗？
部分代码如下：
&amp;nbsp; env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime);
&amp;nbsp; &amp;nbsp; .timeWindow(Time.hours(1))
&nbsp;&nbsp;&nbsp;&nbsp;
急求解决方案，谢谢！