flink sql on hive 批处理

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.

 

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

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

看下是不是你的sql有问题