diff --git a/src/main/java/com/amazonaws/services/kinesis/multilang/MultiLangRecordProcessor.java b/src/main/java/com/amazonaws/services/kinesis/multilang/MultiLangRecordProcessor.java index dd141fa3..2532771b 100644 --- a/src/main/java/com/amazonaws/services/kinesis/multilang/MultiLangRecordProcessor.java +++ b/src/main/java/com/amazonaws/services/kinesis/multilang/MultiLangRecordProcessor.java @@ -150,7 +150,7 @@ public class MultiLangRecordProcessor implements IRecordProcessor, IShutdownNoti } LOG.info("Requesting a checkpoint on shutdown notification."); if (!protocol.shutdownRequested(checkpointer)) { - LOG.error("Child process failed to shutdown"); + LOG.error("Child process failed to complete shutdown notification."); } }