fix: Handle duplicate registration of protocol-buffer files gracefull…

…y. (#10188) (cherry picked from commit aa642a4)
influxdata · Dec 15, 2021 · a4debb1 · a4debb1
1 parent 99c0b23
commit a4debb1
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/plugins/parsers/xpath/protocolbuffer_document.go b/plugins/parsers/xpath/protocolbuffer_document.go
@@ -1,6 +1,7 @@
 package xpath
 
 import (
+	"errors"
 	"fmt"
 	"sort"
 	"strings"
@@ -55,6 +56,13 @@ func (d *protobufDocument) Init() error {
 		if err != nil {
 			return fmt.Errorf("creating file descriptor from proto failed: %v", err)
 		}
+		if _, err := protoregistry.GlobalFiles.FindFileByPath(fileDesc.Path()); !errors.Is(err, protoregistry.NotFound) {
+			if err != nil {
+				return fmt.Errorf("searching for file %q in registry failed: %v", fileDesc.Path(), err)
+			}
+			d.Log.Warnf("Protocol buffer with path %q already registered. Skipping...", fileDesc.Path())
+			continue
+		}
 		if err := protoregistry.GlobalFiles.RegisterFile(fileDesc); err != nil {
 			return fmt.Errorf("registering file descriptor %q failed: %v", fileDesc.Package(), err)
 		}