dear all:
如题,我在调用RestClusterClient#cancel(JobID jobId)方法取消作业时,get不到结果,但作业能正常停止。
用future.get()会报错如下:
Number of retries has been exhausted.
用future.get(10, TimeUnit.SECONDS)会报错timeout.
调用#cancelWithSavepoint(...)和#stopWithSavepoint(...)就没问题,可以正常获取到结果,不报错。
目前发现,
1.10.0有问题,
1.14.0没有上述问题。
作业运行于cdh yarn集群,版本2.6.0
作业部署,per-job
代码如下:
try (ClusterClient<?> clusterClient = new RestClusterClient<>(configuration,
clusterId)) {
clusterClient
.cancel(jobId)
.get(20, TimeUnit.SECONDS)
} catch (Exception e) {
//
}
有谁知道如何解决此问题吗?
非常感谢!