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

…y. (influxdata#10188)
powersj · Jan 21, 2022 · 99b558f · 99b558f
1 parent 57ca11a
commit 99b558f
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)
 		}