Skip to content

[ZEPPELIN-4712]remove paragraph failed due to Interpreter connection refused #3710

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
xiejiajun wants to merge 4 commits into from
Closed

[ZEPPELIN-4712]remove paragraph failed due to Interpreter connection refused #3710

Changes from all commits
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
9b3c744
added timeout for getting Thrift client to avoid situations where the…
xiejiajun Mar 20, 2020
97d2714
Merge pull request #2 from apache/branch-0.9
xiejiajun Mar 23, 2020
9bc5605
bug fix: when we removing a paragraph , an interpreter process refus…
xiejiajun Mar 31, 2020
9bb7341
Merge remote-tracking branch 'origin/branch-0.9' into branch-0.9
xiejiajun Mar 31, 2020
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
31 changes: 17 additions & 14 deletions ...elin-zengine/src/main/java/org/apache/zeppelin/interpreter/InterpreterSettingManager.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -676,20 +676,23 @@ public List<String> call(RemoteInterpreterService.Client client) throws Exceptio
if (paragraphId != null) {
resourceSet = resourceSet.filterByParagraphId(paragraphId);
}

for (final Resource r : resourceSet) {
remoteInterpreterProcess.callRemoteFunction(
new RemoteInterpreterProcess.RemoteFunction<Void>() {

@Override
public Void call(RemoteInterpreterService.Client client) throws Exception {
client.resourceRemove(
r.getResourceId().getNoteId(),
r.getResourceId().getParagraphId(),
r.getResourceId().getName());
return null;
}
});
try{
for (final Resource r : resourceSet) {
remoteInterpreterProcess.callRemoteFunction(
new RemoteInterpreterProcess.RemoteFunction<Void>() {

@Override
public Void call(RemoteInterpreterService.Client client) throws Exception {
client.resourceRemove(
r.getResourceId().getNoteId(),
r.getResourceId().getParagraphId(),
r.getResourceId().getName());
return null;
}
});
}
}catch (Exception e){
LOGGER.error(e.getMessage());
}
}
}
Expand Down