Change the default polling interval.

Set it to 5s from 2.5s. This is the same as the default in qds-sdk-py.
qubole · Aug 11, 2015 · 00803e0 · 00803e0
1 parent 335fbfb
commit 00803e0
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/main/java/com/qubole/qds/sdk/java/client/ResultLatch.java b/src/main/java/com/qubole/qds/sdk/java/client/ResultLatch.java
@@ -36,7 +36,7 @@ public class ResultLatch
 
     private static final ExecutorService executorService = Executors.newCachedThreadPool(new ThreadFactoryBuilder().setNameFormat("ResultLatch-%d").setDaemon(true).build());
 
-    private static final int DEFAULT_POLL_MS = 2500;
+    private static final int DEFAULT_POLL_MS = 5000;
 
     private static final String STATUS_DONE = "done";
     private static final String STATUS_WAITING = "waiting";

diff --git a/src/test/java/com/qubole/qds/sdk/java/TestResultLatch.java b/src/test/java/com/qubole/qds/sdk/java/TestResultLatch.java
@@ -66,7 +66,7 @@ public <T> Future<T> invokeRequest(ForPage forPage, RequestDetails requestDetail
             }
         };
         ResultLatch resultLatch = new ResultLatch(mockClient, 1);
-        Assert.assertTrue(resultLatch.await(10, TimeUnit.SECONDS));
+        Assert.assertTrue(resultLatch.await(20, TimeUnit.SECONDS));
         Assert.assertTrue(count.get() <= 0);
     }