POStore.getSchema() returns null because of which PigOutputCommitter is not 
storing schema while cleanup
--------------------------------------------------------------------------------------------------------

                 Key: PIG-2146
                 URL: https://issues.apache.org/jira/browse/PIG-2146
             Project: Pig
          Issue Type: Bug
    Affects Versions: 0.8.1, 0.9.0
            Reporter: Vivek Padmanabhan


The below is my script;
{code}
register piggybank.jar;
a = load 'myinput' using PigStorage(',') as 
(f1:chararray,f2:chararray,f3:chararray);
b = distinct a;
c = limit b 2;
store c into 'pss001' using org.apache.pig.piggybank.storage.PigStorageSchema();
{code}

Input
-------
a,1,aa
b,2,bb
c,3,cc


For this script , PigStorageSchema is not generating  .pig_headers and 
.pig_schema files. While debugging I could see that storeSchema(..) method 
itself is not invoked.The schema object for the store is returned as  null 
(POStore.getSchema()) because of which PigOutputCommitter is not invoking the 
storSchema.

The same schema object is valid when I run it in local mode. This issue is 
happening for Pig 0.9 also.



--
This message is automatically generated by JIRA.
For more information on JIRA, see: http://www.atlassian.com/software/jira

        

Reply via email to