diff --git a/modules/dcache-bulk/src/main/java/org/dcache/services/bulk/store/jdbc/rtarget/JdbcBulkTargetStore.java b/modules/dcache-bulk/src/main/java/org/dcache/services/bulk/store/jdbc/rtarget/JdbcBulkTargetStore.java index 6cf74ef0be5..1123e9b640b 100644 --- a/modules/dcache-bulk/src/main/java/org/dcache/services/bulk/store/jdbc/rtarget/JdbcBulkTargetStore.java +++ b/modules/dcache-bulk/src/main/java/org/dcache/services/bulk/store/jdbc/rtarget/JdbcBulkTargetStore.java @@ -93,13 +93,15 @@ public void abort(BulkRequestTarget target) target.getErrorType(), target.getErrorMessage()); /* - * If aborted, the target has not yet been stored ... + * If aborted, the placeholder target has not yet been stored ... */ targetDao.insert( targetDao.set().pid(target.getPid()).rid(target.getRid()) .pnfsid(target.getPnfsId()).path(target.getPath()).type(target.getType()) .errorType(target.getErrorType()).errorMessage(target.getErrorMessage()) .aborted()); + + cancelAll(target.getRid()); } @Override