Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 47EA1200C1C for ; Wed, 15 Feb 2017 19:49:53 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id 4677F160B5E; Wed, 15 Feb 2017 18:49:53 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 8F930160B4D for ; Wed, 15 Feb 2017 19:49:52 +0100 (CET) Received: (qmail 59868 invoked by uid 500); 15 Feb 2017 18:49:46 -0000 Mailing-List: contact commits-help@beam.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@beam.apache.org Delivered-To: mailing list commits@beam.apache.org Received: (qmail 59763 invoked by uid 99); 15 Feb 2017 18:49:46 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd2-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 15 Feb 2017 18:49:46 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd2-us-west.apache.org (ASF Mail Server at spamd2-us-west.apache.org) with ESMTP id D7E441A0404 for ; Wed, 15 Feb 2017 18:49:45 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd2-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -1.999 X-Spam-Level: X-Spam-Status: No, score=-1.999 tagged_above=-999 required=6.31 tests=[KAM_LAZY_DOMAIN_SECURITY=1, RP_MATCHES_RCVD=-2.999] autolearn=disabled Received: from mx1-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd2-us-west.apache.org [10.40.0.9]) (amavisd-new, port 10024) with ESMTP id VhNhOpZBlvsC for ; Wed, 15 Feb 2017 18:49:45 +0000 (UTC) Received: from mailrelay1-us-west.apache.org (mailrelay1-us-west.apache.org [209.188.14.139]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with ESMTP id EC7A15F5CC for ; Wed, 15 Feb 2017 18:49:44 +0000 (UTC) Received: from jira-lw-us.apache.org (unknown [207.244.88.139]) by mailrelay1-us-west.apache.org (ASF Mail Server at mailrelay1-us-west.apache.org) with ESMTP id E3419E0272 for ; Wed, 15 Feb 2017 18:49:41 +0000 (UTC) Received: from jira-lw-us.apache.org (localhost [127.0.0.1]) by jira-lw-us.apache.org (ASF Mail Server at jira-lw-us.apache.org) with ESMTP id A1D9F2411D for ; Wed, 15 Feb 2017 18:49:41 +0000 (UTC) Date: Wed, 15 Feb 2017 18:49:41 +0000 (UTC) From: "Thomas Groh (JIRA)" To: commits@beam.incubator.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Resolved] (BEAM-1300) The DirectRunner resumes from unfinalized checkpoints MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 archived-at: Wed, 15 Feb 2017 18:49:53 -0000 [ https://issues.apache.org/jira/browse/BEAM-1300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Groh resolved BEAM-1300. ------------------------------- Resolution: Fixed Fix Version/s: 0.5.0 > The DirectRunner resumes from unfinalized checkpoints > ----------------------------------------------------- > > Key: BEAM-1300 > URL: https://issues.apache.org/jira/browse/BEAM-1300 > Project: Beam > Issue Type: Bug > Components: runner-direct > Reporter: Thomas Groh > Assignee: Thomas Groh > Fix For: 0.5.0 > > > This is a bug in the order in which Source methods are invoked relative to checkpoint methods. Sources may only resume from finalized checkpoints, but the implementation of Unbounded Read in the DirectRunner finalizes a checkpoint after a reader has been created but before it is started. It must be finalized before the reader is created. -- This message was sent by Atlassian JIRA (v6.3.15#6346)