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 <u...@apache.org> Authored: Tue Dec 15 20:39:17 2015 +0100 Committer: Ufuk Celebi <u...@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
