diff --git a/pkg/util/conntrack/BUILD b/pkg/util/conntrack/BUILD index 958fba489aa..a3d89e15ed1 100644 --- a/pkg/util/conntrack/BUILD +++ b/pkg/util/conntrack/BUILD @@ -7,6 +7,7 @@ go_library( visibility = ["//visibility:public"], deps = [ "//staging/src/k8s.io/api/core/v1:go_default_library", + "//vendor/k8s.io/klog/v2:go_default_library", "//vendor/k8s.io/utils/exec:go_default_library", "//vendor/k8s.io/utils/net:go_default_library", ], diff --git a/pkg/util/conntrack/conntrack.go b/pkg/util/conntrack/conntrack.go index 204e05dd1e5..edec3028b04 100644 --- a/pkg/util/conntrack/conntrack.go +++ b/pkg/util/conntrack/conntrack.go @@ -22,6 +22,7 @@ import ( "strings" v1 "k8s.io/api/core/v1" + "k8s.io/klog/v2" "k8s.io/utils/exec" utilnet "k8s.io/utils/net" ) @@ -62,10 +63,12 @@ func Exec(execer exec.Interface, parameters ...string) error { if err != nil { return fmt.Errorf("error looking for path of conntrack: %v", err) } + klog.V(4).Infof("Clearing conntrack entries %v", parameters) output, err := execer.Command(conntrackPath, parameters...).CombinedOutput() if err != nil { return fmt.Errorf("conntrack command returned: %q, error message: %s", string(output), err) } + klog.V(4).Infof("Conntrack entries deleted %s", string(output)) return nil }