[FLINK-22232][tests] Add UnalignedCheckpointsStressITCase

derekm · Apr 29, 2021 · 9a94509 · 9a94509
1 parent 79a521e
commit 9a94509
Show file tree

Hide file tree

Showing 2 changed files with 554 additions and 0 deletions.
diff --git a/...ime/src/test/java/org/apache/flink/runtime/operators/testutils/ExpectedTestException.java b/...ime/src/test/java/org/apache/flink/runtime/operators/testutils/ExpectedTestException.java
@@ -26,4 +26,8 @@ public class ExpectedTestException extends RuntimeException {
  public ExpectedTestException() {
  super(MESSAGE);
  }
+
+ public ExpectedTestException(String message) {
+ super(message);
+ }
 }