doc

Signed-off-by: Yashash H L <[email protected]>
numaproj · Apr 15, 2024 · ea7f692 · ea7f692
1 parent 0f9fa93
commit ea7f692
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git 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
@@ -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"
 )