diff --git a/spring-geode/src/main/java/org/springframework/geode/data/json/JsonCacheDataImporterExporter.java b/spring-geode/src/main/java/org/springframework/geode/data/json/JsonCacheDataImporterExporter.java index 2b21176b..b4ab1dc0 100644 --- a/spring-geode/src/main/java/org/springframework/geode/data/json/JsonCacheDataImporterExporter.java +++ b/spring-geode/src/main/java/org/springframework/geode/data/json/JsonCacheDataImporterExporter.java @@ -181,10 +181,8 @@ public class JsonCacheDataImporterExporter extends AbstractCacheDataImporterExpo .map(this::getContent) .map(this::toPdx) .map(Arrays::stream) - .ifPresent(pdxInstances -> pdxInstances.forEach(pdxInstance -> { - pdxInstance = postProcess(pdxInstance); - region.put(getIdentifier(pdxInstance), pdxInstance); - })); + .ifPresent(pdxInstances -> pdxInstances.forEach(pdxInstance -> + region.put(getIdentifier(pdxInstance), postProcess(pdxInstance)))); return region; }