|
|
您好，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 左右。
|
Locked
