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

check for more session not found error

Browse source
This commit is contained in:
Prabhjyot Singh 2016-05-19 13:37:09 +05:30
parent aeb5a73f61
commit 9689da08da
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
livy/src/main/java/org/apache/zeppelin/livy/LivyHelper.java
View file

@ -299,12 +299,11 @@ public class LivyHelper {
"POST",
"{\"code\": \"" + lines + "\" }",
context.getParagraphId());
if (json.equals("Session not found")) {
if (json.matches("^(\")?Session (\'[0-9]\' )?not found(.?\"?)$")) {
throw new Exception("Exception: Session not found, Livy server would have restarted, " +
"or lost session.");
}
try {
Map jsonMap = gson.fromJson(json,
new TypeToken<Map>() {
}.getType());
@ -369,7 +368,8 @@ public class LivyHelper {
}
LOGGER.error(String.format("Error with %s StatusCode: %s",
response.getStatusLine().getStatusCode(), responseString));
return null;
throw new Exception(String.format("Error with %s StatusCode: %s",
response.getStatusLine().getStatusCode(), responseString));
}
}