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

remove class name as it will be avail with the stack trace

Browse source
This commit is contained in:
Prabhjyot Singh 2016-04-21 17:17:39 +05:30
parent a3b0a06ff4
commit 8c4b983abb
5 changed files with 7 additions and 7 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

@ -349,15 +349,15 @@ public class LivyHelper {
paragraphHttpMap.put(paragraphId, null);
}
protected void closeSession(Map<String, Integer> userSessionMap, String className) {
protected void closeSession(Map<String, Integer> userSessionMap) {
for (Map.Entry<String, Integer> entry : userSessionMap.entrySet()) {
try {
executeHTTP(property.getProperty("zeppelin.livy.url") + "/sessions/"
+ entry.getValue(),
"DELETE", null, null);
} catch (Exception e) {
LOGGER.error(String.format("Error closing session for user with session ID: %s, ClassName: %s",
entry.getValue(), className), e);
LOGGER.error(String.format("Error closing session for user with session ID: %s",
entry.getValue()), e);
}
}
}

2
livy/src/main/java/org/apache/zeppelin/livy/LivyPySparkInterpreter.java
View file

@ -61,7 +61,7 @@ public class LivyPySparkInterpreter extends Interpreter {
@Override
public void close() {
livyHelper.closeSession(userSessionMap, "LivyPySparkInterpreter");
livyHelper.closeSession(userSessionMap);
}
@Override

2
livy/src/main/java/org/apache/zeppelin/livy/LivySparkInterpreter.java
View file

@ -72,7 +72,7 @@ public class LivySparkInterpreter extends Interpreter {
@Override
public void close() {
livyHelper.closeSession(userSessionMap, "LivySparkInterpreter");
livyHelper.closeSession(userSessionMap);
}
@Override

2
livy/src/main/java/org/apache/zeppelin/livy/LivySparkRInterpreter.java
View file

@ -61,7 +61,7 @@ public class LivySparkRInterpreter extends Interpreter {
@Override
public void close() {
livyHelper.closeSession(userSessionMap, "LivySparkRInterpreter");
livyHelper.closeSession(userSessionMap);
}
@Override

2
livy/src/main/java/org/apache/zeppelin/livy/LivySparkSQLInterpreter.java
View file

@ -64,7 +64,7 @@ public class LivySparkSQLInterpreter extends Interpreter {
@Override
public void close() {
livyHelper.closeSession(userSessionMap, "LivySparkSQLInterpreter");
livyHelper.closeSession(userSessionMap);
}
@Override