kilo-org/flink
skills/flink/SKILL.md
Apache Flink stream processing expertise for stateful computations over bounded and unbounded streams. Use when the user mentions Flink, Flink SQL, Table API, DataStream API, CDC, Kafka-to-Flink pipelines, checkpoints, savepoints, watermarks, windows, Flink Kubernetes Operator, or Flink integrations with Iceberg, Paimon, or Fluss.
$ install --global
skillsauthnpx skillsauth add kilo-org/kilo-marketplace flinkInstall this skill globally with one command. Works with Claude Code, Cursor, and Windsurf.
Security Scan Results
3 of 9 scanners reported clean
Some scanners were skipped, did not run, or reported a non-clean status. Review each row below.
3
Scanners Passed
9
Scanners in report
Clean
TrivyContainer and dependency vulnerability scanner
95%
Clean
SemgrepStatic code analysis for vulnerabilities
95%
Clean
mcp-scan (Snyk)Model Context Protocol security validation
95%
Skipped
Snyk (dep)Open source security scanning
50%
Skipped
Socket.devSupply chain security analysis
50%
Skipped
VirusTotalMulti-engine malware detection
50%
Skipped
CrowdStrikeAdvanced threat intelligence
50%
Skipped
OSV-ScannerOpen Source Vulnerability database check
50%
Skipped
OWASP Dep-Check
50%
Last scanned: Jun 30, 2026, 8:01 AM133.0s1 file scanned
SKILL.md
- name:
- flink
- description:
- >-
- category:
- data
- repository:
- https://github.com/gordonmurray/data-engineering-skills
- path:
- flink
- license_path:
- LICENSE
- commit:
- 226973561ae6881d21b6567171195e8211863d75
Apache Flink Data Streaming Expert
Use this skill for production Flink architecture, operations, SQL/DataStream implementation, upgrade planning, and lakehouse streaming integrations.
Current Facts
- Current Flink line: 2.2.x. Downloads include Apache Flink 2.2.1, while the site still labels 2.2.0 as the latest stable line.
- Maintained 2.x patch lines: 2.2.1, 2.1.2, 2.0.2.
- 1.x maintenance line: 1.20.4. Use this as the 1.x migration baseline unless the project is pinned elsewhere.
- Kubernetes Operator: 1.15.0, compatible with Flink 2.2.x, 2.1.x, 2.0.x, 1.20.x, and 1.19.x.
- Flink CDC: 3.6.0, with artifacts for Flink 1.20.x and 2.2.x.
- Java: Flink 2.x requires Java 11+; Java 17 is the practical default for new deployments.
Critical 2.x Notes
- DataSet API removed; use DataStream, Table API, or SQL.
- Scala DataStream/DataSet APIs removed from the core distribution.
- SourceFunction/SinkFunction and Sink V1 patterns are obsolete; prefer Source/Sink V2 connectors.
flink-conf.yamlwas replaced by standard YAMLconfig.yamlin Flink 2.x.- Per-job deployment mode was removed; use Application mode or Kubernetes Operator patterns.
- Validate savepoint compatibility carefully before 1.x to 2.x migrations.
How To Use
- Classify the request: SQL/Table API, DataStream, deployment, operations, upgrade, CDC, or lakehouse sink/source.
- For new greenfield work, prefer Flink 2.2.x plus current connector artifacts.
- For migration work, identify the exact source version, connector versions, state backend, and savepoint strategy before recommending commands.
Production Defaults
- Enable checkpointing for streaming jobs and set explicit checkpoint storage.
- Use savepoints for planned upgrades and topology changes.
- Use watermarks and allowed lateness deliberately; make event-time assumptions visible.
- Monitor checkpoint duration, alignment time, backpressure, restart count, and state size.
- Prefer the Kubernetes Operator for long-running production jobs on Kubernetes.
- Use Iceberg/Paimon/Fluss connectors only at versions compatible with the selected Flink line.
Update Checklist
- Recheck Flink downloads for core, CDC, connector, and Kubernetes Operator versions.
- Update Helm/doc URLs when operator versions change.
Related Skills
kilo-org/oracle-database
development
VerifiedTrustedCommunity
Oracle Database guidance for SQL, PL/SQL, SQLcl, ORDS, administration, app development, performance, security, migrations, and agent-safe database workflows. Use when the user asks to write, edit, rewrite, review, format, debug, tune, or explain SQL; create or refactor PL/SQL; use SQLcl, Liquibase, ORDS, JDBC, node-oracledb, Python, Java, .NET, or database frameworks; troubleshoot queries, sessions, locks, waits, indexes, optimizer plans, AWR, ASH, migrations, schemas, users, roles, privileges, backup, recovery, Data Guard, RAC, multitenant, containers, monitoring, auditing, encryption, VPD, or safe agent database operations.
161SKILL.mdUpdated Jul 21, 2026
kilo-org/oleander-iceberg-catalog
documentation
VerifiedTrustedCommunity
Patterns for reading and writing oleander Iceberg catalog tables in Spark jobs, including naming conventions, write modes, and catalog hierarchy.
161SKILL.mdUpdated Jul 21, 2026
kilo-org/okta-identity-integration-patterns
data-ai
VerifiedTrustedCommunity
Integrate Okta for enterprise identity workflows including OIDC login, group claims, and policy-based access controls. Use when implementing workforce or B2B identity scenarios.
161SKILL.mdUpdated Jul 21, 2026
kilo-org/nifi-flow-layout
documentation
VerifiedTrustedCommunity
Use when arranging Apache NiFi processors, process groups, ports, comments, numbering, crossing connections, dense fan-in/fan-out, or reusable readable canvas layouts.
161SKILL.mdUpdated Jul 21, 2026