News Feed

No results for 'undefined'
Powered by Algolia

Codec not found for requested operation: [list scala.collection.immutable.$colon$colon]


Author: nishant jain

Originally Sourced from: https://stackoverflow.com/questions/43690428/codec-not-found-for-requested-operation-listwatson-destination-intent-sc

I am getting CodecNotFoundException when trying to use the list of UserDefinedType I have already registered the codec for the UDT, this is happening when I am trying to use the list of UDT

com.datastax.driver.core.exceptions.CodecNotFoundException: Codec not found for requested operation: [list<watson.destination_intent> <-> scala.collection.immutable.$colon$colon]
at com.datastax.driver.core.CodecRegistry.notFound(CodecRegistry.java:741)
at com.datastax.driver.core.CodecRegistry.createCodec(CodecRegistry.java:602)
at com.datastax.driver.core.CodecRegistry.findCodec(CodecRegistry.java:582)
at com.datastax.driver.core.CodecRegistry.codecFor(CodecRegistry.java:507)
at com.datastax.driver.core.AbstractGettableByIndexData.codecFor(AbstractGettableByIndexData.java:77)
at com.datastax.driver.core.BoundStatement.bind(BoundStatement.java:201)
at com.datastax.driver.core.DefaultPreparedStatement.bind(DefaultPreparedStatement.java:126)
at com.expedia.www.watson.flink.jobs.CassandraListOutputFormat.writeRecord(TravelerProfileLoadJob.scala:218)
at com.expedia.www.watson.flink.jobs.CassandraListOutputFormat.writeRecord(TravelerProfileLoadJob.scala:173)
at com.expedia.www.watson.sdk.flink.outputs.RateLimitingOutputFormat.writeRecord(RateLimitingOutputFormat.scala:36)
at org.apache.flink.runtime.operators.DataSinkTask.invoke(DataSinkTask.java:192)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:642)
at java.lang.Thread.run(Thread.java:745)