Flink批HashJoin递归超限问题随着Flink流批一体能力的迅速发展以及FlinkSQL易用性的提升,越来越多的厂商开始将Flink作为离线批处理引擎使用。在我们使用Flink进行大规模join操作时,也许会发生如下的异常,导致任务失败:Hashjoinexceededmaximumnumberofrecursions,withoutreducingpartitionsenoughtobememoryresident.字面意思即为HashJoin的递归次数超出限制。Flink批模式下的join算法有两种,即HybridHashJoin和Sort-MergeJoin。顾名思义,Hybri