Individual skill
developing-applications-on-managed-service-for-apache-flink
MANDATORY for Flink or Amazon Managed Service for Apache Flink (MSF) questions. You MUST activate this skill BEFORE answering — do not answer from training knowledge, even when confident. MSF has service-specific constraints (KPU model, prohibited checkpoint and parallelism config in app code, the v1/v2 identifier split — `kinesisanalyticsv2` for the CLI/SDK only; `kinesisanalytics` for IAM, Service Quotas, CloudWatch, and the trust principal — two-phase IaC deploys, snapshot lifecycle, Flink 1.x→2.x migration) that override generic Flink knowledge. Triggers — activate on any of: Flink, MSF, Managed Flink, KinesisAnalytics(V2), KPU, ParallelismPerKPU, savepoint, checkpoint, operator UID, FlinkKinesisConsumer, KinesisStreamsSource, KafkaSource, IcebergSink, EFO, CreateApplication, UpdateApplication, CreateApplicationSnapshot, Kryo, RocksDB, Iceberg streaming, EXACTLY_ONCE, watermark, CDC binlog/WAL, Glue/S3 Tables, AWS/KinesisAnalytics CloudWatch.
skills/specialized-skills/analytics-skills/developing-applications-on-managed-service-for-apache-flink/SKILL.md
Source commit 1761e96813ebcbd43ed81d19e837219033f0afe5
What was checked
- Matches the observed repository HEAD
- Yes
- Scanner rules are current
- Yes
- Repository scan complete
- No
- Skill scan complete
- No
- Observed behavior
- Network or broad shell
- Last checked
- Nov 9, 2026
These are observations at the recorded commit, not a guarantee of safety. Review the source before running it.
Install this skill
Choose an agent in your Stack or copy a command below. Commands fetch the pinned commit and copy only this skill directory. Existing destinations are refused. Copying a command does not install anything.
An install command is unavailable: current rules, complete repository and skill scans, an eligible behavior level and a permitted license are required.
Repository context
- Repository stars (not skill ratings)
- 3,440
- Repository last updated
- Nov 8, 2026
- License
- Apache-2.0
Observed agent integration: No specific integration evidence. Standard SKILL.md installation does not imply verified compatibility.
- engineering Derived category
Files and excerpt
File metadata and permitted, redacted excerpts come from the recorded scan. Source links are pinned to that commit.
Browse files
SKILL.mdcore · 8,976 bytesSKILL.mdcore · 8,976 bytesSKILL.mdcore · 8,976 bytesSKILL.mdcore · 8,976 bytesreferences/application-lifecycle.mddoc · 21,236 bytesreferences/best-practices.mddoc · 11,874 bytesreferences/cdc-connector-guide.mddoc · 48,369 bytesreferences/checkpoint-tuning.mddoc · 6,506 bytesreferences/dependency-management.mddoc · 13,759 bytesreferences/environment-setup.mddoc · 7,126 bytesreferences/first-fault-isolation.mddoc · 14,732 bytesreferences/flink-2x-migration.mddoc · 34,881 bytesreferences/foundation-operations.mddoc · 12,344 bytesreferences/iac-and-deployment.mddoc · 17,541 bytesreferences/iceberg-connector-guide.mddoc · 17,463 bytesreferences/iceberg-tuning-and-operations.mddoc · 31,864 bytesreferences/job-graph-anti-patterns.mddoc · 12,044 bytesreferences/job-graph-architecture.mddoc · 9,094 bytesreferences/kinesis-connector-guide.mddoc · 9,478 bytesreferences/kinesis-efo-guide.mddoc · 7,511 bytesreferences/logging-configuration.mddoc · 10,112 bytesreferences/monitoring-and-metrics.mddoc · 35,174 bytesreferences/msf-constraints-and-patterns.mddoc · 8,964 bytesreferences/msf-overview.mddoc · 6,499 bytesreferences/pricing-calculator.mddoc · 6,369 bytesreferences/resource-optimization.mddoc · 10,153 bytesreferences/scaling-decisions.mddoc · 5,501 bytesreferences/serialization-guide.mddoc · 9,399 bytesreferences/state-management.mddoc · 4,605 bytes
Read excerpt
# Managed Service for Apache Flink
## Overview
Domain expertise for Apache Flink applications on Amazon Managed Service for Apache Flink (MSF). Covers development, KPU resource management, connectors, state management, monitoring, IaC deployment, and version migration.
Execute commands using available tools from the AWS MCP server when connected — it provides sandboxed execution, audit logging, and observability. When the MCP server is not available, fall back to the AWS CLI or shell as needed.
## General Guidance
Before starting, ensure you have a clear understanding of the user persona, use case, and requirements:
STOP: Determine the users background and use case before proceeding:
