From 5712aafba93253b72616bd562e5d22836c1440b6 Mon Sep 17 00:00:00 2001
From: "li.peng" <mi_duo@live.com>
Date: Mon, 16 Mar 2020 18:45:33 +0800
Subject: [PATCH] fix: context cancel (#1350)

Co-authored-by: Asim Aslam <asim@aslam.me>
---
 util/kubernetes/client/watch.go | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/util/kubernetes/client/watch.go b/util/kubernetes/client/watch.go
index c55a406a..833ee534 100644
--- a/util/kubernetes/client/watch.go
+++ b/util/kubernetes/client/watch.go
@@ -98,10 +98,12 @@ func newWatcher(req *api.Request) (Watcher, error) {
 	// do the raw request
 	res, err := req.Raw()
 	if err != nil {
+		cancel()
 		return nil, err
 	}
 
 	if res.StatusCode < 200 || res.StatusCode >= 300 {
+		cancel()
 		// close the response body
 		res.Body.Close()
 		// return an error