ApplicationSnapshot

Source: src/AWS/KinesisAnalyticsV2/ApplicationSnapshot.ts

A snapshot (Flink savepoint) of a running Managed Service for Apache Flink application’s state.

Snapshots are immutable — every prop change replaces the snapshot. The source application must be RUNNING with snapshotsEnabled: true when the snapshot is created.

Creating Snapshots

import * as AWS from "alchemy/AWS";

const app = yield* AWS.KinesisAnalyticsV2.Application("Enrichment", {
  runtimeEnvironment: "FLINK-1_20",
  code: { bucketArn: bucket.bucketArn, fileKey: "jobs/enrichment-1.0.jar" },
  snapshotsEnabled: true,
  start: true,
});
const snapshot = yield* AWS.KinesisAnalyticsV2.ApplicationSnapshot(
  "Checkpoint",
  { applicationName: app.applicationName },
);