[ https://issues.apache.org/jira/browse/CASSANDRA-2869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13069189#comment-13069189 ]
Hudson commented on CASSANDRA-2869: ----------------------------------- Integrated in Cassandra-0.7 #534 (See [https://builds.apache.org/job/Cassandra-0.7/534/]) Use a UDF-specific context signature. Patch by Jeremy Hanna, reviewed by brandonwilliams for CASSANDRA-2869 brandonwilliams : http://svn.apache.org/viewcvs.cgi/?root=Apache-SVN&view=rev&rev=1149341 Files : * /cassandra/branches/cassandra-0.7/contrib/pig/src/java/org/apache/cassandra/hadoop/pig/CassandraStorage.java > 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 > Fix For: 0.7.9, 0.8.2 > > 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