Details
diff --git a/src/java/azkaban/execapp/FlowRunnerManager.java b/src/java/azkaban/execapp/FlowRunnerManager.java
index 17d3ae3..3fbdb15 100644
--- a/src/java/azkaban/execapp/FlowRunnerManager.java
+++ b/src/java/azkaban/execapp/FlowRunnerManager.java
@@ -601,7 +601,11 @@ public class FlowRunnerManager implements EventListener {
if (attachmentFile == null || !attachmentFile.exists()) {
return null;
}
- return (ArrayList<Object>) JSONUtils.parseJSONFromFile(attachmentFile);
+
+ @SuppressWarnings("unchecked")
+ List<Object> jobAttachments = (ArrayList<Object>) JSONUtils.parseJSONFromFile(attachmentFile);
+
+ return jobAttachments;
}
}
catch (IOException e) {
diff --git a/src/java/azkaban/executor/ExecutorManager.java b/src/java/azkaban/executor/ExecutorManager.java
index f2e979b..a48c524 100644
--- a/src/java/azkaban/executor/ExecutorManager.java
+++ b/src/java/azkaban/executor/ExecutorManager.java
@@ -323,7 +323,11 @@ public class ExecutorManager extends EventHandler implements ExecutorManagerAdap
ConnectorParams.ATTACHMENTS_ACTION,
jobIdParam,
attemptParam);
- return (List<Object>) result.get("attachments");
+
+ @SuppressWarnings("unchecked")
+ List<Object> jobStats = (List<Object>) result.get("attachments");
+
+ return jobStats;
}
@Override
diff --git a/src/java/azkaban/executor/JdbcExecutorLoader.java b/src/java/azkaban/executor/JdbcExecutorLoader.java
index 8c7a8ed..f7c5c40 100644
--- a/src/java/azkaban/executor/JdbcExecutorLoader.java
+++ b/src/java/azkaban/executor/JdbcExecutorLoader.java
@@ -718,7 +718,11 @@ public class JdbcExecutorLoader extends AbstractJdbcLoader
if (attachments == null) {
return null;
}
- return (List<Object>) JSONUtils.parseJSONFromString(attachments);
+
+ @SuppressWarnings("unchecked")
+ List<Object> attachmentList = (List<Object>) JSONUtils.parseJSONFromString(attachments);
+
+ return attachmentList;
}
catch (IOException e) {
throw new ExecutorManagerException(
@@ -1049,7 +1053,6 @@ public class JdbcExecutorLoader extends AbstractJdbcLoader
private static String FETCH_ATTACHMENTS_EXECUTABLE_NODE =
"SELECT attachments FROM execution_jobs WHERE exec_id=? AND job_id=?";
- @SuppressWarnings("unchecked")
@Override
public String handle(ResultSet rs) throws SQLException {
String attachmentsJson = null;
diff --git a/src/java/azkaban/project/JdbcProjectLoader.java b/src/java/azkaban/project/JdbcProjectLoader.java
index 9553d48..e61c2d7 100644
--- a/src/java/azkaban/project/JdbcProjectLoader.java
+++ b/src/java/azkaban/project/JdbcProjectLoader.java
@@ -271,7 +271,6 @@ public class JdbcProjectLoader extends AbstractJdbcLoader implements ProjectLoad
}
}
- @SuppressWarnings("resource")
private void uploadProjectFile(Connection connection, Project project, int version, String filetype, String filename, File localFile, String uploader) throws ProjectManagerException {
QueryRunner runner = new QueryRunner();
long updateTime = System.currentTimeMillis();
@@ -361,7 +360,6 @@ public class JdbcProjectLoader extends AbstractJdbcLoader implements ProjectLoad
return handler;
}
- @SuppressWarnings("resource")
private ProjectFileHandler getUploadedFile(Connection connection, int projectId, int version) throws ProjectManagerException {
QueryRunner runner = new QueryRunner();
ProjectVersionResultHandler pfHandler = new ProjectVersionResultHandler();
diff --git a/src/java/azkaban/webapp/AzkabanWebServer.java b/src/java/azkaban/webapp/AzkabanWebServer.java
index 21460b2..2133db8 100644
--- a/src/java/azkaban/webapp/AzkabanWebServer.java
+++ b/src/java/azkaban/webapp/AzkabanWebServer.java
@@ -26,7 +26,6 @@ import java.net.URL;
import java.net.URLClassLoader;
import java.util.ArrayList;
import java.util.Collections;
-import java.util.Comparator;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
diff --git a/src/java/azkaban/webapp/plugin/PluginRegistry.java b/src/java/azkaban/webapp/plugin/PluginRegistry.java
index d49db54..b9382b6 100644
--- a/src/java/azkaban/webapp/plugin/PluginRegistry.java
+++ b/src/java/azkaban/webapp/plugin/PluginRegistry.java
@@ -21,7 +21,6 @@ import java.util.ArrayList;
import java.util.HashMap;
import java.util.Map;
import java.util.TreeSet;
-import java.util.Set;
public class PluginRegistry {
