窗口不会提前关闭，请查看下metircs是否有数据丢弃，
1530130567 <[email protected]> 于2019年12月24日周二 下午8:46写道： > 各位大佬好： > 最近在使用flink stream api处理数据，逻辑是非常简单的ETL操作 > 我自己定义的一个1分钟的tumble窗口，watermark是10s，当处在流量高峰时段时，发现下游出现了数据丢失的问题。 > 举个例子：我上游topic 5000/s,下游接受数据的topic只有4000/s > > 在流量低谷时就没有这个问题，而且我把窗口去掉后也没有这个问题，是否是窗口被提前关闭了呢？导致我下游的processfunction还没处理完？ > ps：我加大了并行度还是不行
