Merge pull request #111549 from claudiubelu/log-compression

Fixes kubelet log compression on Windows
This commit is contained in:
Kubernetes Prow Robot 2022-08-01 13:18:41 -07:00 committed by GitHub
commit acc64759f5
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

View File

@ -393,11 +393,15 @@ func (c *containerLogManager) compressLog(log string) error {
if _, err := io.Copy(w, r); err != nil {
return fmt.Errorf("failed to compress %q to %q: %v", log, tmpLog, err)
}
// The archive needs to be closed before renaming, otherwise an error will occur on Windows.
w.Close()
f.Close()
compressedLog := log + compressSuffix
if err := c.osInterface.Rename(tmpLog, compressedLog); err != nil {
return fmt.Errorf("failed to rename %q to %q: %v", tmpLog, compressedLog, err)
}
// Remove old log file.
r.Close()
if err := c.osInterface.Remove(log); err != nil {
return fmt.Errorf("failed to remove log %q after compress: %v", log, err)
}