From user-return-24372-archive-asf-public=cust-asf.ponee.io@flink.apache.org Thu Nov 15 18:20:44 2018 Return-Path: X-Original-To: archive-asf-public@cust-asf.ponee.io Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx-eu-01.ponee.io (Postfix) with SMTP id C8A09180669 for ; Thu, 15 Nov 2018 18:20:43 +0100 (CET) Received: (qmail 59329 invoked by uid 500); 15 Nov 2018 17:20:42 -0000 Mailing-List: contact user-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Delivered-To: mailing list user@flink.apache.org Received: (qmail 59319 invoked by uid 99); 15 Nov 2018 17:20:42 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd4-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 15 Nov 2018 17:20: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 1D575C030E for ; Thu, 15 Nov 2018 17:20:42 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd4-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -1.411 X-Spam-Level: X-Spam-Status: No, score=-1.411 tagged_above=-999 required=6.31 tests=[DKIMWL_WL_MED=-1.459, DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1, DKIM_VALID_EF=-0.1, FREEMAIL_ENVFROM_END_DIGIT=0.25, RCVD_IN_DNSWL_NONE=-0.0001, SPF_HELO_PASS=-0.001, SPF_PASS=-0.001] autolearn=disabled Authentication-Results: spamd4-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=hotmail.com Received: from mx1-lw-us.apache.org ([10.40.0.8]) by localhost (spamd4-us-west.apache.org [10.40.0.11]) (amavisd-new, port 10024) with ESMTP id ODV0EMDvK6v2 for ; Thu, 15 Nov 2018 17:20:40 +0000 (UTC) Received: from NAM04-BN3-obe.outbound.protection.outlook.com (mail-oln040092009052.outbound.protection.outlook.com [40.92.9.52]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with ESMTPS id 42E685FAD8 for ; Thu, 15 Nov 2018 17:20:40 +0000 (UTC) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=hotmail.com; s=selector1; h=From:Date:Subject:Message-ID:Content-Type:MIME-Version:X-MS-Exchange-SenderADCheck; bh=ozQyaMN/ij5AS7vTmr7FQx80gl1Ymcm6oe4xPIVqlLE=; b=BDujmmI1MgHfRmUXGMxuIdPoR1KImuLfDAdIUugUO5E3sSiwzMsZr8AkWLSNjjkimOl88kS2kCNDsN45Krd60Gzmp+na1xRM6Vt9U2Q07u4WBqef6PzC0tNzCDtNSuUNFyCgDORHipTnBu/pwzVqrcv9OfLGEjDIWqu+K6vH910ix85cwVZkeKFC3PIl3Tk/O9Mw80cFZlpTX2AqIa0jL83DoVJsFhse8Z1OmGqHYq9mz+3I/SvoEC/1GEERycpmiNgWPjBpfmvAEkAGr/mPjkvbhlaSiAYhlGEDz4eX2VwaueqC/9WdjI3VCaapoTTKZ1EfjQCNSr17QKn7MOULLQ== Received: from BN3NAM04FT039.eop-NAM04.prod.protection.outlook.com (10.152.92.58) by BN3NAM04HT097.eop-NAM04.prod.protection.outlook.com (10.152.93.173) with Microsoft SMTP Server (version=TLS1_2, cipher=TLS_ECDHE_RSA_WITH_AES_256_CBC_SHA384) id 15.20.1339.10; Thu, 15 Nov 2018 17:20:33 +0000 Received: from CY4PR11MB1719.namprd11.prod.outlook.com (10.152.92.53) by BN3NAM04FT039.mail.protection.outlook.com (10.152.93.3) with Microsoft SMTP Server (version=TLS1_2, cipher=TLS_ECDHE_RSA_WITH_AES_256_CBC_SHA384) id 15.20.1339.10 via Frontend Transport; Thu, 15 Nov 2018 17:20:33 +0000 Received: from CY4PR11MB1719.namprd11.prod.outlook.com ([fe80::f987:ca3e:9fb8:8055]) by CY4PR11MB1719.namprd11.prod.outlook.com ([fe80::f987:ca3e:9fb8:8055%4]) with mapi id 15.20.1294.045; Thu, 15 Nov 2018 17:20:33 +0000 From: Olga Luganska To: "user@flink.apache.org" Subject: =?Windows-1252?Q?Enabling_Flink=92s_checkpointing?= Thread-Topic: =?Windows-1252?Q?Enabling_Flink=92s_checkpointing?= Thread-Index: AQHUfQeDM/EpFj4e0kyiAvCNUU+6ew== Date: Thu, 15 Nov 2018 17:20:33 +0000 Message-ID: Accept-Language: en-US Content-Language: en-US X-MS-Has-Attach: X-MS-TNEF-Correlator: x-incomingtopheadermarker: OriginalChecksum:AAE968BF8DB0CB1E4581D03CA2B2709AB9EA4312B18B0ED65F649B1C8D9F8D6C;UpperCasedChecksum:77039F28BF95517F0A01998D57715DB1D48853E1E22D6A3AF10DC9526383F269;SizeAsReceived:6872;Count:44 x-ms-exchange-messagesentrepresentingtype: 1 x-tmn: [uuMm0gCcb4PIqGcZYDRXkNgIrNfFkgfR] x-ms-publictraffictype: Email x-microsoft-exchange-diagnostics: 1;BN3NAM04HT097;6:EZc5ICPdnGoDAN443DKtHlwAk3ReSWNEg232W046NkFVw8JkJd2urDqIRUliWIi/Izh+HSJzlMzH52c212y/Fy1Oo/bS8ztrQ8pZx+Zjeden4uQbcGzJZbf9iLglZcy6jZMt6yJAVKpNArZXGsLoBIsxNlOvkq359zIRo9EZpMqFinoPRzjmO2JoQGmTiPEIcdH0VUQIqJ7kb4Bm8Wb0UmoZPXRgF/NRHg0lOsDT6F7Nod32LWD08rFlfhz4EFWUcufElXxz2rkWr8tIbwPER9pbmM3hvVw7OwVM9S1DPwuvq0Z14qTNc2q7Dy6J3wNlGoohLzBASMUCTo7Hse83MZn9Uuq8Wt65jlOCAKyiOF2vBz5e6oGVw4B3a1kDFjx4wFI36zixQ9Q0lqcsiV9euFzKLquN8zT68VMyrgTtXx7BLBfFVuo5SUvghpVRYS0LEEdQXxm3oLf+FIcESr4xug==;5:qZD91J4kvYlijJ6GPhsUXXIDfKHxHCk+oAVpGaFRkqsb2O95/jjMjSfvAA7fFzErwpZzgzJ+S2soFHPXn4n3ta547rbH1V1iAl9W4BejWbu62laxDcTjuAHXlhKFCG6QcW163zqaz+cPYu8X9nGReapNc1A2AOBESULTPGo1vwU=;7:DKgEdoStCXJ+IlRhvQXy3AJI3bGm/Lyy0HalKeYmqLdl7L2fkuM9pxu5XRXg6xAFqhFyDn6UkNJPEaMhZmFoyRei/09irdQdf9gGjaZ7/f8nGUJV9SnFUFVnxFMDmOviNkGJTJ+9N+czE65KuoAy0g== x-incomingheadercount: 44 x-eopattributedmessage: 0 x-microsoft-antispam: BCL:0;PCL:0;RULEID:(2390098)(7020095)(201702061078)(5061506573)(5061507331)(1603103135)(2017031320274)(2017031324274)(2017031323274)(2017031322404)(1601125500)(1603101475)(1701031045);SRVR:BN3NAM04HT097; x-ms-traffictypediagnostic: BN3NAM04HT097: x-exchange-antispam-report-cfa-test: BCL:0;PCL:0;RULEID:(4566010)(82015058);SRVR:BN3NAM04HT097;BCL:0;PCL:0;RULEID:;SRVR:BN3NAM04HT097; x-microsoft-antispam-message-info: YZEDr+UQ8j9cvqHlRDcAZOPBihOQPQMiZkXKJmZM1poEnyGt2kpQ9kBmx5vYNAKZ Content-Type: text/plain; charset="Windows-1252" Content-ID: <9C7415B050CE6B489582B042EDE194F9@sct-15-20-755-16-msonline-outlook-1ab08.templateTenant> Content-Transfer-Encoding: quoted-printable MIME-Version: 1.0 X-OriginatorOrg: hotmail.com X-MS-Exchange-CrossTenant-RMS-PersistedConsumerOrg: 9bd8b953-1c55-4da7-b616-8bcad099ae8b X-MS-Exchange-CrossTenant-Network-Message-Id: 6093e834-7891-4166-87a5-08d64b1ea659 X-MS-Exchange-CrossTenant-rms-persistedconsumerorg: 9bd8b953-1c55-4da7-b616-8bcad099ae8b X-MS-Exchange-CrossTenant-originalarrivaltime: 15 Nov 2018 17:20:33.0370 (UTC) X-MS-Exchange-CrossTenant-fromentityheader: Internet X-MS-Exchange-CrossTenant-id: 84df9e7f-e9f6-40af-b435-aaaaaaaaaaaa X-MS-Exchange-Transport-CrossTenantHeadersStamped: BN3NAM04HT097 Hello, By reading Flink documentation I see that to enable checkpointing we need t= o: 1. Enable checkpointing at the execution environment. 2. Make sure that your source/sink implements either CheckpointedFunction o= r ListCheckpointed interfaces? Is #2 a must, and how checkpointing mechanism is affected if your source do= es not implement mentioned above interfaces? (I see example of using RuntimeContext accessing keyed state) Please explain. Thank you very much, Olga Sent from my iPhone=