You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by xu...@apache.org on 2015/01/15 15:19:57 UTC
svn commit: r1652107 -
/hive/branches/spark/spark-client/src/main/java/org/apache/hive/spark/client/SparkClientImpl.java
Author: xuefu
Date: Thu Jan 15 14:19:57 2015
New Revision: 1652107
URL: http://svn.apache.org/r1652107
Log:
HIVE-9387: Shutting down cli takes quite some time [Spark Branch] (Rui via xuefu)
Modified:
hive/branches/spark/spark-client/src/main/java/org/apache/hive/spark/client/SparkClientImpl.java
Modified: hive/branches/spark/spark-client/src/main/java/org/apache/hive/spark/client/SparkClientImpl.java
URL: http://svn.apache.org/viewvc/hive/branches/spark/spark-client/src/main/java/org/apache/hive/spark/client/SparkClientImpl.java?rev=1652107&r1=1652106&r2=1652107&view=diff
==============================================================================
--- hive/branches/spark/spark-client/src/main/java/org/apache/hive/spark/client/SparkClientImpl.java (original)
+++ hive/branches/spark/spark-client/src/main/java/org/apache/hive/spark/client/SparkClientImpl.java Thu Jan 15 14:19:57 2015
@@ -125,9 +125,7 @@ class SparkClientImpl implements SparkCl
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 {
@@ -142,7 +140,7 @@ class SparkClientImpl implements SparkCl
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();
}
}