diff --git a/app/log/command/command.go b/app/log/command/command.go index 2524c08bf..b23e25d59 100644 --- a/app/log/command/command.go +++ b/app/log/command/command.go @@ -44,6 +44,7 @@ func (s *LoggerServer) FollowLog(_ *FollowLogRequest, stream LoggerService_Follo return newError("logger not support following") } ctx, cancel := context.WithCancel(stream.Context()) + defer cancel() f := func(msg cmlog.Message) { err := stream.Send(&FollowLogResponse{ Message: msg.String(),