diff --git a/kernel/sql/queue.go b/kernel/sql/queue.go
index 8ab363c01..25447d197 100644
--- a/kernel/sql/queue.go
+++ b/kernel/sql/queue.go
@@ -118,6 +118,7 @@ func FlushQueue() {
 		context["current"] = i
 		context["total"] = total
 		if err = execOp(op, tx, context); nil != err {
+			tx.Rollback()
 			logging.LogErrorf("queue operation failed: %s", err)
 			return
 		}