feat(kinesisdataanalytics): Fix Checkpoint Failure Rate calculation and add Full Restart Rate monitoring #668

costmatt-amzn · 2025-09-16T19:23:13Z

Fixed Checkpoint Failure Rate

Replaced manual rate calculation with CloudWatch's native RATE() function
Changed from (3600 * checkpoints) / PERIOD(checkpoints) to RATE(numberOfFailedCheckpoints)

Added Full Restart Rate Monitoring

New metricFullRestartRate() method using RATE(fullRestarts)
New addFullRestartRateAlarm() with custom implementation to avoid naming conflicts
Enhanced Full Restarts widget to show both count (left axis) and rate (right axis)

Technical

Resolved alarm naming conflicts between full restart and checkpoint failure rate alarms
Added test coverage for new functionality
All 5 alarms now supported (was 4)

Provides more accurate rate monitoring and better insights into Kinesis Data Analytics application performance.

…nd add Full Restart Rate monitoring

arkon · 2025-09-19T03:29:16Z

test/monitoring/aws-kinesisanalytics/KinesisDataAnalyticsMonitoring.test.ts

  expect(Template.fromStack(stack)).toMatchSnapshot();
 });

+test("snapshot test: full restart rate alarm", () => {


Doesn't the addition in the following test already cover the same thing as this new test?

feat(kinesisdataanalytics): Fix Checkpoint Failure Rate calculation a…

cc01956

…nd add Full Restart Rate monitoring

arkon reviewed Sep 19, 2025

View reviewed changes

Provide feedback