Unable to persist UDT in Cassandra

Description

I am unable to persist a collecttion of UDT in Cassandra. I get the following exception.
Error:

java.lang.IllegalArgumentException: Failed to get converter for field "_4" of type com.datastax.spark.connector.types.CassandraOption[scala.Array[model.NameValuePair]] in (String, String, String, com.datastax.spark.connector.types.CassandraOption[scala.Array[model.NameValuePair]], com.datastax.spark.connector.types.CassandraOption[model.BillInformation], String, String, com.datastax.spark.connector.types.CassandraOption[scala.Array[model.BillCycleInfo]], com.datastax.spark.connector.types.CassandraOption[scala.Array[model.BillExtraInfo]], com.datastax.spark.connector.types.CassandraOption[scala.Array[model.BillHistoryInfo]]) mapped to column "authenticators" of "billerplatform_schema.bills"
at com.datastax.spark.connector.writer.MappedToGettableDataConverter$$anon$1$$anonfun$5.apply(MappedToGettableDataConverter.scala:164)

Caused by: java.lang.IllegalArgumentException: requirement failed: Columns not found in scala.Array[model.NameValuePair]: [name, value]
at scala.Predef$.require(Predef.scala:224)
at com.datastax.spark.connector.mapper.DefaultColumnMapper.columnMapForWriting(DefaultColumnMapper.scala:108)
at com.datastax.spark.connector.writer.MappedToGettableDataConverter$$anon$1.<init>(MappedToGettableDataConverter.scala:29)

Attaching scripts, driver code and case classes.

Environment

Ubuntu 16.04
Spark 2.0.2
Cassandra 3.9
Kafka 0.9.1

Pull Requests

None

Status

Assignee

Alex Liu

Reporter

Sriraman Gopalan

Labels

Reviewer

None

Reviewer 2

None

Tester

None

Pull Request

None

Components

Affects versions

Priority

Major
Configure