private void loadCache(int maxNodes) throws Exception {
    SerializableCallable setup = new SerializableCallable() {
      @Override
      public Object call() throws Exception {
        CacheFactory cf = new CacheFactory().setPdxSerializer(new MyPdxSerializer());

        Cache cache = getCache(cf);
        RegionGenerator rgen = new RegionGenerator();
        rgen.createRegion(cache, null, RegionType.PARTITION, "test");

        return null;
      }
    };

    forEachVm(setup, true, maxNodes);
  }
This test ensures that parallel import succeeds even when each node does not have a file to
import (import cluster larger than export one)
geode-core/src/distributedTest/java/org/apache/geode/cache/snapshot/ParallelSnapshotDUnitTest.java