diff --git a/repository/repository-derby/src/main/java/org/apache/sqoop/repository/derby/DerbyRepositoryHandler.java b/repository/repository-derby/src/main/java/org/apache/sqoop/repository/derby/DerbyRepositoryHandler.java index 5e24ae3e..8af86b78 100644 --- a/repository/repository-derby/src/main/java/org/apache/sqoop/repository/derby/DerbyRepositoryHandler.java +++ b/repository/repository-derby/src/main/java/org/apache/sqoop/repository/derby/DerbyRepositoryHandler.java @@ -727,6 +727,11 @@ public boolean existsJob(long id, Connection conn) { public boolean inUseJob(long jobId, Connection conn) { MSubmission submission = findSubmissionLastForJob(jobId, conn); + // We have no submissions and thus job can't be in use + if(submission == null) { + return false; + } + // We can't remove running job if(submission.getStatus().isRunning()) { return true;