We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 16ec595 commit 2c20335Copy full SHA for 2c20335
1 file changed
data-prepper-core/src/integrationTest/java/org/opensearch/dataprepper/plugins/InMemorySink.java
@@ -44,7 +44,7 @@ public void output(final Collection<Record<Event>> records) {
44
inMemorySinkAccessor.addEvents(testingKey, records);
45
boolean result = inMemorySinkAccessor.getResult();
46
if (doForward) {
47
- sinkContext.forwardRecords(records);
+ sinkContext.forwardRecords(records, null, null);
48
} else {
49
records.stream().forEach((record) -> {
50
EventHandle eventHandle = ((Event)record.getData()).getEventHandle();
0 commit comments