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

suppress error log when wait target is already removed

Browse source
This commit is contained in:
Lee moon soo 2018-11-25 07:12:11 +09:00
parent fa36c18e37
commit e2dc88a19f
1 changed files with 15 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
zeppelin-plugins/launcher/k8s-standard/src/main/java/org/apache/zeppelin/interpreter/launcher/Kubectl.java
View file

@ -26,6 +26,7 @@ import org.apache.commons.exec.*;
import org.apache.commons.io.IOUtils;
import java.io.*;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@ -60,11 +61,20 @@ public class Kubectl {
}
public String wait(String resource, String waitFor, int timeoutSec) throws IOException {
return execAndGet(new String[]{
"wait",
resource,
String.format("--for=%s", waitFor),
String.format("--timeout=%ds", timeoutSec)});
try {
return execAndGet(new String[]{
"wait",
resource,
String.format("--for=%s", waitFor),
String.format("--timeout=%ds", timeoutSec)});
} catch (IOException e) {
if ("delete".equals(waitFor) && e.getMessage().contains("NotFound")) {
logger.info("{} Not found. Maybe already deleted.", resource);
return "";
} else {
throw e;
}
}
}
public ExecuteWatchdog portForward(String resource, String [] ports) throws IOException {