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

change variable name

Browse source
This commit is contained in:
Prabhjyot Singh 2016-04-20 15:20:24 +05:30
parent bbe2a7c122
commit f0e3c200ff
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 kind) {
protected void closeSession(Map<String, Integer> userSessionMap, String className) {
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, kind: %s",
entry.getValue(), kind), e);
LOGGER.error(String.format("Error closing session for user with session ID: %s, ClassName: %s",
entry.getValue(), className), 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, "pyspark");
livyHelper.closeSession(userSessionMap, "LivyPySparkInterpreter");
}
@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, "spark");
livyHelper.closeSession(userSessionMap, "LivySparkInterpreter");
}
@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, "sparkr");
livyHelper.closeSession(userSessionMap, "LivySparkRInterpreter");
}
@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, "spark");
livyHelper.closeSession(userSessionMap, "LivySparkSQLInterpreter");
}
@Override