Return-Path: X-Original-To: apmail-apex-dev-archive@minotaur.apache.org Delivered-To: apmail-apex-dev-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id C823F18A8A for ; Fri, 27 Nov 2015 23:00:59 +0000 (UTC) Received: (qmail 82678 invoked by uid 500); 27 Nov 2015 23:00:59 -0000 Delivered-To: apmail-apex-dev-archive@apex.apache.org Received: (qmail 82610 invoked by uid 500); 27 Nov 2015 23:00:59 -0000 Mailing-List: contact dev-help@apex.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@apex.incubator.apache.org Delivered-To: mailing list dev@apex.incubator.apache.org Received: (qmail 82584 invoked by uid 99); 27 Nov 2015 23:00:59 -0000 Received: from Unknown (HELO spamd1-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 27 Nov 2015 23:00:59 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd1-us-west.apache.org (ASF Mail Server at spamd1-us-west.apache.org) with ESMTP id B9C0DC14F3 for ; Fri, 27 Nov 2015 23:00:58 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd1-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 4.2 X-Spam-Level: **** X-Spam-Status: No, score=4.2 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, HTML_MESSAGE=3, KAM_LINEPADDING=1.2, SPF_PASS=-0.001, URIBL_BLOCKED=0.001] autolearn=disabled Authentication-Results: spamd1-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=datatorrent-com.20150623.gappssmtp.com Received: from mx1-us-west.apache.org ([10.40.0.8]) by localhost (spamd1-us-west.apache.org [10.40.0.7]) (amavisd-new, port 10024) with ESMTP id 9hVv_Mhe9tMI for ; Fri, 27 Nov 2015 23:00:50 +0000 (UTC) Received: from mail-oi0-f49.google.com (mail-oi0-f49.google.com [209.85.218.49]) by mx1-us-west.apache.org (ASF Mail Server at mx1-us-west.apache.org) with ESMTPS id 8FBC722F01 for ; Fri, 27 Nov 2015 23:00:50 +0000 (UTC) Received: by oiww189 with SMTP id w189so68046275oiw.3 for ; Fri, 27 Nov 2015 15:00:44 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=datatorrent-com.20150623.gappssmtp.com; s=20150623; h=mime-version:in-reply-to:references:date:message-id:subject:from:to :content-type; bh=iKZp9VQuNVMsp29l8etmI2uAoVmdBFrcGaIeM7wXRrg=; b=YcnuglDjUTTQtZclxUJeLXmq2cd2q5HeCPNvFW46aNnzutHDupbCJrj0Mq3qK1FsVR R7+UK5Ai6kXszNYc+6Rg6LclqKtuDZWdbdEfub23JqQtmnjIsT7RZ/6NwgDSpprwYw1F woeIbKLotXwK6kbx82+/0Kh9Do+/g6SL7oq2H0oKquMxmcFfLbQnCZQs3wIutyaqD4ec MfHX/Nfv+uJgXqAmXPYjvCr1lUSkz/3aNoEgwJbVNNclGDSwpOpScZb5YaOfwgDkhOo1 OWavlhwa4yNilqiGLqc73CPhNvSE2Vv7vQHme0duha8DO0bhZH4JPJXMV54gow0iymhS rInw== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20130820; h=x-gm-message-state:mime-version:in-reply-to:references:date :message-id:subject:from:to:content-type; bh=iKZp9VQuNVMsp29l8etmI2uAoVmdBFrcGaIeM7wXRrg=; b=i/6OXs2iaK9uesZX5t6ygSCcUM4t8SyUjExaoFIMEdmZ6dFcn0U1WRYZ4+Ihv/6EYU 9iJP0oHXP7rFFECuALA4G3LJD3Bk/kY4zLN9ZkIbjx4M8MyO+jgtkIdR1E6ZTwlNQdxH pRD5nMHAsZxe6iMDUeX3z8kUVOWliRuweHqJrIUsyNiJ3M6WZT2aQSzRfQM78pHqz36c DJp8oyhtCBBMXfK2EiSP+o8o5tqLAnDVmfK/alDYz49Yni4StQp0NSj2/04pHC7KSbso fc1pnOm3wo3OYcO0QlWDtPO8BTryJVwiNQTmeCQTZ5mn7MMISLV/1sLzXZMWuWJ6m/af UiUw== X-Gm-Message-State: ALoCoQk6/VzDhKD901uJPju6RbVsF6RushJYcuQdjHse9iO9Z8JPuYI7u2kLBaT4ZF7DEJ8mJO3Y MIME-Version: 1.0 X-Received: by 10.202.194.85 with SMTP id s82mr18095879oif.99.1448665243868; Fri, 27 Nov 2015 15:00:43 -0800 (PST) Received: by 10.202.207.131 with HTTP; Fri, 27 Nov 2015 15:00:43 -0800 (PST) In-Reply-To: References: <706A1512-6CE5-482D-86A3-70AB3FC5CB18@datatorrent.com> <5859565A-659C-4C9E-8514-F8E1EC2347E8@datatorrent.com> <3D1508BA-1749-4FFD-A503-133C5C2904B1@datatorrent.com> <09546DAE-DD51-4463-8B36-B54E8981FBD4@datatorrent.com> Date: Fri, 27 Nov 2015 15:00:43 -0800 Message-ID: Subject: Re: Why is Async checkpointing made default? From: Thomas Weise To: dev@apex.incubator.apache.org Content-Type: multipart/alternative; boundary=001a113db09842792005258da94c --001a113db09842792005258da94c Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: quoted-printable Chetan, Would like to understand how the checkpointed callback helps you with what you indicated. This may require a specific example. Let's take it offline. Thomas On Wed, Nov 25, 2015 at 4:07 PM, Chetan Narsude (cnarsude) < cnarsude@cisco.com> wrote: > Yes - a few but cannot share the details - protected under NDA - ping me > in private and I can probably be able to give you more generic details on > similar cooked up examples. > > The part that follows =E2=80=9Ce.g.=E2=80=9D below is an example that pr= obably is > sufficient to infer the use case logically, I think. I shared that to > exemplify how changing the semantics will break semver. > > =E2=80=94 > Chetan > > > > > > > > > > > > On 11/25/15, 3:51 PM, "Thomas Weise" wrote: > > >Do you have a specific example? > > > >I see this happening in committed(), but not in checkpointed() where the > >checkpoint remains intermediate, whether it was copied to HDFS or not. > > > > > >On Wed, Nov 25, 2015 at 3:42 PM, Chetan Narsude (cnarsude) < > >cnarsude@cisco.com> wrote: > > > >> > > >> >Until we have this, how about we restore the previous behavior > >> >temporarily? > >> >Calling checkpointed() immediately does not seem to pose any practica= l > >> >issue but ensures that the code that was written under this assumptio= n > >>is > >> >not broken. > >> > >> We can=C2=B9t do it. It would be incorrect. It breaks all the other co= de that > >> (unassumingly) correctly complied to the semantics. e.g. an operator > >>which > >> informs interesting parties that the checkpointed data is available fo= r > >> immediate consumption from storage. > >> > >> =E2=80=B9 > >> Chetan > >> > >> > > --001a113db09842792005258da94c--