Fix pipeline error while using Redis cluster (#158)

khorshuheng · web-flow · commit 5cd2a861bbb7 · 2022-07-08T10:50:36.000+08:00
Signed-off-by: khorshuheng &lt;khor.heng@gojek.com&gt;

Co-authored-by: khorshuheng &lt;khor.heng@gojek.com&gt;
diff --git a/spark/ingestion/src/main/scala/feast/ingestion/stores/redis/PipelineProviderFactory.scala b/spark/ingestion/src/main/scala/feast/ingestion/stores/redis/PipelineProviderFactory.scala
@@ -51,8 +51,9 @@ object PipelineProviderFactory {
   def newProvider(endpoint: RedisEndpoint): PipelineProvider = {
     if (checkIfInClusterMode(endpoint)) {
       clusterPipelineProvider(endpoint)
+    } else {
+      singleNodePipelineProvider(endpoint)
     }
-    singleNodePipelineProvider(endpoint)
   }
 
   def provider(endpoint: RedisEndpoint): PipelineProvider = {

Original file line number	Diff line number	Diff line change
`@@ -51,8 +51,9 @@ object PipelineProviderFactory {`
`51`	`51`	`def newProvider(endpoint: RedisEndpoint): PipelineProvider = {`
`52`	`52`	`if (checkIfInClusterMode(endpoint)) {`
`53`	`53`	`clusterPipelineProvider(endpoint)`
	`54`	`+ } else {`
	`55`	`+ singleNodePipelineProvider(endpoint)`
`54`	`56`	`}`
`55`		`- singleNodePipelineProvider(endpoint)`
`56`	`57`	`}`
`57`	`58`
`58`	`59`	`def provider(endpoint: RedisEndpoint): PipelineProvider = {`