Merge pull request #1290 from datastax/SPARKC-609-b2.5

jtgrabowski · web-flow · commit 4ea8c18945d9 · 2020-12-14T13:46:06.000+01:00
SPARKC-609 extend await time for auth clusters
diff --git a/connector/src/it/scala/com/datastax/spark/connector/SparkCassandraITFlatSpecBase.scala b/connector/src/it/scala/com/datastax/spark/connector/SparkCassandraITFlatSpecBase.scala
@@ -129,7 +129,7 @@ trait SparkCassandraITSpecBase
       */
     //For Auth Clusters we have to wait for the default User before a connection will work
     if (sparkConf.contains(DefaultAuthConfFactory.PasswordParam.name)) {
-      eventually(timeout(Span(60, Seconds))) {
+      eventually(timeout(Span(120, Seconds))) {
         CassandraConnector(sparkConf).withSessionDo(session => assert(session != null))
       }
     }

Original file line number	Diff line number	Diff line change
`@@ -129,7 +129,7 @@ trait SparkCassandraITSpecBase`
`129`	`129`	`*/`
`130`	`130`	`//For Auth Clusters we have to wait for the default User before a connection will work`
`131`	`131`	`if (sparkConf.contains(DefaultAuthConfFactory.PasswordParam.name)) {`
`132`		`- eventually(timeout(Span(60, Seconds))) {`
	`132`	`+ eventually(timeout(Span(120, Seconds))) {`
`133`	`133`	`CassandraConnector(sparkConf).withSessionDo(session => assert(session != null))`
`134`	`134`	`}`
`135`	`135`	`}`