src/main/java/org/apache/flink/state/benchmark/HashMapStateBackendRescalingBenchmarkExecutor.java [53:59]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        Configuration benchMarkConfig = ConfigUtil.loadBenchMarkConf();
        String stateDataDirPath = benchMarkConfig.getString(StateBenchmarkOptions.STATE_DATA_DIR);
        benchmark =
                new RescalingBenchmarkBuilder<byte[]>()
                        .setMaxParallelism(128)
                        .setParallelismBefore(rescaleType.getParallelismBefore())
                        .setParallelismAfter(rescaleType.getParallelismAfter())
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/main/java/org/apache/flink/state/benchmark/RocksdbStateBackendRescalingBenchmarkExecutor.java [51:57]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        Configuration benchMarkConfig = ConfigUtil.loadBenchMarkConf();
        String stateDataDirPath = benchMarkConfig.getString(StateBenchmarkOptions.STATE_DATA_DIR);
        benchmark =
                new RescalingBenchmarkBuilder<byte[]>()
                        .setMaxParallelism(128)
                        .setParallelismBefore(rescaleType.getParallelismBefore())
                        .setParallelismAfter(rescaleType.getParallelismAfter())
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -