SPARKC-642 ReplicaRepartitionedCassandraRDDSpec fix followup

jtgrabowski · jtgrabowski · commit 23b007a986e0 · 2021-04-07T15:25:48.000+02:00
Fix host matching in ReplicaRepartitionedCassandraRDDSpec
for 2.5 - compare String to String insteadof INetAddress to
String.
diff --git a/connector/src/it/scala/com/datastax/spark/connector/rdd/ReplicaRepartitionedCassandraRDDSpec.scala b/connector/src/it/scala/com/datastax/spark/connector/rdd/ReplicaRepartitionedCassandraRDDSpec.scala
@@ -64,7 +64,7 @@ class ReplicaRepartitionedCassandraRDDSpec extends SparkCassandraITFlatSpecBase
     val someCass = repart.joinWithCassandraTable(ks, tableName)
     someCass.partitions.foreach {
       case e: EndpointPartition =>
-        conn.hostAddresses.map(_.getHostAddress) should contain(e.endpoints.head)
+        conn.hostAddresses.map(_.getHostAddress) should contain(e.endpoints.head.getHostAddress)
       case _ =>
         fail("Unable to get endpoints on repartitioned RDD, This means preferred locations will be broken")
     }

Original file line number	Diff line number	Diff line change
`@@ -64,7 +64,7 @@ class ReplicaRepartitionedCassandraRDDSpec extends SparkCassandraITFlatSpecBase`
`64`	`64`	`val someCass = repart.joinWithCassandraTable(ks, tableName)`
`65`	`65`	`someCass.partitions.foreach {`
`66`	`66`	`case e: EndpointPartition =>`
`67`		`- conn.hostAddresses.map(_.getHostAddress) should contain(e.endpoints.head)`
	`67`	`+ conn.hostAddresses.map(_.getHostAddress) should contain(e.endpoints.head.getHostAddress)`
`68`	`68`	`case _ =>`
`69`	`69`	`fail("Unable to get endpoints on repartitioned RDD, This means preferred locations will be broken")`
`70`	`70`	`}`