未知的pdx类型= 4

我的分布式geode系统发展得很好，但最近没有，我不知道它是否与公司昨晚的停电有关。看来所有的geode数据在之前都不能反序列化之前一直存在。未知的pdx类型= 4

这里的错误信息：

Caused by: java.lang.IllegalStateException: Unknown pdx type=4 
    at com.gemstone.gemfire.internal.InternalDataSerializer.readPdxSerializable(InternalDataSerializer.java:3162) 
    at com.gemstone.gemfire.internal.InternalDataSerializer.basicReadObject(InternalDataSerializer.java:2979) 
    at com.gemstone.gemfire.DataSerializer.readObject(DataSerializer.java:3210) 
    at com.gemstone.gemfire.internal.util.BlobHelper.deserializeBlob(BlobHelper.java:101) 
    at com.gemstone.gemfire.internal.cache.EntryEventImpl.deserialize(EntryEventImpl.java:1554) 
    at com.gemstone.gemfire.internal.cache.EntryEventImpl.deserialize(EntryEventImpl.java:1546) 
    at com.gemstone.gemfire.internal.cache.PreferBytesCachedDeserializable.getDeserializedValue(PreferBytesCachedDeserializable.java:67) 
    at com.gemstone.gemfire.internal.cache.EntryEventImpl.getOldValue(EntryEventImpl.java:723) 
    at com.gemstone.gemfire.internal.cache.LocalRegion.validatedDestroy(LocalRegion.java:1146) 
    at com.gemstone.gemfire.internal.cache.LocalRegion.destroy(LocalRegion.java:1130) 
    at com.gemstone.gemfire.internal.cache.AbstractRegion.destroy(AbstractRegion.java:315) 
    at com.gemstone.gemfire.internal.cache.LocalRegion.remove(LocalRegion.java:9372) 
    at com.igola.datahub.wwl.geode.WWLResultsDAO.removeByKey(WWLResultsDAO.java:276)

我的项目是建立在游戏的框架和我的Geode缓存和区域的配置是这样的：

cache.setIsServer(true); 

    diskStorage = configuration.getString("geode.storage.name"); 
    String fileStorage = configuration.getString("geode.storage.path"); 
    cache.createDiskStoreFactory() 
      .setDiskDirs(new File[]{new File(fileStorage)}) 
      .setDiskUsageWarningPercentage(0.8f) 
      .setAutoCompact(true) 
      .create(diskStorage); 

geodeCache.getCache() 
      .<DataKey, When2GoData>createRegionFactory(PARTITION_REDUNDANT_PERSISTENT_OVERFLOW) 
      .setStatisticsEnabled(true) 
      .setEntryIdleTimeout(new ExpirationAttributes(TIMEOUT_LONG, ExpirationAction.DESTROY)) 
      .setDiskStoreName(geodeCache.getDiskStorage()) 
      .setPartitionAttributes(new PartitionAttributesFactory<>() 
        .setRedundantCopies(REDUNDANT_COPIES) 
        .setPartitionResolver(new DataKey()) 
        .create()) 
      .create("xxx"); 

cache = new CacheFactory() 
      .set("locators", configuration.getString("geode.locator")) 
      .set("name", configuration.getString("geode.name")+ "-"+ uuid) 
      .set("mcast-port", "0") 
      .set("log-level", "error") 
      .setPdxPersistent(true) 
      .setPdxReadSerialized(true) 
      .create();

来源

2016-08-20 Even Young

我该怎么办... –

获取UPS ..... :-) –

下面是来自readPdxSerializable方法相关的代码：

PdxType pdxType = gfc.getPdxRegistry().getType(typeId); 
if (logger.isTraceEnabled(LogMarker.SERIALIZER)) { 
    logger.trace(LogMarker.SERIALIZER, "readPdxSerializable pdxType={}", pdxType); 
} 
if (pdxType == null) { 
    throw new IllegalStateException("Unknown pdx type=" + typeId); 
}

所以它看起来像你有东西在你的缓存中，你不能再反序列化...因为（我认为）类型不再注册在类型注册表中的事实。

来源

2016-08-20 07:27:01

未知的pdx类型= 4

回答

相关问题