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 8535E17D91 for ; Fri, 16 Oct 2015 16:10:05 +0000 (UTC) Received: (qmail 49835 invoked by uid 500); 16 Oct 2015 16:10:05 -0000 Delivered-To: apmail-flink-issues-archive@flink.apache.org Received: (qmail 49772 invoked by uid 500); 16 Oct 2015 16:10:05 -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 49692 invoked by uid 99); 16 Oct 2015 16:10:05 -0000 Received: from arcas.apache.org (HELO arcas.apache.org) (140.211.11.28) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 16 Oct 2015 16:10:05 +0000 Date: Fri, 16 Oct 2015 16:10:05 +0000 (UTC) From: "Stephan Ewen (JIRA)" To: issues@flink.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Closed] (FLINK-2846) Emit checkpoint barriers earlier, before drawing the state snapshot MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 [ https://issues.apache.org/jira/browse/FLINK-2846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2846. ------------------------------- > Emit checkpoint barriers earlier, before drawing the state snapshot > ------------------------------------------------------------------- > > Key: FLINK-2846 > URL: https://issues.apache.org/jira/browse/FLINK-2846 > Project: Flink > Issue Type: Improvement > Components: Streaming > Affects Versions: 0.10 > Reporter: Stephan Ewen > Assignee: Stephan Ewen > Fix For: 0.10 > > > State snapshot drawing and downstream barrier emitting occur in an atomic scope. Currently, the barriers are emitted after the state snapshot has been drawn. > There is no reason why the barriers could not be emitted at the beginning of the atomic scope, and it would reduce the short stalls in the streaming pipeline when drawing the state snapshot of an operator checkpoint. -- This message was sent by Atlassian JIRA (v6.3.4#6332)