[ https://issues.apache.org/jira/browse/PIG-1229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=12910629#action_12910629 ]
Sandesh Devaraju commented on PIG-1229: --------------------------------------- I narrowed down the problem to org.apache.hadoop.mapred.Task.java lines 411-418. {code:title=org.apache.hadoop.mapred.Task.java|linenumbers=true|firstline=411} if (useNewApi) { LOG.debug("using new api for output committer"); outputFormat = ReflectionUtils.newInstance(taskContext.getOutputFormatClass(), job); committer = outputFormat.getOutputCommitter(taskContext); } else { committer = conf.getOutputCommitter(); } {code} But DBStorage UDF assumes that the OutputFormat is in a closure. > allow pig to write output into a JDBC db > ---------------------------------------- > > Key: PIG-1229 > URL: https://issues.apache.org/jira/browse/PIG-1229 > Project: Pig > Issue Type: New Feature > Components: impl > Reporter: Ian Holsman > Assignee: Ankur > Priority: Minor > Fix For: 0.8.0 > > Attachments: jira-1229-final.patch, jira-1229-final.test-fix.patch, > jira-1229-v2.patch, jira-1229-v3.patch, pig-1229.2.patch, pig-1229.patch > > > UDF to store data into a DB -- This message is automatically generated by JIRA. - You can reply to this email to add a comment to the issue online.