Details
-
Bug
-
Status: Resolved
-
Normal
-
Resolution: Fixed
-
None
-
None
-
Normal
Description
Previously CqlInputFormat.getSplits(JobContext) method did not require anything but providing username and password in order to work with password protected Cassandra. Now, since CASSANDRA-9353 moved this part of the code from Thrift to Java Driver, the user needs to explicitly select AuthProvider to make it work.
I propose a simple change in CqlConfigHelper which make CqlConfigHelper.getCluster method set credentials on Cluster.Builder if they are present in the configuration, prior to setting AuthProvider.