Return-Path: X-Original-To: apmail-flink-issues-archive@minotaur.apache.org Delivered-To: apmail-flink-issues-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 69BE317C81 for ; Mon, 26 Jan 2015 17:37:58 +0000 (UTC) Received: (qmail 11797 invoked by uid 500); 26 Jan 2015 17:37:58 -0000 Delivered-To: apmail-flink-issues-archive@flink.apache.org Received: (qmail 11752 invoked by uid 500); 26 Jan 2015 17:37:58 -0000 Mailing-List: contact issues-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@flink.apache.org Delivered-To: mailing list issues@flink.apache.org Received: (qmail 11743 invoked by uid 99); 26 Jan 2015 17:37:58 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 26 Jan 2015 17:37:58 +0000 X-ASF-Spam-Status: No, hits=-2000.0 required=5.0 tests=ALL_TRUSTED,T_RP_MATCHES_RCVD X-Spam-Check-By: apache.org Received: from [140.211.11.3] (HELO mail.apache.org) (140.211.11.3) by apache.org (qpsmtpd/0.29) with SMTP; Mon, 26 Jan 2015 17:37:37 +0000 Received: (qmail 11437 invoked by uid 99); 26 Jan 2015 17:37:35 -0000 Received: from arcas.apache.org (HELO arcas.apache.org) (140.211.11.28) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 26 Jan 2015 17:37:34 +0000 Date: Mon, 26 Jan 2015 17:37:34 +0000 (UTC) From: "ASF GitHub Bot (JIRA)" To: issues@flink.incubator.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Commented] (FLINK-1415) Akka cleanups MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 X-Virus-Checked: Checked by ClamAV on apache.org [ https://issues.apache.org/jira/browse/FLINK-1415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14292134#comment-14292134 ] ASF GitHub Bot commented on FLINK-1415: --------------------------------------- Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/319#issuecomment-71501654 Do you think this change is also addressing this error? https://travis-ci.org/rmetzger/flink/jobs/48365538 > 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 (v6.3.4#6332)