Return-Path: X-Original-To: apmail-cassandra-commits-archive@www.apache.org Delivered-To: apmail-cassandra-commits-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id E618D6726 for ; Wed, 13 Jul 2011 14:31:27 +0000 (UTC) Received: (qmail 1809 invoked by uid 500); 13 Jul 2011 14:31:27 -0000 Delivered-To: apmail-cassandra-commits-archive@cassandra.apache.org Received: (qmail 1783 invoked by uid 500); 13 Jul 2011 14:31:27 -0000 Mailing-List: contact commits-help@cassandra.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@cassandra.apache.org Delivered-To: mailing list commits@cassandra.apache.org Received: (qmail 1775 invoked by uid 99); 13 Jul 2011 14:31:26 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 13 Jul 2011 14:31:26 +0000 X-ASF-Spam-Status: No, hits=-2000.0 required=5.0 tests=ALL_TRUSTED,T_RP_MATCHES_RCVD X-Spam-Check-By: apache.org Received: from [140.211.11.116] (HELO hel.zones.apache.org) (140.211.11.116) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 13 Jul 2011 14:31:21 +0000 Received: from hel.zones.apache.org (hel.zones.apache.org [140.211.11.116]) by hel.zones.apache.org (Postfix) with ESMTP id 1ADCF4EF8D for ; Wed, 13 Jul 2011 14:31:00 +0000 (UTC) Date: Wed, 13 Jul 2011 14:31:00 +0000 (UTC) From: "Jeremy Hanna (JIRA)" To: commits@cassandra.apache.org Message-ID: <727399674.9972.1310567460106.JavaMail.tomcat@hel.zones.apache.org> In-Reply-To: <756559705.8350.1310063236779.JavaMail.tomcat@hel.zones.apache.org> Subject: [jira] [Updated] (CASSANDRA-2869) CassandraStorage does not function properly when used multiple times in a single pig script due to UDFContext sharing issues MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 X-Virus-Checked: Checked by ClamAV on apache.org [ https://issues.apache.org/jira/browse/CASSANDRA-2869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeremy Hanna updated CASSANDRA-2869: ------------------------------------ Attachment: 2869-2.txt Removed that String. Also removed adding mutation twice and put in the nested exception in putNext into the IOException. We've been meaning to add those last two items to one of these tickets. > CassandraStorage does not function properly when used multiple times in a single pig script due to UDFContext sharing issues > ---------------------------------------------------------------------------------------------------------------------------- > > Key: CASSANDRA-2869 > URL: https://issues.apache.org/jira/browse/CASSANDRA-2869 > Project: Cassandra > Issue Type: Bug > Components: Contrib > Affects Versions: 0.7.2 > Reporter: Grant Ingersoll > Assignee: Jeremy Hanna > Attachments: 2869-2.txt, 2869.txt > > > CassandraStorage appears to have threading issues along the lines of those described at http://pig.markmail.org/message/oz7oz2x2dwp66eoz due to the sharing of the UDFContext. > I believe the fix lies in implementing > {code} > public void setStoreFuncUDFContextSignature(String signature) > { > } > {code} > and then using that signature when getting the UDFContext. > From the Pig manual: > {quote} > setStoreFunc!UDFContextSignature(): This method will be called by Pig both in the front end and back end to pass a unique signature to the Storer. The signature can be used to store into the UDFContext any information which the Storer needs to store between various method invocations in the front end and back end. The default implementation in StoreFunc has an empty body. This method will be called before other methods. > {quote} -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira