[hotfix] [tests] Log retry rule failures on warn level

Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/756cbaff
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/756cbaff
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/756cbaff

Branch: refs/heads/master
Commit: 756cbafff1fd25f67268ca84b62c8a479156bf88
Parents: 3a643c0
Author: Ufuk Celebi <u...@apache.org>
Authored: Tue Feb 9 11:25:37 2016 +0100
Committer: Stephan Ewen <se...@apache.org>
Committed: Wed Feb 10 15:27:28 2016 +0100

----------------------------------------------------------------------
 .../test/java/org/apache/flink/testutils/junit/RetryRule.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/756cbaff/flink-core/src/test/java/org/apache/flink/testutils/junit/RetryRule.java
----------------------------------------------------------------------
diff --git 
a/flink-core/src/test/java/org/apache/flink/testutils/junit/RetryRule.java 
b/flink-core/src/test/java/org/apache/flink/testutils/junit/RetryRule.java
index a4aff86..2b3a37a 100644
--- a/flink-core/src/test/java/org/apache/flink/testutils/junit/RetryRule.java
+++ b/flink-core/src/test/java/org/apache/flink/testutils/junit/RetryRule.java
@@ -113,7 +113,7 @@ public class RetryRule implements TestRule {
                                        break; // success
                                }
                                catch (Throwable t) {
-                                       LOG.debug(String.format("Test run 
failed (%d/%d).",
+                                       LOG.warn(String.format("Test run failed 
(%d/%d).",
                                                        currentRun, 
timesOnFailure + 1), t);
 
                                        // Throw the failure if retried too 
often
@@ -156,7 +156,7 @@ public class RetryRule implements TestRule {
                                        break; // success
                                }
                                catch (Throwable t) {
-                                       LOG.debug(String.format("Test run 
failed (%d/%d).", currentRun, timesOnFailure + 1), t);
+                                       LOG.warn(String.format("Test run failed 
(%d/%d).", currentRun, timesOnFailure + 1), t);
 
                                        if 
(!exceptionClass.isAssignableFrom(t.getClass()) || currentRun >= 
timesOnFailure) {
                                                // Throw the failure if retried 
too often, or if it is the wrong exception

Reply via email to