You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by pn...@apache.org on 2020/08/13 10:31:32 UTC
[flink] 02/03: [hotfix][test] Fix formatting in
CheckpointRequestDeciderTest
This is an automated email from the ASF dual-hosted git repository.
pnowojski pushed a commit to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 35cf138d30df7809749ab072d15427a7452d8132
Author: Roman Khachatryan <kh...@gmail.com>
AuthorDate: Sat Aug 8 12:53:27 2020 +0200
[hotfix][test] Fix formatting in CheckpointRequestDeciderTest
---
.../apache/flink/runtime/checkpoint/CheckpointRequestDeciderTest.java | 4 ----
1 file changed, 4 deletions(-)
diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointRequestDeciderTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointRequestDeciderTest.java
index 90967b9..f8f3270 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointRequestDeciderTest.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointRequestDeciderTest.java
@@ -66,7 +66,6 @@ public class CheckpointRequestDeciderTest {
assertEquals(Optional.of(request), decider.chooseQueuedRequestToExecute(isTriggering, 0));
}
-
@Test
public void testNonForcedEnqueueOnTooManyPending() {
final int maxPending = 1;
@@ -99,7 +98,6 @@ public class CheckpointRequestDeciderTest {
new CheckpointTriggerRequest[]{savepoint, checkpoint});
}
-
@Test
public void testNonForcedUserSubmittedPrioritized() {
CheckpointTriggerRequest userSubmitted = nonForcedSavepoint();
@@ -118,8 +116,6 @@ public class CheckpointRequestDeciderTest {
new CheckpointTriggerRequest[]{savepoint, checkpoint});
}
-
-
@Test
public void testQueueSizeLimit() {
final int maxQueuedRequests = 10;