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

retry a for a minute and fail, instead of looping forever

Browse source
This commit is contained in:
Prabhjyot Singh 2016-05-02 13:11:57 +05:30
parent 45e3d4832d
commit 6c19e35ef9
1 changed files with 10 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -70,7 +70,9 @@ public class LivyHelper {
}.getType());
Integer sessionId = ((Double) jsonMap.get("id")).intValue();
if (!jsonMap.get("state").equals("idle")) {
while (true) {
Integer nosRetry = 60;
//Try for 60Sec, if session is not made then throw error.
while (nosRetry <= 0) {
LOGGER.error(String.format("sessionId:%s state is %s",
jsonMap.get("id"), jsonMap.get("state")));
Thread.sleep(1000);
@ -94,6 +96,11 @@ public class LivyHelper {
LOGGER.error(String.format("Cannot start %s.\n%s", kind, logs));
throw new Exception(String.format("Cannot start %s.\n%s", kind, logs));
}
nosRetry--;
}
if (nosRetry <= 0) {
LOGGER.error("Error getting session for user within 60Sec.");
throw new Exception(String.format("Cannot start %s.", kind));
}
}
return sessionId;
@ -186,8 +193,8 @@ public class LivyHelper {
}
public InterpreterResult interpret(String stringLines,
final InterpreterContext context,
final Map<String, Integer> userSessionMap)
final InterpreterContext context,
final Map<String, Integer> userSessionMap)
throws Exception {
stringLines = stringLines
//for "\n" present in string