2016-08-20 51 views
0

我的分佈式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(); 
+0

我該怎麼辦... –

+0

獲取UPS ..... :-) –

回答

0

下面是來自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); 
} 

所以它看起來像你有東西在你的緩存中,你不能再反序列化...因爲(我認爲)類型不再註冊在類型註冊表中的事實。