diff --git a/pkg/oom/v2/v2.go b/pkg/oom/v2/v2.go index a956b1c86676..f45051a2530e 100644 --- a/pkg/oom/v2/v2.go +++ b/pkg/oom/v2/v2.go @@ -70,15 +70,15 @@ func (w *watcher) Run(ctx context.Context) { continue } lastOOM := lastOOMMap[i.id] - if i.ev.OOM > lastOOM { + if i.ev.OOMKill > lastOOM { if err := w.publisher.Publish(ctx, runtime.TaskOOMEventTopic, &eventstypes.TaskOOM{ ContainerID: i.id, }); err != nil { logrus.WithError(err).Error("publish OOM event") } } - if i.ev.OOM > 0 { - lastOOMMap[i.id] = i.ev.OOM + if i.ev.OOMKill > 0 { + lastOOMMap[i.id] = i.ev.OOMKill } } }