|
@@ -62,6 +62,11 @@ public class JobApiImpl implements JobApi {
|
|
|
@Override
|
|
@Override
|
|
|
public Job update(Job job) {
|
|
public Job update(Job job) {
|
|
|
delete(job);
|
|
delete(job);
|
|
|
|
|
+ try {
|
|
|
|
|
+ Thread.sleep(5000);
|
|
|
|
|
+ } catch (InterruptedException e) {
|
|
|
|
|
+ e.printStackTrace();
|
|
|
|
|
+ }
|
|
|
return create(job);
|
|
return create(job);
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -87,8 +92,7 @@ public class JobApiImpl implements JobApi {
|
|
|
if (e.getCode() == NOT_FOUND) {
|
|
if (e.getCode() == NOT_FOUND) {
|
|
|
throw new K8sApiException(NOT_FOUND, "namespace不存在");
|
|
throw new K8sApiException(NOT_FOUND, "namespace不存在");
|
|
|
} else {
|
|
} else {
|
|
|
- LoggerUtil.info(logger, "遇到k8s api错误,但已删除");
|
|
|
|
|
-// throw K8s_SYSTEM_ERROR_EXCEPTION;
|
|
|
|
|
|
|
+ throw K8s_SYSTEM_ERROR_EXCEPTION;
|
|
|
}
|
|
}
|
|
|
} catch (Exception e) {
|
|
} catch (Exception e) {
|
|
|
// k8s api的bug,其实删除成功了,但是返回值类型不正确
|
|
// k8s api的bug,其实删除成功了,但是返回值类型不正确
|