spark从kafka里清洗数据,写入doris,每隔几个钟头就出现OOM,或者开始delay

程序把之前写入kudu的逻辑改成写入doris,除了写doris,其他的代码和之前的一样,数据量也和之前一样,之前的程序没问题,现在却总是出现oom或者delay