alibaba / otter

阿里巴巴分布式数据库同步系统(解决中美异地机房)
Apache License 2.0
8.06k stars 2.49k forks source link

关于提升Load批量处理问题 #1100

Open OsmondGao opened 1 year ago

OsmondGao commented 1 year ago

我看了 #863 ,调整了loadBatchSize的大小,目的是尽可能降低load频次,但是我发现在DbLoadAction的442行, DbLoadWorker worker = new DbLoadWorker(context, Arrays.asList(retryEventData), false);// 强制设置batch为false

这里强制false后,导致后面的过程还是要一条一条处理,请问这里是出于什么原因才强制false的?

quanllong commented 2 months ago

这行代码之前有个判断 if (true == partFailed) ,意思是如果部分写入失败就改为单条写入 ,因此设置batch为false