flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-1529) Improve JobManager startup robustness
Date Thu, 12 Feb 2015 17:56:11 GMT

    [ https://issues.apache.org/jira/browse/FLINK-1529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14318633#comment-14318633
] 

ASF GitHub Bot commented on FLINK-1529:
---------------------------------------

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

    https://github.com/apache/flink/pull/385#discussion_r24601755
  
    --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
    @@ -149,7 +134,7 @@ Actor with ActorLogMessages with ActorLogging {
     
       override def receiveWithLogMessages: Receive = {
         case RegisterTaskManager(connectionInfo, hardwareInformation, numberOfSlots) =>
    -      val taskManager = sender
    +      val taskManager = sender()
    --- End diff --
    
    This does not work with older Akka versions, which we are using with the Hadoop-2.0.0-alpha
profile. I think in older Akka version it is a val.


> Improve JobManager startup robustness
> -------------------------------------
>
>                 Key: FLINK-1529
>                 URL: https://issues.apache.org/jira/browse/FLINK-1529
>             Project: Flink
>          Issue Type: Improvement
>          Components: JobManager
>    Affects Versions: 0.9
>            Reporter: Stephan Ewen
>            Assignee: Stephan Ewen
>             Fix For: 0.9
>
>
> Currently, the JobManager is creates asynchronously (as an actor). If its initialization
fails (for various reasons), the process does not terminate and gives only vague log message
that an actor creation failed.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Mime
View raw message