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) {
 //
}

有谁知道如何解决此问题吗?
非常感谢!

回复