flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject [4/6] flink git commit: [hotfix] [tests] Log retry rule failures on warn level
Date Wed, 10 Feb 2016 16:52:55 GMT
[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 <uce@apache.org>
Authored: Tue Feb 9 11:25:37 2016 +0100
Committer: Stephan Ewen <sewen@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


Mime
View raw message