flink时间窗口

[爱吃鱼]

你好，我最近业务上需要处理一个流式的时间处理窗口，部分业务代码如下
SingleOutputStreamOperator<Tuple2<warningPojo, String>> operator = 
flatMap.keyBy(0,1)
                .timeWindow(Time.minutes(1))
                .process(new ProcessWindowFunction)
当我运行的时候只有第一分钟的时间窗口会有数据进来，之后便没有数据进来了，业务逻辑代码也没有报错，请问这是什么原因。