diff --git a/core/src/main/java/org/apache/sqoop/repository/JdbcRepository.java b/core/src/main/java/org/apache/sqoop/repository/JdbcRepository.java index 6dc8baa8..32df1e5d 100644 --- a/core/src/main/java/org/apache/sqoop/repository/JdbcRepository.java +++ b/core/src/main/java/org/apache/sqoop/repository/JdbcRepository.java @@ -275,7 +275,7 @@ public Object doIt(Connection conn) { if(!job.hasPersistenceId()) { throw new SqoopException(RepositoryError.JDBCREPO_0019); } - if(!handler.existsConnection(job.getPersistenceId(), conn)) { + if(!handler.existsJob(job.getPersistenceId(), conn)) { throw new SqoopException(RepositoryError.JDBCREPO_0020, "Invalid id: " + job.getPersistenceId()); }