Author: kamrul
Date: Thu Mar 29 19:37:53 2012
New Revision: 1307074

URL: http://svn.apache.org/viewvc?rev=1307074&view=rev
Log:
OOZIE-790 default concurrency value is inconsistent between doc and 
implementation.(Mohammad)

Modified:
    
incubator/oozie/trunk/core/src/main/java/org/apache/oozie/command/coord/CoordSubmitXCommand.java
    incubator/oozie/trunk/core/src/main/resources/oozie-default.xml
    
incubator/oozie/trunk/core/src/test/java/org/apache/oozie/command/coord/TestCoordSubmitXCommand.java
    incubator/oozie/trunk/release-log.txt

Modified: 
incubator/oozie/trunk/core/src/main/java/org/apache/oozie/command/coord/CoordSubmitXCommand.java
URL: 
http://svn.apache.org/viewvc/incubator/oozie/trunk/core/src/main/java/org/apache/oozie/command/coord/CoordSubmitXCommand.java?rev=1307074&r1=1307073&r2=1307074&view=diff
==============================================================================
--- 
incubator/oozie/trunk/core/src/main/java/org/apache/oozie/command/coord/CoordSubmitXCommand.java
 (original)
+++ 
incubator/oozie/trunk/core/src/main/java/org/apache/oozie/command/coord/CoordSubmitXCommand.java
 Thu Mar 29 19:37:53 2012
@@ -609,7 +609,7 @@ public class CoordSubmitXCommand extends
 
         val = resolveTagContents("concurrency", eAppXml.getChild("controls", 
eAppXml.getNamespace()), evalNofuncs);
         if (val == null || val.isEmpty()) {
-            val = Services.get().getConf().get(CONF_DEFAULT_CONCURRENCY, "-1");
+            val = Services.get().getConf().get(CONF_DEFAULT_CONCURRENCY, "1");
         }
         ival = ParamChecker.checkInteger(val, "concurrency");
         coordJob.setConcurrency(ival);

Modified: incubator/oozie/trunk/core/src/main/resources/oozie-default.xml
URL: 
http://svn.apache.org/viewvc/incubator/oozie/trunk/core/src/main/resources/oozie-default.xml?rev=1307074&r1=1307073&r2=1307074&view=diff
==============================================================================
--- incubator/oozie/trunk/core/src/main/resources/oozie-default.xml (original)
+++ incubator/oozie/trunk/core/src/main/resources/oozie-default.xml Thu Mar 29 
19:37:53 2012
@@ -370,9 +370,9 @@
        <property>
                <name>oozie.service.coord.default.concurrency
                </name>
-               <value>-1</value>
-               <description>Default concurrency for a coordinator job to 
determine how many maximum action should 
-               be executed at the same time.</description>
+               <value>1</value>
+               <description>Default concurrency for a coordinator job to 
determine how many maximum action should
+               be executed at the same time. -1 means infinite 
concurrency.</description>
        </property>
 
     <property>

Modified: 
incubator/oozie/trunk/core/src/test/java/org/apache/oozie/command/coord/TestCoordSubmitXCommand.java
URL: 
http://svn.apache.org/viewvc/incubator/oozie/trunk/core/src/test/java/org/apache/oozie/command/coord/TestCoordSubmitXCommand.java?rev=1307074&r1=1307073&r2=1307074&view=diff
==============================================================================
--- 
incubator/oozie/trunk/core/src/test/java/org/apache/oozie/command/coord/TestCoordSubmitXCommand.java
 (original)
+++ 
incubator/oozie/trunk/core/src/test/java/org/apache/oozie/command/coord/TestCoordSubmitXCommand.java
 Thu Mar 29 19:37:53 2012
@@ -65,7 +65,7 @@ public class TestCoordSubmitXCommand ext
         Configuration conf = new XConfiguration();
         String appPath = getTestCaseDir() + File.separator + "coordinator.xml";
         String appXml = "<coordinator-app name=\"NAME\" 
frequency=\"${coord:days(1)}\" start=\"2009-02-01T01:00Z\" 
end=\"2009-02-03T23:59Z\" timezone=\"UTC\" "
-                + "xmlns=\"uri:oozie:coordinator:0.2\"> <controls> 
<concurrency>2</concurrency> "
+                + "xmlns=\"uri:oozie:coordinator:0.2\"> <controls> "
                 + "<execution>LIFO</execution> </controls> <datasets> "
                 + "<dataset name=\"a\" frequency=\"${coord:days(7)}\" 
initial-instance=\"2009-02-01T01:00Z\" "
                 + "timezone=\"UTC\"> 
<uri-template>file:///tmp/coord/workflows/${YEAR}/${DAY}</uri-template> 
</dataset> "
@@ -90,6 +90,8 @@ public class TestCoordSubmitXCommand ext
         if (job != null) {
             assertEquals(job.getTimeout(), Services.get().getConf().getInt(
                     "oozie.service.coord.normal.default.timeout", -2));
+            assertEquals(job.getConcurrency(), Services.get().getConf().getInt(
+                    "oozie.service.coord.default.concurrency", 1));
         }
     }
 

Modified: incubator/oozie/trunk/release-log.txt
URL: 
http://svn.apache.org/viewvc/incubator/oozie/trunk/release-log.txt?rev=1307074&r1=1307073&r2=1307074&view=diff
==============================================================================
--- incubator/oozie/trunk/release-log.txt (original)
+++ incubator/oozie/trunk/release-log.txt Thu Mar 29 19:37:53 2012
@@ -1,5 +1,6 @@
 -- Oozie 3.2.0 release
 
+OOZIE-790 default concurrency value is inconsistent between doc and 
implementation.(Mohammad)
 OOZIE-793 remove HiveMain check for HADOOP_HOME (tucu)
 OOZIE-792 add default action configs per cluster (tucu)
 OOZIE-624 client side improvement of authentication for user defined options


Reply via email to