diff --git a/src/coordinator/protobuf_client.go b/src/coordinator/protobuf_client.go index 82c8d0e3ca..750088d7fc 100644 --- a/src/coordinator/protobuf_client.go +++ b/src/coordinator/protobuf_client.go @@ -123,6 +123,7 @@ func (self *ProtobufClient) MakeRequest(request *protocol.Request, responseStrea self.requestBufferLock.Lock() delete(self.requestBuffer, *request.Id) self.requestBufferLock.Unlock() + self.reconnect() return err }