This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 8af7391b034ad8a9d43f4c30a1a48370f3167003 Author: Chesnay Schepler <[email protected]> AuthorDate: Wed Apr 21 14:55:32 2021 +0200 [hotfix][tests] Remove unnecessary field --- .../src/main/java/org/apache/flink/testutils/junit/RetryRule.java | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) diff --git a/flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/testutils/junit/RetryRule.java b/flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/testutils/junit/RetryRule.java index beb2f24..f4e9541 100644 --- a/flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/testutils/junit/RetryRule.java +++ b/flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/testutils/junit/RetryRule.java @@ -85,8 +85,6 @@ public class RetryRule implements TestRule { private final int timesOnFailure; - private int currentRun; - private final Statement statement; private RetryOnFailureStatement(int timesOnFailure, Statement statement) { @@ -104,7 +102,7 @@ public class RetryRule implements TestRule { */ @Override public void evaluate() throws Throwable { - for (currentRun = 0; currentRun <= timesOnFailure; currentRun++) { + for (int currentRun = 0; currentRun <= timesOnFailure; currentRun++) { try { statement.evaluate(); break; // success @@ -130,8 +128,6 @@ public class RetryRule implements TestRule { private final int timesOnFailure; private final Statement statement; - private int currentRun; - private RetryOnExceptionStatement( int timesOnFailure, Class<? extends Throwable> exceptionClass, @@ -155,7 +151,7 @@ public class RetryRule implements TestRule { */ @Override public void evaluate() throws Throwable { - for (currentRun = 0; currentRun <= timesOnFailure; currentRun++) { + for (int currentRun = 0; currentRun <= timesOnFailure; currentRun++) { try { statement.evaluate(); break; // success
