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 6030718C71 for ; Fri, 11 Dec 2015 17:36:42 +0000 (UTC) Received: (qmail 67994 invoked by uid 500); 11 Dec 2015 17:36:42 -0000 Delivered-To: apmail-apex-dev-archive@apex.apache.org Received: (qmail 67936 invoked by uid 500); 11 Dec 2015 17:36:42 -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 67924 invoked by uid 99); 11 Dec 2015 17:36:42 -0000 Received: from Unknown (HELO spamd4-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 11 Dec 2015 17:36:42 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd4-us-west.apache.org (ASF Mail Server at spamd4-us-west.apache.org) with ESMTP id 93FFAC01A8 for ; Fri, 11 Dec 2015 17:36:41 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd4-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 2.98 X-Spam-Level: ** X-Spam-Status: No, score=2.98 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, HTML_MESSAGE=3, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, SPF_PASS=-0.001, URIBL_BLOCKED=0.001] autolearn=disabled Authentication-Results: spamd4-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=datatorrent-com.20150623.gappssmtp.com Received: from mx1-eu-west.apache.org ([10.40.0.8]) by localhost (spamd4-us-west.apache.org [10.40.0.11]) (amavisd-new, port 10024) with ESMTP id 2b7oiP_bLBNV for ; Fri, 11 Dec 2015 17:36:30 +0000 (UTC) Received: from mail-wm0-f54.google.com (mail-wm0-f54.google.com [74.125.82.54]) by mx1-eu-west.apache.org (ASF Mail Server at mx1-eu-west.apache.org) with ESMTPS id BA3E624D8F for ; Fri, 11 Dec 2015 17:36:29 +0000 (UTC) Received: by wmnn186 with SMTP id n186so41504967wmn.0 for ; Fri, 11 Dec 2015 09:36:29 -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=JMmoJ0NCcHRQRJngQjwMGLeChZd1y92WRFztyq+WtU4=; b=wsKYfz7pPzWT5wBm7uVAQovSPoFoQjrmU5w44CMkTIp8dLKNrwGz67are/NmhNAOgV /sdnYQef0zbBHUUEIoTL5Ygigi5ccq/QjoqHZB6Vp9iGj45Dj3UTAKD5SvqwMdGrfzkg UYoJmpDN3gI99vai2agglHXKu/5NHq9hwyPrKvilbsJ9nE4W4ApLYWa165L7KJJkAxCQ diJyMLj4dP4eScaMCZfqSrOinMb7mBll8ivBjp9+B5S4QEotKZBKAArx+BdWZEz6xDBF XoFzmfQUyDhgo5gQhWC2GneqeP7ofDlVasRFS35JKoMMmtedRTS9nNNfU0CjTbydtPkE HRQg== 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=JMmoJ0NCcHRQRJngQjwMGLeChZd1y92WRFztyq+WtU4=; b=E/e3TvMPDd3XfEu9rcbhlYaOuwC36D9cUUwcpEz905Rw1Bf4FEYfQIyxDPmk9Xw8We LUocnifE+GegqOq7liCDNe2/GH2irAgx2rOBfcE3MUsx7YwGAj8WfUU2fo3UJCiSk0gc a4Qa+WhHmPNbxmnS7IhsJ01l5xo/5KKckg1ld++SVvDcvbHRnpNpXggNTJ1MAVH2OS1u 7gzM3H2RCBZg0cic9kmFcPaGaAQGsJXyDfy1y62Q0EGOQOjSyer/wlS8yTXCuTIOCCrI oXYAcE1ro9MS5j713Xk4seC9m4VS6L/6SWOjUjMvso/mBEKCtgSxeRnc+rlOpxOJdu6a aT4g== X-Gm-Message-State: ALoCoQnXRHu9OfyF4LXztEGkjeV4idswRf7vArhsBiVFxcUrhRlTV5Ll+r3TqhW0K0a/XOli6tr3a8YvD/4InGw7ZBS7yhOimsdLlEhbB+7HHozV/SM1rpY= MIME-Version: 1.0 X-Received: by 10.28.212.84 with SMTP id l81mr7785034wmg.50.1449855389381; Fri, 11 Dec 2015 09:36:29 -0800 (PST) Received: by 10.28.178.70 with HTTP; Fri, 11 Dec 2015 09:36:29 -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, 11 Dec 2015 09:36:29 -0800 Message-ID: Subject: Re: Why is Async checkpointing made default? From: Chandni Singh To: dev@apex.incubator.apache.org Content-Type: multipart/alternative; boundary=001a114701ea75d1740526a2c3c8 --001a114701ea75d1740526a2c3c8 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: quoted-printable Hi, There hasn't been a close bracket here (borrowing Ram's expression :-) ). >From what I see the majority agrees with making the fix. Do we need to start a vote for this? On Fri, Nov 27, 2015 at 3:00 PM, Thomas Weise wrote: > Chetan, > > Would like to understand how the checkpointed callback helps you with wha= t > 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 m= e > > 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 = probably 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 t= he > > >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 > practical > > >> >issue but ensures that the code that was written under this > assumption > > >>is > > >> >not broken. > > >> > > >> We can=C2=B9t do it. It would be incorrect. It breaks all the other = code > that > > >> (unassumingly) correctly complied to the semantics. e.g. an operator > > >>which > > >> informs interesting parties that the checkpointed data is available > for > > >> immediate consumption from storage. > > >> > > >> =E2=80=B9 > > >> Chetan > > >> > > >> > > > > > --001a114701ea75d1740526a2c3c8--