Config deprecations are not checked when instantiating CassandraConnector

Description

When CassandraConnector is instantiated with `CassandraConnector(SparkContext)`, config deprecations are not checked (nor automatically replaced).

This is an issue when using any Cassandra RDD function because every default implicit `CassandraConnector` in class `RDDFunctions` is instantiated this way.

For example, when first executing `rdd.saveToCassandra(keyspaceName, tableName, columns, WriteConf())` with no implicit `CassandraConnector` already initialized, then config deprecations are not checked, nor replaced, and deprecated configs are not taken into account.

Note that config deprecations are however checked from methods `ReadConf.fromSparkConf()` and `WriteConf.fromSparkConf()`, so the issue only occurs if these methods are not called previously.

Environment

None

Pull Requests

None

Activity

Show:
Fixed

Details

Assignee

Reporter

Fix versions

Components

Affects versions

Priority

Created February 25, 2021 at 7:17 PM
Updated March 1, 2021 at 10:20 AM
Resolved March 1, 2021 at 10:20 AM