我正在使用intervaljoin函数在10分钟内连接两个流。具体如下：

labelStream.intervalJoin(adLogStream)
           .between(Time.milliseconds(0), Time.milliseconds(600000))
           .process(new processFunction())
           .sink(kafkaProducer)

labelstream和adlogstream是由长id键控的原始buf类。
我们的两个输入流是巨大的。运行大约30分钟后，Kafka的输出缓慢下降，如下所示：

当数据输出开始下降时，我使用jstack和pstack多次得到以下结果：


似乎程序在rockdb的seek中受阻了。我发现一些rockdb的srt文件被迭代访问得很慢。

我试过几种方法：

1)Reduce the input amount to half. This works well.
2)Replace labelStream and adLogStream with simple Strings. This way, data amount will not change. This works well.
3)Use PredefinedOptions like SPINNING_DISK_OPTIMIZED and SPINNING_DISK_OPTIMIZED_HIGH_MEM. This still fails.
4)Use new versions of rocksdbjni. This still fails.

谁能给我一些建议吗？非常感谢你。