Set deadline to 10s to allow quick recovery from partitions.

dgraph-io · May 1, 2019 · 77b52ac · 77b52ac
1 parent 4f23cb0
commit 77b52ac
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/conn/node.go b/conn/node.go
@@ -376,7 +376,9 @@ func (n *Node) streamMessages(to uint64, stream *Stream) {
 	defer atomic.StoreInt32(&stream.alive, 0)
 
 	// Exit after this deadline. Let BatchAndSendMessages create another goroutine, if needed.
-	deadline := time.Now().Add(60 * time.Second)
+	// Let's set the deadline to 10s because if we increase it, then it takes longer to recover from
+	// a partition and get a new leader.
+	deadline := time.Now().Add(10 * time.Second)
 	ticker := time.NewTicker(time.Second)
 	defer ticker.Stop()