diff options
Diffstat (limited to 'infra/translate-impl/src/main')
| -rw-r--r-- | infra/translate-impl/src/main/java/io/fd/honeycomb/translate/impl/write/registry/FlatWriterRegistry.java | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/infra/translate-impl/src/main/java/io/fd/honeycomb/translate/impl/write/registry/FlatWriterRegistry.java b/infra/translate-impl/src/main/java/io/fd/honeycomb/translate/impl/write/registry/FlatWriterRegistry.java index 990431a15..418f4b4b7 100644 --- a/infra/translate-impl/src/main/java/io/fd/honeycomb/translate/impl/write/registry/FlatWriterRegistry.java +++ b/infra/translate-impl/src/main/java/io/fd/honeycomb/translate/impl/write/registry/FlatWriterRegistry.java @@ -224,7 +224,7 @@ final class FlatWriterRegistry implements WriterRegistry { .map(DataObjectUpdate::getId) .filter(id -> !processedNodes.contains(id)) .collect(Collectors.toSet()); - throw new BulkUpdateException(unprocessedChanges, reverter, e); + throw new BulkUpdateException(writerType, singleUpdate, unprocessedChanges, reverter, e); } } } @@ -286,7 +286,7 @@ final class FlatWriterRegistry implements WriterRegistry { LOG.info("Revert successful"); } catch (BulkUpdateException e) { LOG.error("Revert failed", e); - throw new RevertFailedException(e.getFailedIds(), e); + throw new RevertFailedException(e); } } |