You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@oozie.apache.org by rk...@apache.org on 2013/02/04 19:03:36 UTC
svn commit: r1442267 - in /oozie/branches/branch-3.3:
core/src/main/java/org/apache/oozie/command/XCommand.java
core/src/test/java/org/apache/oozie/command/TestXCommand.java release-log.txt
Author: rkanter
Date: Mon Feb 4 18:03:35 2013
New Revision: 1442267
URL: http://svn.apache.org/viewvc?rev=1442267&view=rev
Log:
OOZIE-1051 Repeating Errors for workflows that were allreday Killed (rkanter)
Modified:
oozie/branches/branch-3.3/core/src/main/java/org/apache/oozie/command/XCommand.java
oozie/branches/branch-3.3/core/src/test/java/org/apache/oozie/command/TestXCommand.java
oozie/branches/branch-3.3/release-log.txt
Modified: oozie/branches/branch-3.3/core/src/main/java/org/apache/oozie/command/XCommand.java
URL: http://svn.apache.org/viewvc/oozie/branches/branch-3.3/core/src/main/java/org/apache/oozie/command/XCommand.java?rev=1442267&r1=1442266&r2=1442267&view=diff
==============================================================================
--- oozie/branches/branch-3.3/core/src/main/java/org/apache/oozie/command/XCommand.java (original)
+++ oozie/branches/branch-3.3/core/src/main/java/org/apache/oozie/command/XCommand.java Mon Feb 4 18:03:35 2013
@@ -291,7 +291,7 @@ public abstract class XCommand<T> implem
return ret;
}
finally {
- if (isLockRequired()) {
+ if (isLockRequired() && !this.inInterruptMode()) {
releaseLock();
}
}
Modified: oozie/branches/branch-3.3/core/src/test/java/org/apache/oozie/command/TestXCommand.java
URL: http://svn.apache.org/viewvc/oozie/branches/branch-3.3/core/src/test/java/org/apache/oozie/command/TestXCommand.java?rev=1442267&r1=1442266&r2=1442267&view=diff
==============================================================================
--- oozie/branches/branch-3.3/core/src/test/java/org/apache/oozie/command/TestXCommand.java (original)
+++ oozie/branches/branch-3.3/core/src/test/java/org/apache/oozie/command/TestXCommand.java Mon Feb 4 18:03:35 2013
@@ -135,6 +135,14 @@ public class TestXCommand extends XTestC
execute = true;
return null;
}
+
+ private void resetCalledMethods() {
+ eagerLoadState = false;
+ eagerVerifyPrecondition = false;
+ loadState = false;
+ verifyPrecondition = false;
+ execute = false;
+ }
}
public void testXCommandGetters() throws Exception {
@@ -203,6 +211,18 @@ public class TestXCommand extends XTestC
}
}
+ public void testXCommandPossibleReleaseLockWithoutAcquireEdgeCase()
+ throws Exception {
+ AXCommand command = new AXCommand(true);
+ command.setInterruptMode(false);
+ command.call();
+ assertTrue(command.execute);
+ command.resetCalledMethods();
+ command.setInterruptMode(true);
+ command.call();
+ assertTrue(command.execute);
+ }
+
private static class LockGetter extends Thread {
@Override
Modified: oozie/branches/branch-3.3/release-log.txt
URL: http://svn.apache.org/viewvc/oozie/branches/branch-3.3/release-log.txt?rev=1442267&r1=1442266&r2=1442267&view=diff
==============================================================================
--- oozie/branches/branch-3.3/release-log.txt (original)
+++ oozie/branches/branch-3.3/release-log.txt Mon Feb 4 18:03:35 2013
@@ -1,5 +1,6 @@
-- Oozie 3.3.2 (unreleased)
+OOZIE-1051 Repeating Errors for workflows that were allreday Killed (rkanter)
OOZIE-1140 TestLogStreamer.testStreamLog fails when its started within the first 4 seconds after the hour (rkanter)
OOZIE-1153 comma separated list in <archive> and <file> for JavaActionExecutor. (jaoki via tucu)
OOZIE-1161 Remove unnecessary db updates for some of the blobs like missing_dependencies' of Coordinator Action (virag)