You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@oozie.apache.org by "Purshotam Shah (JIRA)" <ji...@apache.org> on 2015/09/04 22:34:45 UTC

[jira] [Commented] (OOZIE-2358) Coord rerun cleanup should reuse hcat connections

    [ https://issues.apache.org/jira/browse/OOZIE-2358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14731374#comment-14731374 ] 

Purshotam Shah commented on OOZIE-2358:
---------------------------------------

{code}
if (checkAllActionsRunnable(coordActions)) {
//move contextmap here
                for (CoordinatorActionBean coordAction : coordActions) {

                    String actionXml = coordAction.getActionXml();
                    if (!noCleanup) {
                        Element eAction = XmlUtils.parseXml(actionXml);
                        cleanupOutputEvents(eAction);
                    }
					
{code}
We should reuse  contextMap for other action too, otherwise for each action partition delete we will be create new hcat client.


{code}
Configuration actionConf = null;
+            try {
+                actionConf = new XConfiguration(new StringReader(coordJob.getConf()));
+            }
+            catch (IOException e) {
+                throw new CommandException(ErrorCode.E0907,
+                        "failed to read coord job conf to clean up output data");
+            }
{code}
Use global conf  to avoid multiple xml parsing ( among actions). 

> Coord rerun cleanup should reuse hcat connections
> -------------------------------------------------
>
>                 Key: OOZIE-2358
>                 URL: https://issues.apache.org/jira/browse/OOZIE-2358
>             Project: Oozie
>          Issue Type: Bug
>            Reporter: Rohini Palaniswamy
>            Assignee: Rohini Palaniswamy
>             Fix For: trunk
>
>         Attachments: OOZIE-2358-1.patch
>
>
>   It is trying to reuse connections only for a specific data-out. It should reuse across data-outs. 



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)