diff --git a/kernel/sql/queue.go b/kernel/sql/queue.go index 25447d197..7ac078ae2 100644 --- a/kernel/sql/queue.go +++ b/kernel/sql/queue.go @@ -120,7 +120,7 @@ func FlushQueue() { if err = execOp(op, tx, context); nil != err { tx.Rollback() logging.LogErrorf("queue operation failed: %s", err) - return + continue } if err = commitTx(tx); nil != err {