-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/11922/#review22878
-----------------------------------------------------------


Did a first-pass of the review. For HA to work with secure Zookeeper, we'll 
need to add another server setting to indicate ZK to accept SASL based 
authentication, not IP based, and another one for the associated Kerberos 
principal. I see currently you are going with hostname based auth, but for 
dynamically resizing the "oozies" lot, this will require a ZK restart no?

Yet to review the unit tests..


/trunk/core/src/main/java/org/apache/oozie/service/ZKJobsConcurrencyService.java
<https://reviews.apache.org/r/11922/#comment46631>

    Is there a way to save 'myIndex' as a service level variable, so no need to 
query ZK for each invocation of 'jobIdBelongsToMe'? For this however, ZK will 
need to notify when it discovers when one of the Oozie servers goes down/comes 
up, and all the servers then recalculate their indexes just once again.



/trunk/core/src/main/java/org/apache/oozie/service/ZKXLogStreamingService.java
<https://reviews.apache.org/r/11922/#comment46628>

    what does this put do, when line 255 also puts the log lines against the 
currentTimestamp?



/trunk/core/src/test/java/org/apache/oozie/service/TestZKLocksService.java
<https://reviews.apache.org/r/11922/#comment46632>

    What does a timeout of '0' signify for the lock here?


- Mona Chitnis


On June 20, 2013, 6:20 p.m., Robert Kanter wrote:
> 
> -----------------------------------------------------------
> This is an automatically generated e-mail. To reply, visit:
> https://reviews.apache.org/r/11922/
> -----------------------------------------------------------
> 
> (Updated June 20, 2013, 6:20 p.m.)
> 
> 
> Review request for oozie.
> 
> 
> Bugs: OOZIE-615
>     https://issues.apache.org/jira/browse/OOZIE-615
> 
> 
> Repository: oozie
> 
> 
> Description
> -------
> 
> See this comment for details:
> https://issues.apache.org/jira/browse/OOZIE-615?focusedCommentId=13686181&page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel#comment-13686181
> 
> 
> Diffs
> -----
> 
>   /trunk/client/src/main/java/org/apache/oozie/cli/OozieCLI.java 1495113 
>   /trunk/client/src/main/java/org/apache/oozie/client/OozieClient.java 
> 1495113 
>   /trunk/client/src/main/java/org/apache/oozie/client/rest/RestConstants.java 
> 1495113 
>   /trunk/core/pom.xml 1495113 
>   /trunk/core/src/main/java/org/apache/oozie/BaseEngine.java 1495113 
>   /trunk/core/src/main/java/org/apache/oozie/BundleEngine.java 1495113 
>   /trunk/core/src/main/java/org/apache/oozie/CoordinatorEngine.java 1495113 
>   /trunk/core/src/main/java/org/apache/oozie/DagEngine.java 1495113 
>   /trunk/core/src/main/java/org/apache/oozie/ErrorCode.java 1495113 
>   /trunk/core/src/main/java/org/apache/oozie/command/Command.java 1495113 
>   /trunk/core/src/main/java/org/apache/oozie/command/XCommand.java 1495113 
>   
> /trunk/core/src/main/java/org/apache/oozie/service/ActionCheckerService.java 
> 1495113 
>   
> /trunk/core/src/main/java/org/apache/oozie/service/JobsConcurrencyService.java
>  PRE-CREATION 
>   /trunk/core/src/main/java/org/apache/oozie/service/MemoryLocksService.java 
> 1495113 
>   /trunk/core/src/main/java/org/apache/oozie/service/PauseTransitService.java 
> 1495113 
>   /trunk/core/src/main/java/org/apache/oozie/service/PurgeService.java 
> 1495113 
>   /trunk/core/src/main/java/org/apache/oozie/service/RecoveryService.java 
> 1495113 
>   
> /trunk/core/src/main/java/org/apache/oozie/service/StatusTransitService.java 
> 1495113 
>   /trunk/core/src/main/java/org/apache/oozie/service/XLogService.java 1495113 
>   
> /trunk/core/src/main/java/org/apache/oozie/service/XLogStreamingService.java 
> PRE-CREATION 
>   
> /trunk/core/src/main/java/org/apache/oozie/service/ZKJobsConcurrencyService.java
>  PRE-CREATION 
>   /trunk/core/src/main/java/org/apache/oozie/service/ZKLocksService.java 
> PRE-CREATION 
>   
> /trunk/core/src/main/java/org/apache/oozie/service/ZKXLogStreamingService.java
>  PRE-CREATION 
>   /trunk/core/src/main/java/org/apache/oozie/servlet/BaseAdminServlet.java 
> 1495113 
>   /trunk/core/src/main/java/org/apache/oozie/servlet/ServicesLoader.java 
> 1495113 
>   /trunk/core/src/main/java/org/apache/oozie/servlet/V0AdminServlet.java 
> 1495113 
>   /trunk/core/src/main/java/org/apache/oozie/servlet/V0JobServlet.java 
> 1495113 
>   /trunk/core/src/main/java/org/apache/oozie/servlet/V1AdminServlet.java 
> 1495113 
>   /trunk/core/src/main/java/org/apache/oozie/servlet/V1JobServlet.java 
> 1495113 
>   /trunk/core/src/main/java/org/apache/oozie/servlet/V2AdminServlet.java 
> 1495113 
>   /trunk/core/src/main/java/org/apache/oozie/util/ConfigUtils.java 1495113 
>   
> /trunk/core/src/main/java/org/apache/oozie/util/FixedJsonInstanceSerializer.java
>  PRE-CREATION 
>   /trunk/core/src/main/java/org/apache/oozie/util/LockToken.java PRE-CREATION 
>   /trunk/core/src/main/java/org/apache/oozie/util/MemoryLocks.java 1495113 
>   /trunk/core/src/main/java/org/apache/oozie/util/XLogStreamer.java 1495113 
>   /trunk/core/src/main/java/org/apache/oozie/util/ZKUtils.java PRE-CREATION 
>   /trunk/core/src/main/resources/oozie-default.xml 1495113 
>   
> /trunk/core/src/test/java/org/apache/oozie/TestCoordinatorEngineStreamLog.java
>  1495113 
>   /trunk/core/src/test/java/org/apache/oozie/command/TestXCommand.java 
> 1495113 
>   
> /trunk/core/src/test/java/org/apache/oozie/service/DummyLogStreamingServlet.java
>  PRE-CREATION 
>   
> /trunk/core/src/test/java/org/apache/oozie/service/TestJobsConcurrencyService.java
>  PRE-CREATION 
>   /trunk/core/src/test/java/org/apache/oozie/service/TestXLogService.java 
> 1495113 
>   
> /trunk/core/src/test/java/org/apache/oozie/service/TestXLogStreamingService.java
>  PRE-CREATION 
>   
> /trunk/core/src/test/java/org/apache/oozie/service/TestZKJobsConcurrencyService.java
>  PRE-CREATION 
>   /trunk/core/src/test/java/org/apache/oozie/service/TestZKLocksService.java 
> PRE-CREATION 
>   
> /trunk/core/src/test/java/org/apache/oozie/service/TestZKXLogStreamingService.java
>  PRE-CREATION 
>   
> /trunk/core/src/test/java/org/apache/oozie/servlet/MockCoordinatorEngineService.java
>  1495113 
>   
> /trunk/core/src/test/java/org/apache/oozie/servlet/MockDagEngineService.java 
> 1495113 
>   /trunk/core/src/test/java/org/apache/oozie/test/ZKXTestCase.java 
> PRE-CREATION 
>   /trunk/core/src/test/java/org/apache/oozie/util/TestMemoryLocks.java 
> 1495113 
>   /trunk/core/src/test/java/org/apache/oozie/util/TestXLogFilter.java 1495113 
>   /trunk/core/src/test/java/org/apache/oozie/util/TestZKUtils.java 
> PRE-CREATION 
>   /trunk/distro/src/main/tomcat/ssl-web.xml 1495113 
>   /trunk/docs/src/site/twiki/AG_Install.twiki 1495113 
>   /trunk/docs/src/site/twiki/DG_CommandLineTool.twiki 1495113 
>   /trunk/docs/src/site/twiki/WebServicesAPI.twiki 1495113 
>   /trunk/pom.xml 1495113 
> 
> Diff: https://reviews.apache.org/r/11922/diff/
> 
> 
> Testing
> -------
> 
> 
> Thanks,
> 
> Robert Kanter
> 
>

Reply via email to