Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5746#discussion_r177724627
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/ZooKeeperSubmittedJobGraphStore.java
---
@@ -177,7 +178,7 @@ public SubmittedJobGraph recoverJobGraph(JobID jobId)
throws Exception {
success = true;
return null;
} catch (Exception e) {
- throw new Exception("Could not retrieve
the submitted job graph state handle " +
+ throw new FlinkException("Could not
retrieve the submitted job graph state handle " +
"for " + path + "from the
submitted job graph store.", e);
--- End diff --
nit: missing space, i.e., `" from [...]"`
---
