Code:
asOptions = {
"aerospike.namespace": AS_NAMESPACE,
"aerospike.seedhost": AS_CONNECTION_STRING
}
df.write.mode("overwrite").format("aerospike")\
.options(**asOptions)\
.option("aerospike.set","transactions")\
.option("aerospike.updateByKey", "USER_ID")\
.save()
Error :
23/01/03 16:15:55 WARN AerospikeConnection: feature verification with Aerospike server failed. Attempting the verification on application side.
23/01/03 16:15:56 WARN AerospikeConnection: feature verification with Aerospike server failed. Attempting the verification on application side.
23/01/03 16:15:56 ERROR Executor: Exception in task 2.0 in stage 0.0 (TID 2)
asdbjavaclientshadeAerospikeException: Error -1: Unable to read feature key at /etc/aerospike/features.conf
The workaround for above of using this config aerospike.featureKey in spark option is not properly documented on what actual values is to be passed and in what format.