diff --git a/pkg/mapstreamer/service.go b/pkg/mapstreamer/service.go index b6eb36a3..2e9022e0 100644 --- a/pkg/mapstreamer/service.go +++ b/pkg/mapstreamer/service.go @@ -12,7 +12,7 @@ const ( uds = "unix" defaultMaxMessageSize = 1024 * 1024 * 64 address = "/var/run/numaflow/mapstream.sock" - serverInfoFilePath = "/var/run/numaflow/mapstreamer-sever-info" + serverInfoFilePath = "/var/run/numaflow/mapstreamer-server-info" ) // Service implements the proto gen server interface and contains the map diff --git a/pkg/sideinput/options.go b/pkg/sideinput/options.go index 8567a3aa..7740be62 100644 --- a/pkg/sideinput/options.go +++ b/pkg/sideinput/options.go @@ -1,7 +1,5 @@ package sideinput -import "github.com/numaproj/numaflow-go/pkg/info" - // options is the struct to hold the server options. type options struct { sockAddr string