java - Caused by: javax.persistence.PersistenceException: org.apache.cassandra.serializers.MarshalException: Unexpected extraneous bytes after map value -


i have table in cassandra has column of type map (i.e) source_id_map map

when try read row table, see there issue while reading column of map type below

caused by: javax.persistence.persistenceexception: org.apache.cassandra.serializers.marshalexception: unexpected extraneous bytes after map value @ com.impetus.client.cassandra.datahandler.cassandradatahandlerbase.setcollectionvalue(cassandradatahandlerbase.java:2526) @ com.impetus.client.cassandra.datahandler.cassandradatahandlerbase.setfieldvalueviacql(cassandradatahandlerbase.java:1504) @ com.impetus.client.cassandra.datahandler.cassandradatahandlerbase.populateviathrift(cassandradatahandlerbase.java:1163) @ com.impetus.client.cassandra.datahandler.cassandradatahandlerbase.oncolumn(cassandradatahandlerbase.java:1054) @ com.impetus.client.cassandra.datahandler.cassandradatahandlerbase.populateentity(cassandradatahandlerbase.java:653)

another exception notice below.

error while retrieving fieldutf8type value via cql, caused by: . java.lang.illegalargumentexception @ java.nio.buffer.limit(buffer.java:267) @ org.apache.cassandra.utils.bytebufferutil.readbytes(bytebufferutil.java:543) @ org.apache.cassandra.utils.bytebufferutil.readbyteswithshortlength(bytebufferutil.java:552) @ org.apache.cassandra.serializers.collectionserializer.readvalue(collectionserializer.java:128) @ org.apache.cassandra.serializers.mapserializer.deserializefornativeprotocol(mapserializer.java:104) @ com.impetus.client.cassandra.schemamanager.cassandradatatranslator$maptypebuilder.decompose(cassandradatatranslator.java:1177) @ com.impetus.client.cassandra.schemamanager.cassandradatatranslator$maptypebuilder.access$4800(cassandradatatranslator.java:1100) @ com.impetus.client.cassandra.schemamanager.cassandradatatranslator.decompose(cassandradatatranslator.java:507) @ com.impetus.client.cassandra.datahandler.cassandradatahandlerbase.setcollectionvalue(cassandradatahandlerbase.java:2518) @ com.impetus.client.cassandra.datahandler.cassandradatahandlerbase.setfieldvalueviacql(cassandradatahandlerbase.java:1504) @ com.impetus.client.cassandra.datahandler.cassandradatahandlerbase.populateviathrift(cassandradatahandlerbase.java:1163) @ com.impetus.client.cassandra.datahandler.cassandradatahandlerbase.oncolumn(cassandradatahandlerbase.java:1054) @ com.impetus.client.cassandra.datahandler.cassandradatahandlerbase.populateentity(cassandradatahandlerbase.java:653) @ com.impetus.client.cassandra.cassandraclientbase$cqlclient.executequery(cassandraclientbase.java:2272) @ com.impetus.client.cassandra.cassandraclientbase.executeselectquery(cassandraclientbase.java:926) @ com.impetus.client.cassandra.thrift.thriftclient.executequery(thriftclient.java:1062) @ com.impetus.client.cassandra.query.cassquery.populateentities(cassquery.java:153) @ com.impetus.kundera.query.queryimpl.fetch(queryimpl.java:1377) @ com.impetus.kundera.query.queryimpl.getresultlist(queryimpl.java:200)

please enable cql3 both while inserting reading data

map propertymap = new hashmap(); propertymap.put(cassandraconstants.cql_version, cassandraconstants.cql_version_3_0); entitymanagerfactory emf = persistence.createentitymanagerfactory("cassandra-pu",propertymap); 

Comments

Popular posts from this blog

java - Run spring boot application error: Cannot instantiate interface org.springframework.context.ApplicationListener -

python - pip wont install .WHL files -

Excel VBA "Microsoft Windows Common Controls 6.0 (SP6)" Location Changes -