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 43B6317DB7 for ; Fri, 7 Nov 2014 10:16:58 +0000 (UTC) Received: (qmail 73136 invoked by uid 500); 7 Nov 2014 10:16:58 -0000 Delivered-To: apmail-flink-issues-archive@flink.apache.org Received: (qmail 73091 invoked by uid 500); 7 Nov 2014 10:16:58 -0000 Mailing-List: contact issues-help@flink.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@flink.incubator.apache.org Delivered-To: mailing list issues@flink.incubator.apache.org Received: (qmail 73081 invoked by uid 99); 7 Nov 2014 10:16:58 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 07 Nov 2014 10:16:58 +0000 X-ASF-Spam-Status: No, hits=-2000.6 required=5.0 tests=ALL_TRUSTED,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; Fri, 07 Nov 2014 10:16:35 +0000 Received: (qmail 72963 invoked by uid 99); 7 Nov 2014 10:16:33 -0000 Received: from arcas.apache.org (HELO arcas.apache.org) (140.211.11.28) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 07 Nov 2014 10:16:33 +0000 Date: Fri, 7 Nov 2014 10:16:33 +0000 (UTC) From: "Stephan Ewen (JIRA)" To: issues@flink.incubator.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Commented] (FLINK-1222) Let tasks finish as soon as their data is sent 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-1222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14201878#comment-14201878 ] Stephan Ewen commented on FLINK-1222: ------------------------------------- I added this change non the less, it was a 5 minute fix. It lets the web monitor plots reflect the actual execution times much better. > Let tasks finish as soon as their data is sent > ---------------------------------------------- > > Key: FLINK-1222 > URL: https://issues.apache.org/jira/browse/FLINK-1222 > Project: Flink > Issue Type: Improvement > Components: Distributed Runtime > Affects Versions: 0.8-incubating > Reporter: Stephan Ewen > Assignee: Stephan Ewen > Priority: Minor > Fix For: 0.8-incubating > > > Currently tasks finish only after their successor has left the run() method, because only then the close acknowledgements are sent. Sending the close acknowledgements earlier would free resources earlier and lead to more understandable execution timestamps. -- This message was sent by Atlassian JIRA (v6.3.4#6332)