From 410b4016fd3dc97cdaf0a8e2bc20726900db772e Mon Sep 17 00:00:00 2001 From: ilackarms Date: Sat, 13 Jan 2018 13:14:31 -0500 Subject: [PATCH] periodically flush writer --- staging/src/k8s.io/apiserver/pkg/server/filters/compression.go | 1 + 1 file changed, 1 insertion(+) diff --git a/staging/src/k8s.io/apiserver/pkg/server/filters/compression.go b/staging/src/k8s.io/apiserver/pkg/server/filters/compression.go index 6303ab54a5..6bedfadea7 100644 --- a/staging/src/k8s.io/apiserver/pkg/server/filters/compression.go +++ b/staging/src/k8s.io/apiserver/pkg/server/filters/compression.go @@ -136,6 +136,7 @@ func (c *compressionResponseWriter) Write(p []byte) (int, error) { return -1, errors.New("compressing error: tried to write data using closed compressor") } c.Header().Set(headerContentEncoding, c.encoding) + defer c.compressor.Flush() return c.compressor.Write(p) }