最近flinksql采用2阶段提交写doris时总是报[INTERNAL_ERROR]cancelled: [CANCELLED]Process memory not enough, cancel top memory used load:

详细日志信息：
"Message": "[INTERNAL_ERROR]cancelled: [CANCELLED]Process memory not enough, cancel top memory used load: <Load#Id=xxxxxxxxx> consumption 376.32 KB, backend xx.xx.xx.xxx, process memory used 148.98 GB exceed limit 148.92 GB or sys available memory 13.10 GB less than low water mark 8.29 GB. Execute again after enough memory, details see be.INFO."
总是报内存不足，从程序层面可以如何优化啊？