Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Threaded View
Pig >> mail # user >> error handling in Python UDFs with Pig 0.11

Copy link to this message
error handling in Python UDFs with Pig 0.11
Hi everyone,
When an exception is thrown in a Python UDF the execution just stops. What
I want is to continue processing even when exceptions are thrown from my
Python UDFs. The trivial solution is to catch the exceptions in the UDF
code, but what I want is a more elegant solution, something like the
@MonitoredUDF(errorCallback = MyErrorHandler.class) annotation that's
available with Java UDFs, where I can register a generic error handler. How
can I achieve something similar with Python UDFs?