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

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.8.1, 0.9.0
• Fix Version/s: 0.9.0
• Assignee: Thejas Nair
• Reporter: Vivek Padmanabhan
• Created: 28/Jun/11 11:56
• Updated: 04/Aug/11 00:35
• Resolved: 20/Jul/11 22:58

Description

The below is my script;

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();

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.