skip wrong sink

River-sh · Apr 25, 2024 · d254605 · d254605
1 parent 2e79815
commit d254605
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/pkg/exporter/cmd/server.go b/pkg/exporter/cmd/server.go
@@ -309,7 +309,8 @@ func (i *inspServer) start(cfg *InspServerConfig) error {
 		sinks, err := createSink(cfg.EventConfig.EventSinks)
 		if err != nil {
 			log.Errorf("failed create sinks, err: %v", err)
-			return
+		} else if len(sinks) != len(cfg.EventConfig.EventSinks) {
+			log.Warnf("expected to create %d sinks , but %d were created", len(cfg.EventConfig.EventSinks), len(sinks))
 		}
 
 		log.Infof("start event server")
@@ -366,7 +367,8 @@ func createSink(sinkConfigs []EventSinkConfig) ([]sink.Sink, error) {
 	for _, config := range sinkConfigs {
 		s, err := sink.CreateSink(config.Name, config.Args)
 		if err != nil {
-			return nil, fmt.Errorf("failed create sink %s, err: %w", config.Name, err)
+			log.Errorf("failed create sink %s, err: %v", config.Name, err)
+			continue
 		}
 		ret = append(ret, s)
 	}