Elgato_dark/zeppelin
1
0
Fork 0
mirror of https://github.com/apache/zeppelin synced 2026-05-24 09:38:26 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

address comments

Browse source
This commit is contained in:
Jeff Zhang 2017-01-16 08:17:53 +08:00
parent 1cbeb26128
commit 200ca71296
1 changed files with 11 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
livy/src/main/java/org/apache/zeppelin/livy/BaseLivyInterprereter.java
View file

@ -115,6 +115,8 @@ public abstract class BaseLivyInterprereter extends Interpreter {
}
LOGGER.info("Create livy session successfully with sessionId: {}, appId: {}, webUI: {}",
sessionInfo.id, sessionInfo.appId, sessionInfo.webUIAddress);
} else {
LOGGER.info("Create livy session successfully with sessionId: {}", this.sessionInfo.id);
}
// check livy version
try {
@ -167,12 +169,17 @@ public abstract class BaseLivyInterprereter extends Interpreter {
public void cancel(InterpreterContext context) {
if (livyVersion.isCancelSupported()) {
try {
cancelStatement(paragraphId2StmtIdMapping.get(context.getParagraphId()));
if (paragraphId2StmtIdMapping.containsKey(context.getParagraphId())) {
cancelStatement(paragraphId2StmtIdMapping.get(context.getParagraphId()));
}
} catch (LivyException e) {
LOGGER.warn("Fail to cancel statement {} for paragraph {} ",
paragraphId2StmtIdMapping.get(context.getParagraphId()), context.getParagraphId());
LOGGER.error("Fail to cancel statement " +
paragraphId2StmtIdMapping.get(context.getParagraphId()) + " for paragraph " +
context.getParagraphId(), e);
} finally {
paragraphId2StmtIdMapping.remove(context.getParagraphId());
if (paragraphId2StmtIdMapping.containsKey(context.getParagraphId())) {
paragraphId2StmtIdMapping.remove(context.getParagraphId());
}
}
} else {
LOGGER.warn("cancel is not supported for this version of livy: " + livyVersion);