regular join确实是这样，所以量大的话可以用interval join 、temporal join
> 2020年7月5日 下午3:50，忝忝向仧 <[email protected]> 写道： > > Hi,all: > > 我看源码里写到JoinedStreams: > 也就是说join时候都是走内存计算的，那么如果某个stream的key值过多，会导致oom > 那么有什么预防措施呢? > 将key值多的一边进行打散？ > > > Right now, the join is being evaluated in memory so you need to ensure that > the number > * of elements per key does not get too high. Otherwise the JVM might crash.
