[incubator-livy] branch master updated: [LIVY-566] Cancel Spark jobs related to statement on cancellation.

[vanzin]

This is an automated email from the ASF dual-hosted git repository.

vanzin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-livy.git


The following commit(s) were added to refs/heads/master by this push:
     new 292896b  [LIVY-566] Cancel Spark jobs related to statement on 
cancellation.
292896b is described below

commit 292896bacfd873ce69c682ba584a03ef8455bd52
Author: Marcelo Vanzin <van...@cloudera.com>
AuthorDate: Fri Mar 15 08:45:24 2019 -0700

    [LIVY-566] Cancel Spark jobs related to statement on cancellation.
    
    Author: Marcelo Vanzin <van...@cloudera.com>
    
    Closes #156 from vanzin/LIVY-566.
---
 .../java/org/apache/livy/thriftserver/session/ThriftSessionState.java    | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/thriftserver/session/src/main/java/org/apache/livy/thriftserver/session/ThriftSessionState.java
 
b/thriftserver/session/src/main/java/org/apache/livy/thriftserver/session/ThriftSessionState.java
index 9da4cbe..1a89d21 100644
--- 
a/thriftserver/session/src/main/java/org/apache/livy/thriftserver/session/ThriftSessionState.java
+++ 
b/thriftserver/session/src/main/java/org/apache/livy/thriftserver/session/ThriftSessionState.java
@@ -106,6 +106,7 @@ class ThriftSessionState {
     if (statements.remove(statementId) == null) {
       throw statementNotFound(statementId);
     }
+    ctx.sc().cancelJobGroup(statementId);
   }
 
   void dispose() {