azkaban-memoizeit
Details
diff --git a/src/java/azkaban/executor/ExecutableNode.java b/src/java/azkaban/executor/ExecutableNode.java
index a0a52d5..32eac5d 100644
--- a/src/java/azkaban/executor/ExecutableNode.java
+++ b/src/java/azkaban/executor/ExecutableNode.java
@@ -40,7 +40,6 @@ public class ExecutableNode {
private int level = 0;
private ExecutableFlow flow;
private Props outputProps;
- private Props resolvedProps;
private int attempt = 0;
private boolean paused = false;
src/java/azkaban/sla/SlaMailer.java 2(+2 -0)
diff --git a/src/java/azkaban/sla/SlaMailer.java b/src/java/azkaban/sla/SlaMailer.java
index db9e24d..8916e71 100644
--- a/src/java/azkaban/sla/SlaMailer.java
+++ b/src/java/azkaban/sla/SlaMailer.java
@@ -15,7 +15,9 @@ public class SlaMailer {
private static Logger logger = Logger.getLogger(SlaMailer.class);
private boolean testMode = false;
+ @SuppressWarnings("unused")
private String clientHostname;
+ @SuppressWarnings("unused")
private String clientPortNumber;
private String mailHost;
src/java/azkaban/sla/SLAManager.java 1(+1 -0)
diff --git a/src/java/azkaban/sla/SLAManager.java b/src/java/azkaban/sla/SLAManager.java
index 3c2a4fe..0313849 100644
--- a/src/java/azkaban/sla/SLAManager.java
+++ b/src/java/azkaban/sla/SLAManager.java
@@ -387,6 +387,7 @@ public class SLAManager {
mailer.sendSlaEmail(s, message);
}
+ @SuppressWarnings("unused")
private void sendSlaSuccessEmail(SLA s, ExecutableFlow exflow) {
String message = null;
ExecutableNode exnode;
diff --git a/src/java/azkaban/webapp/AzkabanWebServer.java b/src/java/azkaban/webapp/AzkabanWebServer.java
index f9f62a5..5ce6985 100644
--- a/src/java/azkaban/webapp/AzkabanWebServer.java
+++ b/src/java/azkaban/webapp/AzkabanWebServer.java
@@ -31,14 +31,9 @@ import java.util.Comparator;
import java.util.List;
import java.util.TimeZone;
-import javax.management.AttributeNotFoundException;
-import javax.management.InstanceNotFoundException;
-import javax.management.IntrospectionException;
-import javax.management.MBeanException;
import javax.management.MBeanInfo;
import javax.management.MBeanServer;
import javax.management.ObjectName;
-import javax.management.ReflectionException;
import org.apache.commons.lang.StringUtils;
import org.apache.log4j.Logger;
diff --git a/src/java/azkaban/webapp/servlet/IndexServlet.java b/src/java/azkaban/webapp/servlet/IndexServlet.java
index cf94e93..289e49d 100644
--- a/src/java/azkaban/webapp/servlet/IndexServlet.java
+++ b/src/java/azkaban/webapp/servlet/IndexServlet.java
@@ -26,12 +26,8 @@ import javax.servlet.http.HttpServletResponse;
import org.apache.log4j.Logger;
-//import org.apache.log4j.Logger;
-
-import azkaban.executor.ExecutorManager;
import azkaban.project.Project;
import azkaban.project.ProjectManager;
-import azkaban.scheduler.ScheduleManager;
import azkaban.user.Permission;
import azkaban.user.Role;
import azkaban.user.User;
diff --git a/src/java/azkaban/webapp/servlet/JMXHttpServlet.java b/src/java/azkaban/webapp/servlet/JMXHttpServlet.java
index 27bbb3f..78aec2f 100644
--- a/src/java/azkaban/webapp/servlet/JMXHttpServlet.java
+++ b/src/java/azkaban/webapp/servlet/JMXHttpServlet.java
@@ -21,7 +21,6 @@ import azkaban.user.Permission;
import azkaban.user.Role;
import azkaban.user.User;
import azkaban.user.UserManager;
-import azkaban.utils.Pair;
import azkaban.webapp.AzkabanWebServer;
import azkaban.webapp.session.Session;
diff --git a/unit/java/azkaban/scheduler/JdbcScheduleLoaderTest.java b/unit/java/azkaban/scheduler/JdbcScheduleLoaderTest.java
index 91a5e6e..f1717b2 100644
--- a/unit/java/azkaban/scheduler/JdbcScheduleLoaderTest.java
+++ b/unit/java/azkaban/scheduler/JdbcScheduleLoaderTest.java
@@ -4,9 +4,7 @@ import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
-import java.util.HashMap;
import java.util.List;
-import java.util.Map;
import javax.sql.DataSource;
@@ -15,13 +13,6 @@ import junit.framework.Assert;
import org.apache.commons.dbutils.DbUtils;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.ResultSetHandler;
-import org.joda.time.DateTimeZone;
-import org.joda.time.DurationFieldType;
-import org.joda.time.Hours;
-import org.joda.time.MutablePeriod;
-import org.joda.time.Period;
-import org.joda.time.PeriodType;
-import org.joda.time.ReadablePeriod;
import org.junit.AfterClass;
import org.junit.BeforeClass;
import org.junit.Test;
diff --git a/unit/java/azkaban/test/executor/JdbcExecutorLoaderTest.java b/unit/java/azkaban/test/executor/JdbcExecutorLoaderTest.java
index ad28bb3..903491a 100644
--- a/unit/java/azkaban/test/executor/JdbcExecutorLoaderTest.java
+++ b/unit/java/azkaban/test/executor/JdbcExecutorLoaderTest.java
@@ -376,6 +376,7 @@ public class JdbcExecutorLoaderTest {
Assert.assertEquals("Logs length is " + logsResult6.getLength(), logsResult6.getLength(), 185493);
}
+ @SuppressWarnings("static-access")
@Test
public void testRemoveExecutionLogsByTime() throws ExecutorManagerException, IOException, InterruptedException {
diff --git a/unit/java/azkaban/test/executor/SleepJavaJob.java b/unit/java/azkaban/test/executor/SleepJavaJob.java
index 0c7d23c..ac831fc 100644
--- a/unit/java/azkaban/test/executor/SleepJavaJob.java
+++ b/unit/java/azkaban/test/executor/SleepJavaJob.java
@@ -7,10 +7,8 @@ public class SleepJavaJob {
private String seconds;
private int attempts;
private int currentAttempt;
- private String id;
public SleepJavaJob(String id, Map<String, String> parameters) {
- this.id = id;
String failStr = parameters.get("fail");
if (failStr == null || failStr.equals("false")) {