khorshuheng
diff --git a/‎spark/ingestion/src/main/scala/feast/ingestion/errorhanders/RetryStrategy.scala‎
Lines changed: 0 additions & 37 deletions b/‎spark/ingestion/src/main/scala/feast/ingestion/errorhanders/RetryStrategy.scala‎
Lines changed: 0 additions & 37 deletions
diff --git a/‎spark/ingestion/src/main/scala/feast/ingestion/stores/redis/ClusterPipelineProvider.scala‎
Lines changed: 1 addition & 15 deletions b/‎spark/ingestion/src/main/scala/feast/ingestion/stores/redis/ClusterPipelineProvider.scala‎
Lines changed: 1 addition & 15 deletions
diff --git a/‎spark/ingestion/src/test/scala/feast/ingestion/errorhandlers/RetryStrategySpec.scala‎
Lines changed: 0 additions & 68 deletions b/‎spark/ingestion/src/test/scala/feast/ingestion/errorhandlers/RetryStrategySpec.scala‎
Lines changed: 0 additions & 68 deletions
@@ -16,14 +16,10 @@
  */
 package feast.ingestion.stores.redis
 
-import feast.ingestion.errorhanders.RetryStrategy
-import redis.clients.jedis.exceptions.JedisClusterOperationException
 import redis.clients.jedis.{ClusterPipeline, DefaultJedisClientConfig, HostAndPort}
 import redis.clients.jedis.providers.ClusterConnectionProvider
 
 import scala.collection.JavaConverters._
-import scala.concurrent.duration.DurationInt
-import scala.util.{Failure, Success, Try}
 
 /**
   * Provide pipeline for Redis cluster.
@@ -35,17 +31,7 @@ case class ClusterPipelineProvider(endpoint: RedisEndpoint) extends PipelineProv
     .builder()
     .password(endpoint.password)
     .build()
-  val MAX_RECONNECTION_ATTEMPT = 2
-  val RETRY_INTERVAL           = 2.seconds
-  val provider                 = RetryStrategy.fixedBackOff(RETRY_INTERVAL, MAX_RECONNECTION_ATTEMPT)(getProvider)
-
-  def getProvider: Either[JedisClusterOperationException, ClusterConnectionProvider] = {
-    Try { new ClusterConnectionProvider(nodes, DEFAULT_CLIENT_CONFIG) } match {
-      case Success(provider)                          => Right(provider)
-      case Failure(e: JedisClusterOperationException) => Left(e)
-      case Failure(e)                                 => throw e
-    }
-  }
+  val provider = new ClusterConnectionProvider(nodes, DEFAULT_CLIENT_CONFIG)
 
   /**
     * @return a cluster pipeline