flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From somnussuy <somnus...@163.com>
Subject RestClusterClient
Date Fri, 26 Jul 2019 03:42:00 GMT
您好,flink集群关闭的情况下,运行任务会有报错信息  Could not retrieve
the execution result,但是在 flink 集群正常运行的情况下,偶然会报 

Could not retrieve the execution result,通过查询了解到,flink 通过 RestClusterClient类
将任务提交至 jobmanager,如果 detached 为 false,会采用 CompletableFuture

的 thenCompose 方法,在获取结果时,会有异常的捕获,如下:
final CompletableFuture<JobResult> jobResultFuture = jobSubmissionFuture.thenCompose(
   ignored -> requestJobResult(jobGraph.getJobID()));

final JobResult jobResult;
try {
   jobResult = jobResultFuture.get();
} catch (Exception e) {
throw new ProgramInvocationException("Could not retrieve the execution result.",
      jobGraph.getJobID(), ExceptionUtils.stripExecutionException(e));
}
但是,什么原因导致报错,日志中并无明显体现。
希望得到您的帮助:
1. 如果出现该报错,应该在哪里去排查日志。
2. 出现该报错的可能情况有哪些,目前仅有 flink 集群未启动,一定会复现,其他情况偶然出现,频率在
1/50 左右。

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message