From 7bd2d638643b2c21d0bce21d72de013cd65e74a3 Mon Sep 17 00:00:00 2001 From: Krishna Kondaka Date: Fri, 18 Oct 2024 17:38:37 +0000 Subject: [PATCH] Fixed failing tests Signed-off-by: Krishna Kondaka --- .../core/pipeline/router/RouterCopyRecordStrategyTests.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/data-prepper-core/src/test/java/org/opensearch/dataprepper/core/pipeline/router/RouterCopyRecordStrategyTests.java b/data-prepper-core/src/test/java/org/opensearch/dataprepper/core/pipeline/router/RouterCopyRecordStrategyTests.java index 6e1f3f6cc7..aedf1f60a5 100644 --- a/data-prepper-core/src/test/java/org/opensearch/dataprepper/core/pipeline/router/RouterCopyRecordStrategyTests.java +++ b/data-prepper-core/src/test/java/org/opensearch/dataprepper/core/pipeline/router/RouterCopyRecordStrategyTests.java @@ -280,10 +280,10 @@ void test_multiple_records_with_acknowledgements_and_multi_components() { attachEventHandlesToRecordsIn(eventHandles); try { doAnswer((i) -> { - JacksonEvent e1 = (JacksonEvent) i.getArgument(0); - ((DefaultEventHandle)e1.getEventHandle()).addAcknowledgementSet(acknowledgementSet1); + EventHandle handle = (EventHandle) i.getArgument(0); + ((DefaultEventHandle)handle).addAcknowledgementSet(acknowledgementSet1); return null; - }).when(acknowledgementSet1).add(any(JacksonEvent.class)); + }).when(acknowledgementSet1).add(any(EventHandle.class)); } catch (Exception e){} eventBuilder = mock(EventBuilder.class);