Caused by：javax.persistence.PersistenceException：org.apache.cassandra.serializers.MarshalException：映射值后出现意外的额外字节 [英] Caused by: javax.persistence.PersistenceException: org.apache.cassandra.serializers.MarshalException: Unexpected extraneous bytes after map value

问题描述

我在cassandra中有一个表类型MAP（ie）source_id_map映射表

I have a table in cassandra which has a column of type MAP (i.e) source_id_map map

当我尝试从这个表中读取一行时，我看到在读取地图类型的列时出现一些问题

When I try to read a row from this table, I see that there is some issue while reading column of map type as below

导致：javax.persistence.PersistenceException：
org.apache .cassandra.serializers.MarshalException：意外的
映射值之后的额外字节
at com.impetus.client.cassandra.datahandler.CassandraDataHandlerBase.setCollectionValue（CassandraDataHandlerBase.java:2526）
at com.impetus .client.cassandra.datahandler.CassandraDataHandlerBase.setFieldValueViaCQL（CassandraDataHandlerBase.java:1504）
at com.impetus.client.cassandra.datahandler.CassandraDataHandlerBase.populateViaThrift（CassandraDataHandlerBase.java:1163）
at com.impetus .client.cassandra.datahandler.CassandraDataHandlerBase.onColumn（CassandraDataHandlerBase.java:1054）
at com.impetus.client.cassandra.datahandler.CassandraDataHandlerBase.populateEntity（CassandraDataHandlerBase.java:653）

Caused by: javax.persistence.PersistenceException: org.apache.cassandra.serializers.MarshalException: Unexpected extraneous bytes after map value at com.impetus.client.cassandra.datahandler.CassandraDataHandlerBase.setCollectionValue(CassandraDataHandlerBase.java:2526) at com.impetus.client.cassandra.datahandler.CassandraDataHandlerBase.setFieldValueViaCQL(CassandraDataHandlerBase.java:1504) at com.impetus.client.cassandra.datahandler.CassandraDataHandlerBase.populateViaThrift(CassandraDataHandlerBase.java:1163) at com.impetus.client.cassandra.datahandler.CassandraDataHandlerBase.onColumn(CassandraDataHandlerBase.java:1054) at com.impetus.client.cassandra.datahandler.CassandraDataHandlerBase.populateEntity(CassandraDataHandlerBase.java:653)

我注意到的另一个例外情况如下。

Another exception that I notice is as below.

检索fieldUTF8Type时出错值通过CQL，导致：。
java.lang.IllegalArgumentException
at java.nio.Buffer.limit（Buffer.java:267）
at org.apache.cassandra.utils.ByteBufferUtil.readBytes（ByteBufferUtil.java:543 ）
at org.apache.cassandra.utils.ByteBufferUtil.readBytesWithShortLength（ByteBufferUtil.java:552）
at org.apache.cassandra.serializers.CollectionSerializer.readValue（CollectionSerializer.java:128）
at org.apache.cassandra.serializers.MapSerializer.deserializeForNativeProtocol（MapSerializer.java:104）
at com.impetus.client.cassandra.schemamanager.CassandraDataTranslator $ MapTypeBuilder.decompose（CassandraDataTranslator.java:1177）
at com.impetus.client.cassandra.schemamanager.CassandraDataTranslator $ MapTypeBuilder.access $ 4800（CassandraDataTranslator.java:1100）
at com.impetus.client.cassandra.schemamanager.CassandraDataTranslator.decompose（CassandraDataTranslator.java:507）
at com.impetus.client.cassandra.datahandler.CassandraDataHandlerBase.setCollectionValue（CassandraDataHandlerBase.java:2518）
at com.impetus.client.cassandra.datahandler.CassandraDataHandlerBase.setFieldValueViaCQL（CassandraDataHandlerBase.java:1504）
at com.impetus.client.cassandra.datahandler.CassandraDataHandlerBase.populateViaThrift（CassandraDataHandlerBase.java:1163）
at com.impetus.client.cassandra.datahandler.CassandraDataHandlerBase.onColumn（CassandraDataHandlerBase.java:1054）
at com.impetus.client.cassandra.datahandler.CassandraDataHandlerBase.populateEntity（CassandraDataHandlerBase.java:653）
at com.impetus.client.cassandra.CassandraClientBase $ CQLClient.executeQuery（CassandraClientBase.java:2272）
at com.impetus.client.cassandra.CassandraClientBase.executeSelectQuery（CassandraClientBase.java:926）
at com.impetus.client.cassandra.thrift.ThriftClient.executeQuery（ThriftClient.java:1062）
at com.impetus.client.cassandra.query.CassQuery.populateEntities（CassQuery.java:153）
at com.impetus.kundera.query.QueryImpl.fetch（QueryImpl.java:1377）
at com.impetus.kundera.query.QueryImpl.getResultList（QueryImpl.java:200）

Error while retrieving fieldUTF8Type value via CQL, Caused by: . java.lang.IllegalArgumentException at java.nio.Buffer.limit(Buffer.java:267) at org.apache.cassandra.utils.ByteBufferUtil.readBytes(ByteBufferUtil.java:543) at org.apache.cassandra.utils.ByteBufferUtil.readBytesWithShortLength(ByteBufferUtil.java:552) at org.apache.cassandra.serializers.CollectionSerializer.readValue(CollectionSerializer.java:128) at org.apache.cassandra.serializers.MapSerializer.deserializeForNativeProtocol(MapSerializer.java:104) at com.impetus.client.cassandra.schemamanager.CassandraDataTranslator$MapTypeBuilder.decompose(CassandraDataTranslator.java:1177) at com.impetus.client.cassandra.schemamanager.CassandraDataTranslator$MapTypeBuilder.access$4800(CassandraDataTranslator.java:1100) at com.impetus.client.cassandra.schemamanager.CassandraDataTranslator.decompose(CassandraDataTranslator.java:507) at com.impetus.client.cassandra.datahandler.CassandraDataHandlerBase.setCollectionValue(CassandraDataHandlerBase.java:2518) at com.impetus.client.cassandra.datahandler.CassandraDataHandlerBase.setFieldValueViaCQL(CassandraDataHandlerBase.java:1504) at com.impetus.client.cassandra.datahandler.CassandraDataHandlerBase.populateViaThrift(CassandraDataHandlerBase.java:1163) at com.impetus.client.cassandra.datahandler.CassandraDataHandlerBase.onColumn(CassandraDataHandlerBase.java:1054) at com.impetus.client.cassandra.datahandler.CassandraDataHandlerBase.populateEntity(CassandraDataHandlerBase.java:653) at com.impetus.client.cassandra.CassandraClientBase$CQLClient.executeQuery(CassandraClientBase.java:2272) at com.impetus.client.cassandra.CassandraClientBase.executeSelectQuery(CassandraClientBase.java:926) at com.impetus.client.cassandra.thrift.ThriftClient.executeQuery(ThriftClient.java:1062) at com.impetus.client.cassandra.query.CassQuery.populateEntities(CassQuery.java:153) at com.impetus.kundera.query.QueryImpl.fetch(QueryImpl.java:1377) at com.impetus.kundera.query.QueryImpl.getResultList(QueryImpl.java:200)

推荐答案

请在插入和读取数据时启用CQL3。

Please enable CQL3 both while inserting as well as reading data

Map propertyMap = new HashMap();
propertyMap.put(CassandraConstants.CQL_VERSION, CassandraConstants.CQL_VERSION_3_0);
EntityManagerFactory emf = Persistence.createEntityManagerFactory("cassandra-pu",propertyMap);

这篇关于Caused by：javax.persistence.PersistenceException：org.apache.cassandra.serializers.MarshalException：映射值后出现意外的额外字节的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！