in cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/BulkSparkConf.java [355:389]
public void validateSslConfiguration()
{
if (getKeyStorePassword() != null)
{
// If the mTLS keystore password is provided, we validate that the path or a base64 keystore is provided
if (getKeyStorePath() == null && getKeystoreBase64Encoded() == null)
{
throw new NullPointerException("Keystore password was set. "
+ "But both keystore path and base64 encoded string are not set. "
+ "Please either set option " + WriterOptions.KEYSTORE_PATH
+ " or option " + WriterOptions.KEYSTORE_BASE64_ENCODED);
}
}
// Check to make sure if either trust store password or trust store path are specified, both are specified
if (getConfiguredTrustStorePassword() != null)
{
Preconditions.checkArgument(getTruststoreBase64Encoded() != null || getTrustStorePath() != null,
"Trust Store password was provided, but both truststore path and base64 encoded string are missing. "
+ "Please provide either option " + WriterOptions.TRUSTSTORE_PATH
+ " or option " + WriterOptions.TRUSTSTORE_BASE64_ENCODED);
}
else
{
if (getTrustStorePath() != null || getTruststoreBase64Encoded() != null)
{
Preconditions.checkNotNull(getTruststoreBase64Encoded(),
"Trust Store Path was provided, but password is missing. "
+ "Please provide option " + WriterOptions.TRUSTSTORE_PASSWORD);
Preconditions.checkNotNull(getTrustStorePath(),
"Trust Store Base64 encoded was provided, but password is missing."
+ "Please provide option " + WriterOptions.TRUSTSTORE_PASSWORD);
}
}
}