[Bug]: Cannot read from ssl-enabled cassandra cluster

[hassanhamod]

What happened?

Using Beam Version 2.53
Cassandra version is currently 3.11.5
Using cassandra-driver-core & cassandra-driver-mapping 3.10.2 (also tested on 3.11.5 but no luck)

CassandraIO.Read.withSsl expects an object that implements RemoteEndpointAwareSSLOptions.

Following the datastax documentation... provide the following parameter for .withSsl: RemoteEndpointAwareJdkSSLOptions.builder().build()

And the following runtime errors will appear when you execute the pipeline:

Forbidden IOException when writing to OutputStream
Caused by: java.io.NotSerializableException: com.datastax.driver.core.RemoteEndpointAwareJdkSSLOptions

Does not matter if the datastax driver config is set programmatically or property-based (following datastax documentation) - the same errors will appear once the pipeline is run.

Issue Priority

Priority: 1 (data loss / total loss of function)

Issue Components

• Component: Python SDK
• Component: Java SDK
• Component: Go SDK
• Component: Typescript SDK
• Component: IO connector
• Component: Beam YAML
• Component: Beam examples
• Component: Beam playground
• Component: Beam katas
• Component: Website
• Component: Spark Runner
• Component: Flink Runner
• Component: Samza Runner
• Component: Twister2 Runner
• Component: Hazelcast Jet Runner
• Component: Google Cloud Dataflow Runner