flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From trohrm...@apache.org
Subject flink git commit: [runtime] Fixes re-submission of a job by JobClient
Date Thu, 12 Feb 2015 13:18:31 GMT
Repository: flink
Updated Branches:
  refs/heads/master fab1bd9dc -> 46a675ccb


[runtime] Fixes re-submission of a job by JobClient


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/46a675cc
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/46a675cc
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/46a675cc

Branch: refs/heads/master
Commit: 46a675ccb1b6a55f9c6963264fa3f231fed4b3c0
Parents: fab1bd9
Author: Till Rohrmann <trohrmann@apache.org>
Authored: Thu Feb 12 12:40:24 2015 +0100
Committer: Till Rohrmann <trohrmann@apache.org>
Committed: Thu Feb 12 14:18:04 2015 +0100

----------------------------------------------------------------------
 .../main/scala/org/apache/flink/runtime/client/JobClient.scala  | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/46a675cc/flink-runtime/src/main/scala/org/apache/flink/runtime/client/JobClient.scala
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/scala/org/apache/flink/runtime/client/JobClient.scala
b/flink-runtime/src/main/scala/org/apache/flink/runtime/client/JobClient.scala
index 191e11a..676ddda 100644
--- a/flink-runtime/src/main/scala/org/apache/flink/runtime/client/JobClient.scala
+++ b/flink-runtime/src/main/scala/org/apache/flink/runtime/client/JobClient.scala
@@ -171,10 +171,11 @@ object JobClient{
     var waitForAnswer = true
     var answer: JobExecutionResult = null
 
+    val result =(jobClient ? SubmitJobAndWait(jobGraph, listenToEvents = listenToStatusEvents))(
+      AkkaUtils.INF_TIMEOUT).mapTo[JobExecutionResult]
+
     while(waitForAnswer) {
       try {
-        val result =(jobClient ? SubmitJobAndWait(jobGraph, listenToEvents = listenToStatusEvents))(
-          timeout).mapTo[JobExecutionResult]
         answer = Await.result(result, timeout)
         waitForAnswer = false
       } catch {


Mime
View raw message