Hi,
in my UDF (Java) the following code throws and NPE, when executed in -x
mapred mode:
Configuration jobConf = UDFContext.getUDFContext().getJobConf();
System.err.println(jobConf.toString());
I did not find any useful information as why my JobConf is always null. All
I find is that this is the
Sure, just did https://issues.apache.org/jira/browse/PIG-3554
Kind regards
2013/10/30 Cheolsoo Park
> Indeed. Do you mind filing a jira?
> https://issues.apache.org/jira/browse/PIG
>
>
> On Wed, Oct 30, 2013 at 11:34 AM, Henning Kropp >wrote:
>
> > Wow, I was pretty sure to have tested it, bu
Indeed. Do you mind filing a jira?
https://issues.apache.org/jira/browse/PIG
On Wed, Oct 30, 2013 at 11:34 AM, Henning Kropp wrote:
> Wow, I was pretty sure to have tested it, but apparently not. The reason
> for the NPE seems to be the @MonitoredUDF
>
> You can reproduced it with the following
Wow, I was pretty sure to have tested it, but apparently not. The reason
for the NPE seems to be the @MonitoredUDF
You can reproduced it with the following code:
import java.io.IOException;
import java.util.concurrent.TimeUnit;
import org.apache.hadoop.conf.Configuration;
import org.apache.pig.Ev
Are you able to post your UDF (or at least a sanitized version)?
On Wed, Oct 30, 2013 at 10:46 AM, Henning Kropp wrote:
> Hi,
>
> thanks for your reply. I read about the expected behavior on the front-end
> and I am getting the NPE on the back-end. The Mappers log the Exception
> during Executio
Hi,
thanks for your reply. I read about the expected behavior on the front-end
and I am getting the NPE on the back-end. The Mappers log the Exception
during Execution.
I am currently digging through debug messages. What to look out for? There
are bunch of
[main] DEBUG org.apache.hadoop.conf.Con
Hi,
Are you getting NPE on the front-end or the back-end? Sounds like jobConf
is not added to UDFContext, which is expected on the front-end. Please see
the comments in getJobConf() and addJobConf() in the source code:
https://svn.apache.org/repos/asf/pig/trunk/src/org/apache/pig/impl/util/UDFCon
Hi,
I am stuck. In my UDF (Java) extends EvalFunc the following code throws and
NPE in exec(), when executed in -x mapred mode:
Configuration jobConf = UDFContext.getUDFContext().getJobConf();
System.err.println(jobConf.toString());
I did not find any useful information as why my JobConf is alwa