Github user tillrohrmann commented on a diff in the pull request:

    https://github.com/apache/flink/pull/5184#discussion_r160108453
  
    --- Diff: 
flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniClusterJobDispatcher.java
 ---
    @@ -358,12 +360,12 @@ private DetachedFinalizer(JobID jobID, int 
numJobManagersToWaitFor) {
                }
     
                @Override
    -           public void jobFinished(JobExecutionResult result) {
    +           public void 
jobFinished(org.apache.flink.runtime.jobmaster.JobExecutionResult result) {
                        decrementCheckAndCleanup();
                }
     
                @Override
    -           public void jobFailed(Throwable cause) {
    +           public void 
jobFailed(org.apache.flink.runtime.jobmaster.JobExecutionResult result) {
    --- End diff --
    
    +1


---

Reply via email to