From 083c5aa790910c5e9f7a5b807fc7576b8c44042b Mon Sep 17 00:00:00 2001 From: debug-LiXiwen <2159559677@qq.com> Date: Wed, 24 Aug 2022 19:54:35 +0800 Subject: [PATCH] fix cr suggestion Change-Id: Ic1c90803c4fe8a43d1192a65ca2d331364a50eab --- go/logic/migrator.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/go/logic/migrator.go b/go/logic/migrator.go index 23bc9c1..cec1b4d 100644 --- a/go/logic/migrator.go +++ b/go/logic/migrator.go @@ -1302,10 +1302,10 @@ func (this *Migrator) executeWriteFuncs() error { func (this *Migrator) drainApplierEventQueue() error { for { - this.throttler.throttle(nil) select { case eventStruct := <-this.applyEventsQueue: { + this.throttler.throttle(nil) if err := this.onApplyEventStruct(eventStruct); err != nil { return err }