Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/6203#discussion_r199198501 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/job/JobSubmitHandlerTest.java --- @@ -71,20 +112,131 @@ public void testSerializationFailureHandling() throws Exception { @Test public void testSuccessfulJobSubmission() throws Exception { + final Path jobGraphFile = TEMPORARY_FOLDER.newFile().toPath(); + try (OutputStream fileOut = Files.newOutputStream(jobGraphFile)) { + try (ObjectOutputStream objectOut = new ObjectOutputStream(fileOut)) { + objectOut.writeObject(new JobGraph("testjob")); + } + } + DispatcherGateway mockGateway = mock(DispatcherGateway.class); --- End diff -- Maybe replace by `TestingDispatcherGateway`.
---