azkaban-uncached

some bad bug in the previous version that doesn't take in flow

8/13/2013 5:32:15 PM

Details

diff --git a/src/java/azkaban/executor/ExecutionOptions.java b/src/java/azkaban/executor/ExecutionOptions.java
index a91a6d0..687dd71 100644
--- a/src/java/azkaban/executor/ExecutionOptions.java
+++ b/src/java/azkaban/executor/ExecutionOptions.java
@@ -40,7 +40,7 @@ public class ExecutionOptions {
 	private Set<String> initiallyDisabledJobs = new HashSet<String>();
 	
 	public void setFlowParameters(Map<String,String> flowParam) {
-		flowParameters.get(flowParam);
+		flowParameters.putAll(flowParam);
 	}
 	
 	public Map<String,String> getFlowParameters() {
diff --git a/src/java/azkaban/executor/ExecutorManager.java b/src/java/azkaban/executor/ExecutorManager.java
index a7eef2d..1b24a07 100644
--- a/src/java/azkaban/executor/ExecutorManager.java
+++ b/src/java/azkaban/executor/ExecutorManager.java
@@ -76,7 +76,7 @@ public class ExecutorManager {
 	
 	private long lastThreadCheckTime = -1;
 	
-	private final boolean isPrimary;
+	private final boolean isActive;
 	
 	private Map<String, Alerter> alerters;
 	
@@ -86,24 +86,26 @@ public class ExecutorManager {
 		void alertOnFirstError(ExecutableFlow exflow) throws Exception;
 	}
 	
-	public ExecutorManager(Props props, ExecutorLoader loader, boolean isPrimary) throws ExecutorManagerException {
+	public ExecutorManager(Props props, ExecutorLoader loader, boolean isActive) throws ExecutorManagerException {
 		this.executorLoader = loader;
 		this.loadRunningFlows();
 		
 		executorHost = props.getString("executor.host", "localhost");
 		executorPort = props.getInt("executor.port");
 		
-		alerters = loadAlerters(props);
 		
-		this.isPrimary = isPrimary;		
 		
-		if(isPrimary) {
+		this.isActive = isActive;		
+		
+		if(isActive) {
 			executingManager = new ExecutingManagerUpdaterThread();
 			executingManager.start();
 
 			long executionLogsRetentionMs = props.getLong("execution.logs.retention.ms", DEFAULT_EXECUTION_LOGS_RETENTION_MS);
 			cleanerThread = new CleanerThread(executionLogsRetentionMs);
 			cleanerThread.start();
+			
+			alerters = loadAlerters(props);
 		}
 	}
 	
@@ -861,7 +863,7 @@ public class ExecutorManager {
 	
 	private void finalizeFlows(ExecutableFlow flow) {
 		int execId = flow.getExecutionId();
-		
+
 		// First we check if the execution in the datastore is complete
 		try {
 			ExecutableFlow dsFlow;