This is an automated email from the ASF dual-hosted git repository.

fjy pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-druid.git


The following commit(s) were added to refs/heads/master by this push:
     new 6e87824  ITTLSTest: Retry on "Connection reset by peer". (#6406)
6e87824 is described below

commit 6e878249a040b502082f9393ccfdde3113755561
Author: Gian Merlino <[email protected]>
AuthorDate: Sun Sep 30 12:30:10 2018 -0700

    ITTLSTest: Retry on "Connection reset by peer". (#6406)
    
    * ITTLSTest: Retry on "Connection reset by peer".
    
    This sometimes happens and causes tests to fail spuriously.
    
    * Better error messages when retries are exhausted.
---
 .../src/test/java/org/apache/druid/tests/security/ITTLSTest.java | 9 +++++----
 1 file changed, 5 insertions(+), 4 deletions(-)

diff --git 
a/integration-tests/src/test/java/org/apache/druid/tests/security/ITTLSTest.java
 
b/integration-tests/src/test/java/org/apache/druid/tests/security/ITTLSTest.java
index cb14870..82c5f9a 100644
--- 
a/integration-tests/src/test/java/org/apache/druid/tests/security/ITTLSTest.java
+++ 
b/integration-tests/src/test/java/org/apache/druid/tests/security/ITTLSTest.java
@@ -62,7 +62,7 @@ public class ITTLSTest
 
   private static final Duration SSL_HANDSHAKE_TIMEOUT = new Duration(30 * 
1000);
 
-  private static final int MAX_BROKEN_PIPE_RETRIES = 30;
+  private static final int MAX_CONNECTION_EXCEPTION_RETRIES = 30;
 
   @Inject
   IntegrationTestingConfig config;
@@ -396,10 +396,11 @@ public class ITTLSTest
       catch (RuntimeException re) {
         Throwable rootCause = Throwables.getRootCause(re);
 
-        if (rootCause instanceof IOException && "Broken 
pipe".equals(rootCause.getMessage())) {
-          if (retries > MAX_BROKEN_PIPE_RETRIES) {
+        if (rootCause instanceof IOException && ("Broken 
pipe".equals(rootCause.getMessage())
+                                                 || "Connection reset by 
peer".contains(rootCause.getMessage()))) {
+          if (retries > MAX_CONNECTION_EXCEPTION_RETRIES) {
             Assert.fail(StringUtils.format(
-                "Broken pipe retries exhausted, test failed, did not get %s.",
+                "Broken pipe / connection reset retries exhausted, test 
failed, did not get %s.",
                 expectedException
             ));
           } else {


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to