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 D48222007D1 for ; Thu, 12 May 2016 22:51:30 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id D3421160A15; Thu, 12 May 2016 20:51:30 +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 023ED1602BF for ; Thu, 12 May 2016 22:51:29 +0200 (CEST) Received: (qmail 39586 invoked by uid 500); 12 May 2016 20:51:25 -0000 Mailing-List: contact user-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@flink.apache.org Delivered-To: mailing list user@flink.apache.org Received: (qmail 39356 invoked by uid 99); 12 May 2016 20:51:25 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd3-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 12 May 2016 20:51:25 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd3-us-west.apache.org (ASF Mail Server at spamd3-us-west.apache.org) with ESMTP id 92CDD1857E4 for ; Thu, 12 May 2016 20:45:40 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd3-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 1.28 X-Spam-Level: * X-Spam-Status: No, score=1.28 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, HEADER_FROM_DIFFERENT_DOMAINS=0.001, HTML_MESSAGE=2, RCVD_IN_DNSWL_LOW=-0.7, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, SPF_PASS=-0.001] autolearn=disabled Authentication-Results: spamd3-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=braintreepayments-com.20150623.gappssmtp.com Received: from mx1-lw-us.apache.org ([10.40.0.8]) by localhost (spamd3-us-west.apache.org [10.40.0.10]) (amavisd-new, port 10024) with ESMTP id O4BsjZU2cgyJ for ; Thu, 12 May 2016 20:45:38 +0000 (UTC) Received: from mail-ig0-f169.google.com (mail-ig0-f169.google.com [209.85.213.169]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with ESMTPS id 050615F2C5 for ; Thu, 12 May 2016 20:45:37 +0000 (UTC) Received: by mail-ig0-f169.google.com with SMTP id m9so60490743ige.1 for ; Thu, 12 May 2016 13:45:37 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=braintreepayments-com.20150623.gappssmtp.com; s=20150623; h=mime-version:in-reply-to:references:date:message-id:subject:from:to; bh=OjTe9HRCNz3I2TFzY0XK3LXE9eHa+rhYaHydkKePW60=; b=kB+0bYRqadNeL2bEpz/KIVWlN0oTgDgqJhuC3kjQyKrfSkZnqPC8GZ+CpE+cfe6HXb oNq4sFUdhVowZfZiz7jEpZrhu2G2NcpfUEpvgRzrb1Uj0IvB9E7vZrWe6htjudUs2Mq4 GgqtFlMMU67BtSwefxizXXpYcJ7e6yRaBenQra9Wh6d2ICz3MgbkM2XGJwfFd/oU47xZ ZyRWSQhXFLhyCBhO5c0slzglKtPJakWLaAxJV2w/47ZH8NWfnCXPldYhE1wT7yHCNT2P QsbJCLYIcDfqWkTh++1r02rxsc6HW8ZLHe38liEkMHdLrVgNOzu04thBi0NNdHl+rDs/ 4r8A== 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; bh=OjTe9HRCNz3I2TFzY0XK3LXE9eHa+rhYaHydkKePW60=; b=kUvjNVifary1ovAh6SQLvEu6Z+63Wmm0QsAqJeNaBpA8qmDqyKxw3OOA2sp4YPzsGU Rx88EFxgeAz9CxOa4/AtYKXjRwLHltSsXlJu1eUm6TXPpAxgcNWl7UOVEgdSAwxC5miO F5xk2WEkusSXt5fb5gfXmVZ7mCtB66GfBHIEu3mAGe3FKI9GJVFx4cKcM+2qk1i5NSwZ BCAX1Lg+fPwyk3yAfWIAxi4RmP/mlrvopG7tGk5Q6Lg/ZK83u5DOA5c1ixB1/Zod0FfN zHJJU9cEygkUXpoq9TDd9TFEwUghFhPXSd28qcj8b31Q1ORfMxbMCNqY2bxMCTo8p0cL aQjw== X-Gm-Message-State: AOPr4FWrldcs6mgJWGCwIUeGgMr6yc+I6qhli08i0qC/u4Tft6+hx1/FdZZynJKIqa+yDXhadOBYfViNRAmm2Vqp MIME-Version: 1.0 X-Received: by 10.50.77.5 with SMTP id o5mr27596917igw.33.1463085936836; Thu, 12 May 2016 13:45:36 -0700 (PDT) Received: by 10.107.147.10 with HTTP; Thu, 12 May 2016 13:45:36 -0700 (PDT) In-Reply-To: References: Date: Thu, 12 May 2016 15:45:36 -0500 Message-ID: Subject: Re: Interesting window behavior with savepoints From: Andrew Whitaker To: user@flink.apache.org Content-Type: multipart/alternative; boundary=047d7bdc0ce88ae8100532ab3d19 archived-at: Thu, 12 May 2016 20:51:31 -0000 --047d7bdc0ce88ae8100532ab3d19 Content-Type: text/plain; charset=UTF-8 "Flink can't successfully restore a checkpoint" should be "Flink can't successfully restore a savepoint". On Thu, May 12, 2016 at 3:44 PM, Andrew Whitaker < andrew.whitaker@braintreepayments.com> wrote: > Hi, > > I was recently experimenting with savepoints and various situations in > which they succeed or fail. I expected this example to fail: > > https://gist.github.com/AndrewWhitaker/fa46db04066ea673fe0eda232f0a5ce1 > > Basically, the first program runs with a count window. The second program > is identical except that it uses a time window instead of a count window. > > From what I've observed, most of the time when Flink can't successfully > restore a checkpoint it throws an exception saying as much. I was expecting > to see that behavior here. Could someone explain why this "works" (as in, > flink accepts the program with the savepoint from the first version of the > program), and if this is a bug? > > Thanks, > > -- > Andrew Whitaker | andrew.whitaker@braintreepayments.com > -- Andrew Whitaker | andrew.whitaker@braintreepayments.com -- Note: this information is confidential. It is prohibited to share, post online or otherwise publicize without Braintree's prior written consent. --047d7bdc0ce88ae8100532ab3d19 Content-Type: text/html; charset=UTF-8 Content-Transfer-Encoding: quoted-printable
"Flink can't suc= cessfully restore a checkpoint" should be "Flink can't successfully restore a savepoint".

On Thu= , May 12, 2016 at 3:44 PM, Andrew Whitaker <andrew.whi= taker@braintreepayments.com> wrote:
Hi,

I was recently experimenti= ng with savepoints and various situations in which they succeed or fail. I = expected this example to fail:


Basically, the first program runs with a = count window. The second program is identical except that it uses a time wi= ndow instead of a count window.

From what I've= observed, most of the time when Flink can't successfully restore a che= ckpoint it throws an exception saying as much. I was expecting to see that = behavior here. Could someone explain why this "works" (as in, fli= nk accepts the program with the savepoint from the first version of the pro= gram), and if this is a bug?

Thanks,

--



--
--
Note: this information is confidential. It is p= rohibited to share, post online or otherwise publicize without Braintree= 9;s prior written consent.
--047d7bdc0ce88ae8100532ab3d19--