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

Purshotam Shah commented on OOZIE-1699:
---------------------------------------

{quote}
But from CallableQueueService perspective, I don't see how the same command can 
be queued in parallel as CallabeQueueService.queue() is synchronised and 
filterDuplicates will remove the 2nd queue().
{quote}

The problem we notice was not with queuing same command in parallel, but system 
congestion because of acquiring two lock for a queue command.

{quote}
Anyways, the lock in offer() can be removed.
{quote}

Other option could be is to keep lock in offer(), so that peek() and offer() 
uses same lock. We can remove synchronized keyword for 
CallableQueueService.queue() and queueSerial.

> Some of the commands submitted to Oozie internal queue are never executed
> -------------------------------------------------------------------------
>
>                 Key: OOZIE-1699
>                 URL: https://issues.apache.org/jira/browse/OOZIE-1699
>             Project: Oozie
>          Issue Type: Bug
>            Reporter: Srikanth Sundarrajan
>            Assignee: Srikanth Sundarrajan
>            Priority: Critical
>             Fix For: trunk
>
>         Attachments: OOZIE-1699-v1-no-prefix.patch, OOZIE-1699.patch
>
>
> At scale, we are seeing issues with some command submitted to the command 
> queue in CallableQueueService aren't getting executed at all.



--
This message was sent by Atlassian JIRA
(v6.2#6252)

Reply via email to