From ea7f6923f36716486301f90c4626ff1a6c9741ec Mon Sep 17 00:00:00 2001 From: Yashash H L Date: Mon, 15 Apr 2024 12:24:40 +0530 Subject: [PATCH] doc Signed-off-by: Yashash H L --- pkg/sinker/options.go | 3 ++- pkg/sinker/service.go | 2 +- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/pkg/sinker/options.go b/pkg/sinker/options.go index 34dbcd81..361cc2e5 100644 --- a/pkg/sinker/options.go +++ b/pkg/sinker/options.go @@ -15,7 +15,8 @@ func defaultOptions() *options { defaultPath := serverInfoFilePath defaultAddress := address - if os.Getenv(EnvUDContaclinerType) == UDContainerFallbackSink { + // If the container type is fallback sink, then use the fallback sink address and path. + if os.Getenv(EnvUDContainerType) == UDContainerFallbackSink { defaultPath = fbServerInfoFilePath defaultAddress = fbAddress } diff --git a/pkg/sinker/service.go b/pkg/sinker/service.go index d6dc09b2..67f99838 100644 --- a/pkg/sinker/service.go +++ b/pkg/sinker/service.go @@ -18,7 +18,7 @@ const ( fbAddress = "/var/run/numaflow/fb-sink.sock" serverInfoFilePath = "/var/run/numaflow/sinker-server-info" fbServerInfoFilePath = "/var/run/numaflow/fb-sinker-server-info" - EnvUDContaclinerType = "NUMAFLOW_UD_CONTAINER_TYPE" + EnvUDContainerType = "NUMAFLOW_UD_CONTAINER_TYPE" UDContainerFallbackSink = "fb-udsink" )