0

私の分散geodeシステムは以前はうまくいっていましたが、最近はうまくいきませんでした。それが昨夜の会社の停電に関連しているかどうかはわかりません。以前に永続化されたすべての geode データは、現在は逆シリアル化できないようです。

エラー情報は次のとおりです。

 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)

私のプロジェクトは Play フレームワークで構築され、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();
4

1 に答える 1

1

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-20T07:27:01.253 に答える