src/main/java/org/apache/flink/benchmark/CheckpointEnvironmentContext.java [95:101]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                config -> {
                    config.set(CheckpointingOptions.ENABLE_UNALIGNED, true);
                    config.set(
                            TaskManagerOptions.MEMORY_SEGMENT_SIZE,
                            CheckpointEnvironmentContext.START_MEMORY_SEGMENT_SIZE);
                    config.set(
                            CheckpointingOptions.ALIGNED_CHECKPOINT_TIMEOUT,
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/main/java/org/apache/flink/benchmark/CheckpointEnvironmentContext.java [107:113]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                config -> {
                    config.set(CheckpointingOptions.ENABLE_UNALIGNED, true);
                    config.set(
                            TaskManagerOptions.MEMORY_SEGMENT_SIZE,
                            CheckpointEnvironmentContext.START_MEMORY_SEGMENT_SIZE);
                    config.set(
                            CheckpointingOptions.ALIGNED_CHECKPOINT_TIMEOUT,
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -