Removing synchronized on getting list.

Changing code to catch throwable.
rbpark · Mar 20, 2012 · e215921 · e215921
1 parent 514fb87
commit e215921
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 4 deletions.
diff --git a/azkaban/src/java/azkaban/flow/IndividualJobExecutableFlow.java b/azkaban/src/java/azkaban/flow/IndividualJobExecutableFlow.java
@@ -179,7 +179,7 @@ public void run()
                         try {
                             job.run();
                         }
-                        catch (Exception e) {
+                        catch (Throwable e) {
                             synchronized (sync) {
                                 jobState = Status.FAILED;
                                 returnProps = new Props();

diff --git a/azkaban/src/java/azkaban/scheduler/ScheduleManager.java b/azkaban/src/java/azkaban/scheduler/ScheduleManager.java
@@ -66,15 +66,17 @@ public void shutdown() {
     	this.runner.shutdown();
     }
 
+
+
     /**
      * Retrieves a copy of the list of schedules.
      * 
      * @return
      */
-    public synchronized List<ScheduledJob> getSchedule() {
+    private List<ScheduledJob> getSchedule() {
     	return runner.getSchedule();
     }
-
+    
     /**
      * Returns the scheduled job for the job name
      * 
@@ -178,7 +180,7 @@ public void shutdown() {
     	 * Return a list of scheduled job
     	 * @return
     	 */
-    	public synchronized List<ScheduledJob> getSchedule() {
+    	public List<ScheduledJob> getSchedule() {
     		return new ArrayList<ScheduledJob>(schedule);
     	}