flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From u..@apache.org
Subject [1/3] flink git commit: [FLINK-3074] [yarn] Fix port range retry termination condition
Date Fri, 15 Jan 2016 15:31:07 GMT
Repository: flink
Updated Branches:
  refs/heads/master cfcb5d7ba -> e43b970aa


[FLINK-3074] [yarn] Fix port range retry termination condition


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

Branch: refs/heads/master
Commit: cf7045c2dc07615c3ec3885134b9bfddd72deb97
Parents: cfcb5d7
Author: Ufuk Celebi <uce@apache.org>
Authored: Tue Dec 15 20:39:17 2015 +0100
Committer: Ufuk Celebi <uce@apache.org>
Committed: Fri Jan 15 16:11:33 2016 +0100

----------------------------------------------------------------------
 .../main/scala/org/apache/flink/yarn/ApplicationMasterBase.scala   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/cf7045c2/flink-yarn/src/main/scala/org/apache/flink/yarn/ApplicationMasterBase.scala
----------------------------------------------------------------------
diff --git a/flink-yarn/src/main/scala/org/apache/flink/yarn/ApplicationMasterBase.scala b/flink-yarn/src/main/scala/org/apache/flink/yarn/ApplicationMasterBase.scala
index 28b0aa3..95521a0 100644
--- a/flink-yarn/src/main/scala/org/apache/flink/yarn/ApplicationMasterBase.scala
+++ b/flink-yarn/src/main/scala/org/apache/flink/yarn/ApplicationMasterBase.scala
@@ -180,7 +180,7 @@ abstract class ApplicationMasterBase {
       }
 
       // try starting the actor system
-      val result = retry(startActorSystem(portsIterator), {portsIterator.hasNext})
+      val result = retry(startActorSystem(portsIterator), {!portsIterator.hasNext})
 
       val (actorSystem, jmActor, archiveActor, webMonitor) = result match {
         case Success(r) => r


Mime
View raw message