private boolean isRecoveryNeeded() {
    return getDataPolicy().withPersistence() && getDiskRegion().isRecreated();
  }
remove any partial entries received in a failed GII
geode-core/src/main/java/org/apache/geode/internal/cache/DistributedRegion.java