Revision 59425
Added by Claudio Atzori over 3 years ago
| MDStoreFeeder.java | ||
|---|---|---|
| 66 | 66 |
//means the process was cancelled, so we must not commit |
| 67 | 67 |
log.warn(String.format("The feeding process on mdstore %s has been cancelled. Records will not be committed. Transaction %s set as invalid.", mdId, transactionId));
|
| 68 | 68 |
dao.invalidTransaction(transactionId, mdId); |
| 69 |
failCallback.call(new MDStoreServiceException(String.format("Feeding cancelled for mdstore %s on transaction %s", mdId, transactionId)), buildParams(mdstore.getSize(), writeOps));
|
|
| 69 |
final Map<String, String> params = buildParams(dao.getMDStore(mdId).getSize(), writeOps); |
|
| 70 |
failCallback.call(new MDStoreServiceException(String.format("Feeding cancelled for mdstore %s on transaction %s", mdId, transactionId)), params);
|
|
| 70 | 71 |
} else {
|
| 71 | 72 |
dao.commit(mdstore.getId(), mdId); |
| 72 | 73 |
int size = dao.refreshSize(mdId); |
Also available in: Unified diff
in case of feeding canceled report the effective mdstore size rather than the size of the transaction