Problem with Cassandra classes

Highlighted
Seven Stars

Problem with Cassandra classes

Hi,
 
I am trying to retrieve data from Cassandra. I have a big table. I am doing a select with all the columns and I got this error:
 
 
com.datastax.driver.core.exceptions.CodecNotFoundException: Codec not found for requested operation: [frozen<asia_svil.authzpointofservicedatacode> <-> java.lang.String]
    at com.datastax.driver.core.CodecRegistry.notFound(CodecRegistry.java:679)
    at com.datastax.driver.core.CodecRegistry.createCodec(CodecRegistry.java:526)
    at com.datastax.driver.core.CodecRegistry.findCodec(CodecRegistry.java:506)
    at com.datastax.driver.core.CodecRegistry.access$200(CodecRegistry.java:140)
    at com.datastax.driver.core.CodecRegistry$TypeCodecCacheLoader.load(CodecRegistry.java:211)
    at com.datastax.driver.core.CodecRegistry$TypeCodecCacheLoader.load(CodecRegistry.java:208)
    at com.datastax.shaded.google.common.cache.LocalCache$LoadingValueReference.loadFuture(LocalCache.java:3524)
    at com.datastax.shaded.google.common.cache.LocalCache$Segment.loadSync(LocalCache.java:2317)
    at com.datastax.shaded.google.common.cache.LocalCache$Segment.lockedGetOrLoad(LocalCache.java:2280)
    at com.datastax.shaded.google.common.cache.LocalCache$Segment.get(LocalCache.java:2195)
    at com.datastax.shaded.google.common.cache.LocalCache.get(LocalCache.java:3934)
    at com.datastax.shaded.google.common.cache.LocalCache.getOrLoad(LocalCache.java:3938)
    at com.datastax.shaded.google.common.cache.LocalCache$LocalLoadingCache.get(LocalCache.java:4821)
    at com.datastax.driver.core.CodecRegistry.lookupCodec(CodecRegistry.java:480)
    at com.datastax.driver.core.CodecRegistry.codecFor(CodecRegistry.java:448)
    at com.datastax.driver.core.CodecRegistry.codecFor(CodecRegistry.java:430)
    at com.datastax.driver.core.AbstractGettableByIndexData.codecFor(AbstractGettableByIndexData.java:69)
    at com.datastax.driver.core.AbstractGettableByIndexData.getString(AbstractGettableByIndexData.java:242)
    at com.datastax.driver.core.AbstractGettableData.getString(AbstractGettableData.java:26)
    at com.datastax.driver.core.AbstractGettableData.getString(AbstractGettableData.java:159)
    at cre.subopenconn_0_1.subOpenConn.tCassandraInput_1Process(subOpenConn.java:7821)
    at cre.subopenconn_0_1.subOpenConn.runJobInTOS(subOpenConn.java:10454)
    at cre.subopenconn_0_1.subOpenConn.main(subOpenConn.java:10303)
 
I downloaded the latest driver cassandra-driver-core-3.6.0.jar, but I still have error:
com.datastax.driver.core.exceptions.CodecNotFoundException: Codec not found for requested operation
 
I know that the connection to Cassandra is working because I tried to create a little table and retrieve data from it with success.
 
Does anyone could help me, please?

Accepted Solutions
Seven Stars

Re: Problem with Cassandra classes

I solved by mapping the column frozen as object and db type blob!


All Replies
Seven Stars JGM
Seven Stars

Re: Problem with Cassandra classes

This is a datatype mapping error. the driver is telling you that there is no such Codec registered that maps the java  java.lang.String to a cql frozen<asia_svil.authzpointofservicedatacode>. Check the datatypes on your table. 

Seven Stars

Re: Problem with Cassandra classes

Thank you! I checked the table datatype. I have two column defined as follow:

 

- colname frozen<authzpointofservicedatacode>
- colname set<frozen<additionaldata>>
 
What does it mean? How can I solve it?
Seven Stars

Re: Problem with Cassandra classes

I solved by mapping the column frozen as object and db type blob!

2019 GARNER MAGIC QUADRANT FOR DATA INTEGRATION TOOL

Talend named a Leader.

Get your copy

OPEN STUDIO FOR DATA INTEGRATION

Kickstart your first data integration and ETL projects.

Download now

What’s New for Talend Summer ’19

Watch the recorded webinar!

Watch Now

Best Practices for Using Context Variables with Talend – Part 1

Learn how to do cool things with Context Variables

Blog

Migrate Data from one Database to another with one Job using the Dynamic Schema

Find out how to migrate from one database to another using the Dynamic schema

Blog

Put Massive Amounts of Data to Work

Learn how to make your data more available, reduce costs and cut your build time

Watch Now