Fix pipeline error while using Redis cluster (#158)

Signed-off-by: khorshuheng <[email protected]> Co-authored-by: khorshuheng <[email protected]>
feast-dev · Jul 8, 2022 · 5cd2a86 · 5cd2a86
1 parent 2be80cd
commit 5cd2a86
Showing 1 changed file with 2 additions and 1 deletion.
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 = {