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 [...]"`
---