flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Till Rohrmann (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-1415) Akka cleanups
Date Sun, 18 Jan 2015 22:55:34 GMT
Till Rohrmann created FLINK-1415:

             Summary: Akka cleanups
                 Key: FLINK-1415
                 URL: https://issues.apache.org/jira/browse/FLINK-1415
             Project: Flink
          Issue Type: Improvement
            Reporter: Till Rohrmann
            Assignee: Till Rohrmann

Currently, Akka has many different timeout values. From a user perspective, it would be helpful
to deduce all different timeouts from a single timeout value. Additionally, the user should
still be able to define specific values for the different timeouts.

Akka uses the akka.jobmanager.url config parameter to override the jobmanager address and
the port in case of a local setup. This mechanism is not safe since it is exposed to the user.
Thus, the mechanism should be replaced.

The notifyExecutionStateChange method allows objects to access the internal state of the TaskManager
actor. This causes NullPointerExceptions when shutting down the actor. This method should
be removed to avoid accessing the internal state of an actor by another object.

With the latest Akka changes, the TaskManager watches the JobManager in order to detect when
it died or lost the connection to the TaskManager. This behaviour should be tested.

This message was sent by Atlassian JIRA

View raw message