From d70f35f8d14bb208f6c5be130ecf36cfd9d60ac9 Mon Sep 17 00:00:00 2001
From: "leoyang.yl" <leoyang.yl@alibaba-inc.com>
Date: Tue, 2 Mar 2021 17:43:24 +0800
Subject: [PATCH] create event do not need prevkv range

---
 server/etcdserver/api/v3rpc/watch.go | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/server/etcdserver/api/v3rpc/watch.go b/server/etcdserver/api/v3rpc/watch.go
index 4531dbe60bf..c56ec4b26e7 100644
--- a/server/etcdserver/api/v3rpc/watch.go
+++ b/server/etcdserver/api/v3rpc/watch.go
@@ -391,7 +391,7 @@ func (sws *serverWatchStream) sendLoop() {
 			sws.mu.RUnlock()
 			for i := range evs {
 				events[i] = &evs[i]
-				if needPrevKV {
+				if needPrevKV && !IsCreateEvent(evs[i]) {
 					opt := mvcc.RangeOptions{Rev: evs[i].Kv.ModRevision - 1}
 					r, err := sws.watchable.Range(context.TODO(), evs[i].Kv.Key, nil, opt)
 					if err == nil && len(r.KVs) != 0 {
@@ -501,6 +501,10 @@ func (sws *serverWatchStream) sendLoop() {
 	}
 }
 
+func IsCreateEvent(e mvccpb.Event) bool {
+	return e.Type == mvccpb.PUT && e.Kv.CreateRevision == e.Kv.ModRevision
+}
+
 func sendFragments(
 	wr *pb.WatchResponse,
 	maxRequestBytes int,