Return-Path: <user-return-11133-archive-asf-public=cust-asf.ponee.io@flink.apache.org>
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 26D56200C05
	for <archive-asf-public-internal@cust-asf2.ponee.io>; Mon, 23 Jan 2017 19:31:03 +0100 (CET)
Received: by cust-asf.ponee.io (Postfix)
	id 256F4160B49; Mon, 23 Jan 2017 18:31:03 +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 6FD11160B3C
	for <archive-asf-public@cust-asf.ponee.io>; Mon, 23 Jan 2017 19:31:02 +0100 (CET)
Received: (qmail 73726 invoked by uid 500); 23 Jan 2017 18:31:01 -0000
Mailing-List: contact user-help@flink.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:user-help@flink.apache.org>
List-Unsubscribe: <mailto:user-unsubscribe@flink.apache.org>
List-Post: <mailto:user@flink.apache.org>
List-Id: <user.flink.apache.org>
Reply-To: user@flink.apache.org
Delivered-To: mailing list user@flink.apache.org
Received: (qmail 73717 invoked by uid 99); 23 Jan 2017 18:31:01 -0000
Received: from mail-relay.apache.org (HELO mail-relay.apache.org) (140.211.11.15)
    by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 23 Jan 2017 18:31:01 +0000
Received: from mail-it0-f41.google.com (mail-it0-f41.google.com [209.85.214.41])
	by mail-relay.apache.org (ASF Mail Server at mail-relay.apache.org) with ESMTPSA id CF66B1A018B
	for <user@flink.apache.org>; Mon, 23 Jan 2017 18:31:00 +0000 (UTC)
Received: by mail-it0-f41.google.com with SMTP id c7so72553302itd.1
        for <user@flink.apache.org>; Mon, 23 Jan 2017 10:31:00 -0800 (PST)
X-Gm-Message-State: AIkVDXIwcghIl2AgSqm39lLpdYMXDMtSnHYWvnGHapOQt3PLGnf+KY4f6M+2AXKviHErUlsklvFv8n7wjiRpnA==
X-Received: by 10.36.10.3 with SMTP id 3mr15479226itw.108.1485196260164; Mon,
 23 Jan 2017 10:31:00 -0800 (PST)
MIME-Version: 1.0
Received: by 10.107.19.101 with HTTP; Mon, 23 Jan 2017 10:30:59 -0800 (PST)
In-Reply-To: <CAAQE4bNQYRo_wzmEHefD3THP8vafmDa0uEpse5myPr0JQcZX4w@mail.gmail.com>
References: <CAAQE4bNQYRo_wzmEHefD3THP8vafmDa0uEpse5myPr0JQcZX4w@mail.gmail.com>
From: Stephan Ewen <sewen@apache.org>
Date: Mon, 23 Jan 2017 19:30:59 +0100
X-Gmail-Original-Message-ID: <CANC1h_tcPtVYvAODySYsW1uN4=OtE8JZxWxiJQzHSFsK4MsUig@mail.gmail.com>
Message-ID: <CANC1h_tcPtVYvAODySYsW1uN4=OtE8JZxWxiJQzHSFsK4MsUig@mail.gmail.com>
Subject: Re: Is there any difference between Checkpointed and CheckpointedAsynchronously?
To: user@flink.apache.org
Content-Type: multipart/alternative; boundary=001a1143e4ce8278410546c7335d
archived-at: Mon, 23 Jan 2017 18:31:03 -0000

--001a1143e4ce8278410546c7335d
Content-Type: text/plain; charset=UTF-8

Hi!

"CheckpointedAsynchronously" was a hint to the system that the state
objects could be persisted asynchronously, i.e., that the stateful function
could process data concurrently to the persisting operation.

However, this path was never implemented, so the hint was never used.

Flink 1.2 has not yet added an equivalent interface, because the interface
being there without actual support for asynchronous operator state ended up
confusing users.

Stephan


On Mon, Jan 23, 2017 at 3:36 PM, Tao Meng <oatgnem@gmail.com> wrote:

> Hi all,
>    When I read the source code about checkpoint, I can't find any
> difference between Checkpointed and CheckpointedAsynchronously. I can not
> sure that I am correct. The doc about `Asynchronous State Snapshots`
> is commented out in markdown file.
>   I want to know if I am right (there no difference between checkpointed
> and checkpintedAsynchronously in release versions.)
>
>
>

--001a1143e4ce8278410546c7335d
Content-Type: text/html; charset=UTF-8
Content-Transfer-Encoding: quoted-printable

<div dir=3D"ltr">Hi!<div><br></div><div>&quot;CheckpointedAsynchronously&qu=
ot; was a hint to the system that the state objects could be persisted asyn=
chronously, i.e., that the stateful function could process data concurrentl=
y to the persisting operation.</div><div><br></div><div>However, this path =
was never implemented, so the hint was never used.</div><div><br></div><div=
>Flink 1.2 has not yet added an equivalent interface, because the interface=
 being there without actual support for asynchronous operator state ended u=
p confusing users.</div><div><br></div><div>Stephan</div><div><br></div></d=
iv><div class=3D"gmail_extra"><br><div class=3D"gmail_quote">On Mon, Jan 23=
, 2017 at 3:36 PM, Tao Meng <span dir=3D"ltr">&lt;<a href=3D"mailto:oatgnem=
@gmail.com" target=3D"_blank">oatgnem@gmail.com</a>&gt;</span> wrote:<br><b=
lockquote class=3D"gmail_quote" style=3D"margin:0 0 0 .8ex;border-left:1px =
#ccc solid;padding-left:1ex"><div dir=3D"ltr">Hi all,<div>=C2=A0 =C2=A0When=
 I read the source code about checkpoint, I can&#39;t find any difference=
=C2=A0between Checkpointed and CheckpointedAsynchronously. I can not sure t=
hat I am correct. The doc about `Asynchronous State Snapshots` is=C2=A0comm=
ented out in markdown file.</div><div>=C2=A0 I want to know if I am right (=
there no difference between checkpointed and checkpintedAsynchronously in r=
elease versions.)</div><div><br></div><div><br></div></div>
</blockquote></div><br></div>

--001a1143e4ce8278410546c7335d--