Skip to content

Commit

Permalink
Fix bug where process worker would shut down if a processor drops all…
Browse files Browse the repository at this point in the history
… events

Signed-off-by: Taylor Gray <tylgry@amazon.com>
  • Loading branch information
graytaylor0 committed Mar 11, 2024
1 parent 8535d68 commit a977b7b
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -129,7 +129,7 @@ private void doRun() {

List<Event> inputEvents = null;
if (acknowledgementsEnabled) {
inputEvents = ((ArrayList<Record<Event>>) records).stream().map(Record::getData).collect(Collectors.toList());
inputEvents = ((List<Record<Event>>) records).stream().map(Record::getData).collect(Collectors.toList());
}

try {
Expand Down

0 comments on commit a977b7b

Please sign in to comment.