diff --git spark-client/src/main/java/org/apache/hive/spark/client/SparkClientImpl.java spark-client/src/main/java/org/apache/hive/spark/client/SparkClientImpl.java index a30d8cb..3d4275f 100644 --- spark-client/src/main/java/org/apache/hive/spark/client/SparkClientImpl.java +++ spark-client/src/main/java/org/apache/hive/spark/client/SparkClientImpl.java @@ -120,9 +120,7 @@ public void stop() { if (isAlive) { isAlive = false; try { - protocol.endSession().get(10, TimeUnit.SECONDS); - } catch (TimeoutException te) { - LOG.warn("Timed out waiting for driver to respond to stop request."); + protocol.endSession(); } catch (Exception e) { LOG.warn("Exception while waiting for end session reply.", e); } finally { @@ -137,7 +135,7 @@ public void stop() { LOG.debug("Interrupted before driver thread was finished."); } if (endTime - System.currentTimeMillis() <= 0) { - LOG.debug("Shut down time out."); + LOG.warn("Timed out shutting down remote driver, interrupting..."); driverThread.interrupt(); } }