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.