[SPARK-8839][SQL]ThriftServer2 will remove session and execution no m…

…atter it's finished or not.
apache · Jul 6, 2015 · 9d5ceb8 · 9d5ceb8
1 parent 86768b7
commit 9d5ceb8
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/...hriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/HiveThriftServer2.scala b/...hriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/HiveThriftServer2.scala
@@ -218,7 +218,9 @@ object HiveThriftServer2 extends Logging {
       if (executionList.size > retainedStatements) {
         val toRemove = math.max(retainedStatements / 10, 1)
         executionList.take(toRemove).foreach { s =>
-          executionList.remove(s._1)
+          if (s._2.finishTimestamp != 0) {
+            executionList.remove(s._1)
+          }
         }
       }
     }
@@ -227,7 +229,9 @@ object HiveThriftServer2 extends Logging {
       if (sessionList.size > retainedSessions) {
         val toRemove = math.max(retainedSessions / 10, 1)
         sessionList.take(toRemove).foreach { s =>
-          sessionList.remove(s._1)
+          if (s._2.finishTimestamp != 0) {
+            sessionList.remove(s._1)
+          }
         }
       }