Return error when txn conflicted

xiaojunhong · Nov 19, 2018 · b2a6dc1 · b2a6dc1
1 parent 64043bf
commit b2a6dc1
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/command/transactions.go b/command/transactions.go
@@ -101,7 +101,11 @@ func Exec(ctx *Context) {
 			zap.String("command", ctx.Name),
 			zap.String("traceid", ctx.TraceID),
 			zap.Error(err))
-		resp.ReplyArray(ctx.Out, 0)
+		if watching {
+			resp.ReplyArray(ctx.Out, 0)
+			return
+		}
+		resp.ReplyError(ctx.Out, "EXECABORT Transaction discarded because of txn conflicts")
 		return
 	}