From user-return-499-archive-asf-public=cust-asf.ponee.io@arrow.apache.org Wed Jun 10 15:51:47 2020 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 [207.244.88.153]) by mx-eu-01.ponee.io (Postfix) with SMTP id A92B218062B for ; Wed, 10 Jun 2020 17:51:46 +0200 (CEST) Received: (qmail 80790 invoked by uid 500); 10 Jun 2020 15:51:45 -0000 Mailing-List: contact user-help@arrow.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@arrow.apache.org Delivered-To: mailing list user@arrow.apache.org Received: (qmail 80780 invoked by uid 99); 10 Jun 2020 15:51:45 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd2-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 10 Jun 2020 15:51:45 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd2-us-west.apache.org (ASF Mail Server at spamd2-us-west.apache.org) with ESMTP id E92741A33E2 for ; Wed, 10 Jun 2020 15:51:44 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd2-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 0.25 X-Spam-Level: X-Spam-Status: No, score=0.25 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1, DKIM_VALID_EF=-0.1, FREEMAIL_ENVFROM_END_DIGIT=0.25, HTML_MESSAGE=0.2, RCVD_IN_DNSWL_NONE=-0.0001, SPF_HELO_NONE=0.001, SPF_PASS=-0.001] autolearn=disabled Authentication-Results: spamd2-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=gmail.com Received: from mx1-he-de.apache.org ([10.40.0.8]) by localhost (spamd2-us-west.apache.org [10.40.0.9]) (amavisd-new, port 10024) with ESMTP id OB-uzCClW3nY for ; Wed, 10 Jun 2020 15:51:43 +0000 (UTC) Received-SPF: Pass (mailfrom) identity=mailfrom; client-ip=2a00:1450:4864:20::435; helo=mail-wr1-x435.google.com; envelope-from=saurabh.cse16@gmail.com; receiver= Received: from mail-wr1-x435.google.com (mail-wr1-x435.google.com [IPv6:2a00:1450:4864:20::435]) by mx1-he-de.apache.org (ASF Mail Server at mx1-he-de.apache.org) with ESMTPS id 958B07F581 for ; Wed, 10 Jun 2020 15:51:42 +0000 (UTC) Received: by mail-wr1-x435.google.com with SMTP id c3so2820916wru.12 for ; Wed, 10 Jun 2020 08:51:42 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20161025; h=mime-version:from:date:message-id:subject:to; bh=0fbJzkC7Ipt/q2OdodBhEaLVhwhISEjzFEnWuKpWeMs=; b=JNyj7Vgpjw7GdzStg0BT1k6LqcosO5/mcA0QFCBPPAf4uAM5Krf3ZOIykvg2eS1kVs pk1UYwcG8yGicGMy14mClEbGbKNSqOJEx+m00P1+y4PQrFmiggrzmn+U8hhksJpTE0fB QoWiliohUswHJ8uKg2CJPtxJlNn0UD9VVY7im9UCbeEIDDz8avYHwvFdWxOLIIVornAi uT7F435FmCQaXnGjfkTSVeCb/kQOzQO4eeL+ZAtLd2FzaUi6y5tp2tjPLgq6LfUEbQWK Bb3MMm/tPpXXlIBwsk+oXP298csHy/g0DEyoq6Qs70tOwKCSzEl7BCkWOVRB4x4qiqJ6 QFYQ== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:mime-version:from:date:message-id:subject:to; bh=0fbJzkC7Ipt/q2OdodBhEaLVhwhISEjzFEnWuKpWeMs=; b=DDCxHITCIOPzDsrf8dBMIrQ5hOG9tjh0aDGNIBzjjrsd0w59UtqaU9V+H0rGPmAnwW jV7c2QJ+nqlzlkG7Vob0ljWsnmouqKrz4AuagKooU86rbT9uYjPNj6C3JaSTNa4fKiAj kI16gczCMG3tcyQvCRG7ZiON6HS3vmXkW++ex+UCd2To8WlnT449KAyU73aVPEUGH+oE JEikiLo3fWskYlAQVjqDgHPOkz/T0jBpb+dY7jQxkwr0HJAg9pK+V7w2x7czIcMXrAe3 HizT2N9a0fI26CvsTciO9zA6AGoiWiOqFy/0Q5kttUb+YXMbFz2+1fLuJH9XMuNrD+/G G0pA== X-Gm-Message-State: AOAM533DbQlBpGgXqmMETtPFCXi7jkhYX9Jo1sxK9bOriNycXnejbPZ3 FdZvPnc/afFI6ee+6fHi3t+lpTSgw9lMKsFwy5k3mjOJiEk= X-Google-Smtp-Source: ABdhPJxcxhKFyxL8kmuYNaAzuj25B6ezp1GxFYCW6BL2CPvvgagolYpy2ltGOPg4rTTITWnZuz0pYVRAxC4pZRlzf3c= X-Received: by 2002:a5d:400f:: with SMTP id n15mr4667145wrp.419.1591804301549; Wed, 10 Jun 2020 08:51:41 -0700 (PDT) MIME-Version: 1.0 From: saurabh pratap singh Date: Wed, 10 Jun 2020 21:21:30 +0530 Message-ID: Subject: python plasma client get_buffers behavior To: user@arrow.apache.org Content-Type: multipart/alternative; boundary="000000000000f224df05a7bcd1c9" --000000000000f224df05a7bcd1c9 Content-Type: text/plain; charset="UTF-8" Hi We are using python plasma client to do a get_buffers for arrow tables created by java in plasma . The python plasma client basically polls on a queue and do a get_buffers on the object ids returned from the queue. What I have observed is tin context of plasma object table entry for those object ids is that the get_buffers will first increment the ref count by 1 and then there is an implicit release call which decreases the ref count again . But when there are no more entries in the queue I see that few object ids still have a lingering reference count in plasma wrt to get_buffers and there was no "implicit" release for that get call like previous one. Plasma version is 0.15.x Is this expected ? Is there any way I can handle this and make and explicit release for such object ids as well . Thanks --000000000000f224df05a7bcd1c9 Content-Type: text/html; charset="UTF-8" Content-Transfer-Encoding: quoted-printable
Hi=C2=A0

We are using python plasma cli= ent to do a get_buffers for arrow tables created by java in plasma .
<= div>
The python plasma client basically polls on a queue and = do a get_buffers on the object=C2=A0ids returned from the queue.
= What I have observed is tin context of plasma object table entry for those = object ids is that the get_buffers will first increment the ref count by 1 = and then there is an implicit=C2=A0 release call which decreases the ref co= unt again .

But when there are no more entries in = the queue I see that few object ids still have a lingering reference count = in plasma wrt to get_buffers and there was no "implicit" release = for that get call like previous one.
Plasma version is 0.15.x
=C2=A0Is this expected ?
Is there any way I can handle thi= s and make and explicit release for such object ids as well .
Thanks=C2=A0
--000000000000f224df05a7bcd1c9--