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

bugfix: reload only once

Browse source
This commit is contained in:
Khalid Huseynov 2016-09-21 01:25:55 +09:00
parent 537cc0ebad
commit 781207e15b
2 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
zeppelin-server/src/main/java/org/apache/zeppelin/socket/NotebookServer.java
View file

@ -550,7 +550,7 @@ public class NotebookServer extends WebSocketServlet implements
}
public void broadcastReloadedNoteList(AuthenticationInfo subject) {
//send first to requesting user
//reload and reply first to requesting user
List<Map<String, String>> notesInfo = generateNotebooksInfo(true, subject);
multicastToUser(subject.getUser(), new Message(OP.NOTES_INFO).put("notes", notesInfo));
//to others afterwards
@ -558,7 +558,8 @@ public class NotebookServer extends WebSocketServlet implements
if (subject.getUser() == user) {
continue;
}
notesInfo = generateNotebooksInfo(true, new AuthenticationInfo(user));
//reloaded already above; parameter - false
notesInfo = generateNotebooksInfo(false, new AuthenticationInfo(user));
multicastToUser(user, new Message(OP.NOTES_INFO).put("notes", notesInfo));
}
}

1
zeppelin-zengine/src/main/java/org/apache/zeppelin/notebook/Notebook.java
View file

@ -482,7 +482,6 @@ public class Notebook implements NoteEventListener {
}
List<NoteInfo> noteInfos = notebookRepo.list(subject);
noteInfos = notebookAuthorization.filterByUser(noteInfos, subject);
for (NoteInfo info : noteInfos) {
loadNoteFromRepo(info.getId(), subject);