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

clean logs

Browse source
This commit is contained in:
Khalid Huseynov 2017-03-21 03:28:39 +09:00
parent 796040076f
commit b465b6e962
4 changed files with 4 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
zeppelin-server/src/main/java/org/apache/zeppelin/realm/ZeppelinHubRealm.java
View file

@ -217,7 +217,6 @@ public class ZeppelinHubRealm extends AuthorizingRealm {
ZeppelinServer.notebookWsServer.broadcastReloadedNoteList(
new org.apache.zeppelin.user.AuthenticationInfo(username), userAndRoles);
LOG.info("broadcasted notes, starting userLoginRoutine");
ZeppelinhubUtils.userLoginRoutine(username);
}

3
zeppelin-zengine/src/main/java/org/apache/zeppelin/notebook/repo/zeppelinhub/model/UserTokenContainer.java
View file

@ -51,14 +51,13 @@ public class UserTokenContainer {
}
private UserTokenContainer(ZeppelinhubRestApiHandler restClient, String defaultToken) {
LOG.info("Initializing ZeppelinHub token container");
restApiClient = restClient;
this.defaultToken = defaultToken;
}
public void setUserToken(String username, String token) {
if (StringUtils.isBlank(username) || StringUtils.isBlank(token)) {
LOG.info("Can't set empty user token");
LOG.warn("Can't set empty user token");
return;
}
userTokens.put(username, token);

2
zeppelin-zengine/src/main/java/org/apache/zeppelin/notebook/repo/zeppelinhub/websocket/scheduler/ZeppelinHubHeartbeat.java
View file

@ -40,8 +40,8 @@ public class ZeppelinHubHeartbeat implements Runnable {
@Override
public void run() {
LOG.debug("Sending PING to zeppelinhub token");
for (String token: UserTokenContainer.instance.getAllTokens()) {
LOG.debug("Sending PING to zeppelinhub token {}", token);
client.send(ZeppelinhubUtils.pingMessage(token), token);
}
}

7
zeppelin-zengine/src/main/java/org/apache/zeppelin/notebook/repo/zeppelinhub/websocket/utils/ZeppelinhubUtils.java
View file

@ -99,21 +99,18 @@ public class ZeppelinhubUtils {
}
public static void userLoginRoutine(String username) {
LOG.info("Executing user login routine");
LOG.debug("Executing user login routine");
String token = UserTokenContainer.instance.getUserToken(username);
UserTokenContainer.instance.setUserToken(username, token);
LOG.info("Token for {} is {} ", username, token);
String msg = ZeppelinhubUtils.liveMessage(token);
LOG.info("Live message is {} with token {}", msg, token);
ZeppelinhubClient.getInstance()
.send(msg, token);
}
public static void userLogoutRoutine(String username) {
LOG.info("Executing user logout routine");
LOG.debug("Executing user logout routine");
String token = UserTokenContainer.instance.removeUserToken(username);
String msg = ZeppelinhubUtils.deadMessage(token);
LOG.info("Dead message is {} with token {}", msg, token);
ZeppelinhubClient.getInstance()
.send(msg, token);
ZeppelinhubClient.getInstance().removeSession(token);