From issues-return-536641-archive-asf-public=cust-asf.ponee.io@flink.apache.org Mon Sep 13 13:52:41 2021 Return-Path: X-Original-To: archive-asf-public@mx-eu-03.ponee.io Delivered-To: archive-asf-public@mx-eu-03.ponee.io Received: from mx-eu-01.ponee.io (mx-eu-01.ponee.io [94.130.169.78]) by mx-eu-03.ponee.io (Postfix) with ESMTP id 59FFE3E6BE for ; Mon, 13 Sep 2021 13:52:41 +0200 (CEST) Received: by mx-eu-01.ponee.io (Postfix) id 408F7180676; Mon, 13 Sep 2021 11:52:41 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mxout1-ec2-va.apache.org (mxout1-ec2-va.apache.org [3.227.148.255]) by mx-eu-01.ponee.io (Postfix) with ESMTPS id BC55F180621 for ; Mon, 13 Sep 2021 13:52:40 +0200 (CEST) Received: from mail.apache.org (mailroute1-lw-us.apache.org [207.244.88.153]) by mxout1-ec2-va.apache.org (ASF Mail Server at mxout1-ec2-va.apache.org) with SMTP id ECF7C3FF1E for ; Mon, 13 Sep 2021 11:52:39 +0000 (UTC) Received: (qmail 29980 invoked by uid 500); 13 Sep 2021 11:52:39 -0000 Mailing-List: contact issues-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@flink.apache.org Delivered-To: mailing list issues@flink.apache.org Received: (qmail 29971 invoked by uid 99); 13 Sep 2021 11:52:39 -0000 Received: from ec2-52-202-80-70.compute-1.amazonaws.com (HELO gitbox.apache.org) (52.202.80.70) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 13 Sep 2021 11:52:39 +0000 From: =?utf-8?q?GitBox?= To: issues@flink.apache.org Subject: =?utf-8?q?=5BGitHub=5D_=5Bflink=5D_rkhachatryan_opened_a_new_pull_request_?= =?utf-8?q?=2317258=3A_=5BWIP=5D=5BFLINK-23342=5D=5Bstate=5D_State_ownership?= =?utf-8?q?=3A_compute_shared_state_on_recovery?= Message-ID: Date: Mon, 13 Sep 2021 11:52:39 -0000 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 8bit rkhachatryan opened a new pull request #17258: URL: https://github.com/apache/flink/pull/17258 This is an alternative implementation of FLINK-23342: Sharing information about the state is encoded into the state handles (specifically,low-level state handles such as `FileStateHandle`) This information is passed between JM and TM in both directions and will be used in to decide whether to delete state or not. To accomplish this, `StateAssignmentOperation` computes shared state based on state IDs and rebuilds the snapshot before sending it to TM, marking the corresponding handles as shared. `SharedStateRegistry` is not affected by this change. cc: @StephanEwen -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscribe@flink.apache.org For queries about this service, please contact Infrastructure at: users@infra.apache.org