Created 06-20-2017 04:44 PM
public class TestUdf extends EvalFunc<String>{
@Override public String exec(Tuple input) throws IOException
{
log.info("My message*********************");
String inputData = (String)input.get(0);
return inputData;
}
}
Please check my pig log Properties file in screenshot which is being used by my pig script as shown below.
REGISTER hdfs:///user/maria_dev/test.jar; aa = LOAD 'mydoc' USING PigStorage('\t') as (email: chararray) ; finaloutput =FOREACH aa GENERATE test.TestUdf(email) as email; dump finaloutput;
Created 06-20-2017 06:22 PM
Seems like you are adding these properties directly in the pig properties. Have you tried configuring the actual log4j.properties file that pig uses (I believe under /etc/pig/conf)?
Created 06-21-2017 04:52 AM
I am adding pig log4j.properties from ambari gui .Thanks