Github user uce commented on the issue:
https://github.com/apache/flink/pull/2385
I will merge this and add the following test for min pause. This fails with
the current master, but works with your PR.
```java
/**
* Tests that no minimum delay between savepoints is enforced.
*/
@Test
public void testMinDelayBetweenSavepoints() throws Exception {
JobID jobId = new JobID();
final ExecutionAttemptID attemptID1 = new ExecutionAttemptID();
ExecutionVertex vertex1 = mockExecutionVertex(attemptID1);
CheckpointCoordinator coord = new CheckpointCoordinator(
jobId,
100000,
200000,
100000000L, // very long min delay => should not affect
savepoints
1,
42,
new ExecutionVertex[] { vertex1 },
new ExecutionVertex[] { vertex1 },
new ExecutionVertex[] { vertex1 },
cl,
new StandaloneCheckpointIDCounter(),
new StandaloneCompletedCheckpointStore(2, cl),
new HeapSavepointStore(),
new DisabledCheckpointStatsTracker());
Future<String> savepoint0 = coord.triggerSavepoint(0);
assertFalse("Did not trigger savepoint", savepoint0.isCompleted());
Future<String> savepoint1 = coord.triggerSavepoint(1);
assertFalse("Did not trigger savepoint", savepoint1.isCompleted());
}
```
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
