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

ZEPPELIN-2403 checkstyle

Browse source
This commit is contained in:
Tinkoff DWH 2017-05-01 21:47:50 +05:00
parent 637cb0a155
commit b41e7a3f19
3 changed files with 9 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
spark/src/main/java/org/apache/zeppelin/spark/SparkInterpreter.java
View file

@ -532,7 +532,8 @@ public class SparkInterpreter extends Interpreter {
File pysparkPath;
if (null == pysparkBasePath) {
pysparkBasePath =
new DefaultInterpreterProperty("ZEPPELIN_HOME", "zeppelin.home", "../").getValue().toString();
new DefaultInterpreterProperty("ZEPPELIN_HOME", "zeppelin.home", "../")
.getValue().toString();
pysparkPath = new File(pysparkBasePath,
"interpreter" + File.separator + "spark" + File.separator + "pyspark");
} else {
@ -583,7 +584,8 @@ public class SparkInterpreter extends Interpreter {
File sparkRPath;
if (null == sparkRBasePath) {
sparkRBasePath =
new DefaultInterpreterProperty("ZEPPELIN_HOME", "zeppelin.home", "../").getValue().toString();
new DefaultInterpreterProperty("ZEPPELIN_HOME", "zeppelin.home", "../")
.getValue().toString();
sparkRPath = new File(sparkRBasePath,
"interpreter" + File.separator + "spark" + File.separator + "R");
} else {

6
zeppelin-server/src/main/java/org/apache/zeppelin/rest/InterpreterRestApi.java
View file

@ -45,8 +45,8 @@ import org.apache.zeppelin.rest.message.RestartInterpreterRequest;
import org.apache.zeppelin.rest.message.UpdateInterpreterSettingRequest;
import org.apache.zeppelin.server.JsonResponse;
import org.apache.zeppelin.socket.NotebookServer;
import org.apache.zeppelin.utils.SecurityUtils;
import org.apache.zeppelin.utils.InterpreterPropertyWidgetUtils;
import org.apache.zeppelin.utils.SecurityUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.sonatype.aether.repository.RemoteRepository;
@ -300,8 +300,8 @@ public class InterpreterRestApi {
@GET
@Path("property/widgets")
public Response listInterpreterPropertyWidgets() {
return new JsonResponse<>(Status.OK, InterpreterPropertyWidgetUtils.getAvailableWidgets()).build();
return new JsonResponse<>(Status.OK, InterpreterPropertyWidgetUtils.getAvailableWidgets())
.build();
}
}

3
zeppelin-zengine/src/main/java/org/apache/zeppelin/interpreter/InterpreterSettingManager.java
View file

@ -179,7 +179,8 @@ public class InterpreterSettingManager {
widget = InterpreterPropertyWidget.byValue(fields.get("widget")).getValue();
type = InterpreterPropertyType.byValue(fields.get("type")).getValue();
} catch (Exception e) {
logger.warn("Incorrect widget or type of property {} in settings {}", key, setting.getId());
logger.warn("Incorrect widget or type of property {} in settings {}", key,
setting.getId());
}
properties.put(key, new InterpreterProperty(key, fields.get("value"), widget, type));
}