diff --git a/spring-batch-core/src/main/java/org/springframework/batch/core/repository/dao/MongoSequenceIncrementer.java b/spring-batch-core/src/main/java/org/springframework/batch/core/repository/dao/MongoSequenceIncrementer.java index db78dc343a..7adf60c4e0 100644 --- a/spring-batch-core/src/main/java/org/springframework/batch/core/repository/dao/MongoSequenceIncrementer.java +++ b/spring-batch-core/src/main/java/org/springframework/batch/core/repository/dao/MongoSequenceIncrementer.java @@ -47,7 +47,7 @@ public long nextLongValue() throws DataAccessException { return mongoTemplate.execute("BATCH_SEQUENCES", collection -> collection .findOneAndUpdate(new Document("_id", sequenceName), new Document("$inc", new Document("count", 1)), - new FindOneAndUpdateOptions().returnDocument(ReturnDocument.AFTER)) + new FindOneAndUpdateOptions().returnDocument(ReturnDocument.AFTER).upsert(true)) .getLong("count")); }