Skip to content

Commit

Permalink
[chore] remove ReportFatalError from otelarrowreceiver (#31137)
Browse files Browse the repository at this point in the history
See
#30501

---------

Co-authored-by: Pablo Baeyens <pbaeyens31+github@gmail.com>
  • Loading branch information
atoulme and mx-psi authored Feb 8, 2024
1 parent f7748b1 commit 6629b60
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions receiver/otelarrowreceiver/otelarrow.go
Original file line number Diff line number Diff line change
Expand Up @@ -76,7 +76,7 @@ func newOTelArrowReceiver(cfg *Config, set receiver.CreateSettings) (*otelArrowR
return r, nil
}

func (r *otelArrowReceiver) startGRPCServer(cfg configgrpc.GRPCServerSettings, host component.Host) error {
func (r *otelArrowReceiver) startGRPCServer(cfg configgrpc.GRPCServerSettings, _ component.Host) error {
r.settings.Logger.Info("Starting GRPC server", zap.String("endpoint", cfg.NetAddr.Endpoint))

gln, err := cfg.ToListener()
Expand All @@ -88,7 +88,7 @@ func (r *otelArrowReceiver) startGRPCServer(cfg configgrpc.GRPCServerSettings, h
defer r.shutdownWG.Done()

if errGrpc := r.serverGRPC.Serve(gln); errGrpc != nil && !errors.Is(errGrpc, grpc.ErrServerStopped) {
host.ReportFatalError(errGrpc)
r.settings.ReportStatus(component.NewFatalErrorEvent(errGrpc))
}
}()
return nil
Expand Down

0 comments on commit 6629b60

Please sign in to comment.