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) { // } 有谁知道如何解决此问题吗? 非常感谢!