Merge pull request #182 from xiekeyang/close-body

close response body
fission · Aug 7, 2018 · 41e17e3 · 41e17e3
2 parents 373c76e + fe0d1d6
commit 41e17e3
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/pkg/fnenv/fission/runtime.go b/pkg/fnenv/fission/runtime.go
@@ -75,10 +75,13 @@ func (fe *FunctionEnv) Invoke(spec *types.TaskInvocationSpec) (*types.TaskInvoca
 	fnenv.FnActive.WithLabelValues(Name).Inc()
 	defer fnenv.FnExecTime.WithLabelValues(Name).Observe(float64(time.Since(timeStart)))
 	ctxLog.Infof("Invoking Fission function: '%v'.", req.URL)
+
 	resp, err := http.DefaultClient.Do(req)
 	if err != nil {
 		return nil, fmt.Errorf("error for reqUrl '%v': %v", url, err)
 	}
+	defer resp.Body.Close()
+
 	fnenv.FnActive.WithLabelValues(Name).Dec()
 	fnenv.FnActive.WithLabelValues(Name).Inc()