reduce the timeout

Canner · Jan 24, 2024 · 5810eaf · 5810eaf
1 parent cc412ba
commit 5810eaf
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 5 deletions.
diff --git a/accio-main/src/main/java/io/accio/main/wireprotocol/PostgresNetty.java b/accio-main/src/main/java/io/accio/main/wireprotocol/PostgresNetty.java
@@ -152,9 +152,6 @@ protected void initChannel(Channel ch)
             LOGGER.info("Postgre wire protocol server start. Bound Address: %s", boundAddress);
             success = true;
         }
-        catch (Exception e) {
-            LOGGER.error(e, "Failed to bind to address");
-        }
         finally {
             if (!success) {
                 // stop

diff --git a/accio-tests/src/main/java/io/accio/testing/TestingWireProtocolClient.java b/accio-tests/src/main/java/io/accio/testing/TestingWireProtocolClient.java
@@ -67,7 +67,7 @@ public TestingWireProtocolClient(InetSocketAddress isa)
             throws IOException
     {
         this.socketClient = new Socket();
-        socketClient.setSoTimeout(60000);
+        socketClient.setSoTimeout(10000);
         socketClient.connect(isa);
 
         this.in = socketClient.getInputStream();

diff --git a/accio-tests/src/test/java/io/accio/testing/RequireAccioServer.java b/accio-tests/src/test/java/io/accio/testing/RequireAccioServer.java
@@ -77,7 +77,7 @@ public RequireAccioServer() {}
     public void init()
     {
         this.accioServer = createAccioServer();
-        this.client = closer.register(new JettyHttpClient(new HttpClientConfig().setIdleTimeout(new Duration(300, SECONDS))));
+        this.client = closer.register(new JettyHttpClient(new HttpClientConfig().setIdleTimeout(new Duration(20, SECONDS))));
         closer.register(accioServer);
         prepare();
     }