Can anybody tell me what changes I need to made to the code below running on 2.0.8 spark connector vs 3.0.0 which uses java-driver-core 4.0.0
I am getting an error on code that was calling com.datastax.driver.core.Cluster
There is seem to be gone. This code does not work:
Cluster cluster = Cluster.builder().addContactPoints(hosts.split(","))
.withSSL()
.withCredentials(user, password)
.build();
I found the instructions here:https://docs.datastax.com/en/developer/java-driver/4.3/manual/core/.
which simple instructions:
CqlSessionBuilder builder = CqlSession.builder()
.addContactPoint(new InetSocketAddress("1.2.3.4", 9042))
.addContactPoint(new InetSocketAddress("5.6.7.8", 9042))
.withSslContext(new SSLContext())
.withCredentials(user, password)
.with(keySpace)
.build();
However the SSL is not as easy as before. The instructions are here https://docs.datastax.com/en/developer/java-driver/4.3/manual/core/ssl/
However they don't look at simple. Before I needed to specify connect on the session. Now it appears that build connects automatically.
The Spark Cassandra connector 3.0.0 uses Java driver v4.7 (whereas v2.0 of the connector used Java driver v3.0).
The Java driver was redesigned in version 4 so it is not binary-compatible with older versions. You will need to rewrite your application to use the new API.
You are correct that Cluster does not exist anymore and was replaced with CqlSession. See the Java driver v4.7 Upgrade Guide for details.
Also, you referenced v4.3 of the docs. For completeness, here is the Java driver v4.7 SSL page. Cheers!
5 People are following this question.
