flink sql on hive 批处理

Question

Caused by: java.lang.RuntimeException: Hash join exceeded maximum number of recursions, without reducing partitions enough to be memory resident. Probably cause: Too many duplicate keys.

 

关联了一个字典表，然后出现了上述错误。

Answer 1

找到了，是关联的右边的字典表出现了很多重复数据，去重之后再关联就好了。