Skip to content

Commit f9c4003

Browse files
committed
Upgrade Java Driver to 4.10.0
1 parent 0c3f497 commit f9c4003

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

driver/src/main/scala/com/datastax/spark/connector/cql/LocalNodeFirstLoadBalancingPolicy.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@ import com.datastax.oss.driver.api.core.session.{Request, Session}
1515
import com.datastax.oss.driver.internal.core.context.InternalDriverContext
1616
import com.datastax.oss.driver.internal.core.metadata.MetadataManager
1717
import com.datastax.oss.driver.internal.core.util.Reflection
18-
import com.datastax.oss.driver.internal.core.util.collection.QueryPlan
18+
import com.datastax.oss.driver.internal.core.util.collection.SimpleQueryPlan
1919
import com.datastax.spark.connector.cql.LocalNodeFirstLoadBalancingPolicy.{LoadBalancingShuffleNodes, _}
2020
import com.datastax.spark.connector.util.DriverUtil.{toAddress, toOption}
2121

@@ -119,7 +119,7 @@ class LocalNodeFirstLoadBalancingPolicy(context: DriverContext, profileName: Str
119119
} else {
120120
tokenUnawareQueryPlan(request)
121121
}
122-
new QueryPlan(nodes: _*)
122+
new SimpleQueryPlan(nodes: _*)
123123
}
124124

125125
override def onAdd(node: Node) {

project/Versions.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@ object Versions {
55
val CommonsLang3 = "3.5"
66
val Paranamer = "2.8"
77

8-
val DataStaxJavaDriver = "4.9.0"
8+
val DataStaxJavaDriver = "4.10.0"
99

1010
val ScalaCheck = "1.14.0"
1111
val ScalaTest = "3.0.8"

0 commit comments

Comments
 (0)