Added a timeout for hive queries wait so that we can fail fast

and return if there is inordinate delay.
TIBCOSoftware · Jul 11, 2018 · de2f765 · de2f765
1 parent 1d23dc1
commit de2f765
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/core/src/main/java/io/snappydata/impl/SnappyHiveCatalog.java b/core/src/main/java/io/snappydata/impl/SnappyHiveCatalog.java
@@ -269,7 +269,8 @@ private HMSQuery getHMSQuery() {
 
   private <T> T handleFutureResult(Future<T> f) {
     try {
-      return f.get();
+      // Time out if it takes more than 30 seconds
+      return f.get(30, TimeUnit.SECONDS);
     } catch (ExecutionException e) {
       throw new RuntimeException(e.getCause());
     } catch (Exception e) {