Confluent Cloud Flink Sql
by confluentinc914d95eff7ffNo license58 starsListed Oct 8, 2026Updated Oct 8, 2026Repository updated 2 days ago
Write and debug Flink SQL that runs on Confluent Cloud, enforcing the CC-vs-Apache-Flink (OSS) dialect boundary. Use when the working directory is a Confluent Cloud Flink workspace, when a Flink SQL statement needs checking before it runs on a CC compute pool, or when the user mentions CC Flink, Confluent Cloud Flink SQL, the `confluent flink` CLI, a CFU compute pool, `CREATE CONNECTION`, or asks to check or debug Flink SQL whose runtime is Confluent Cloud. Also trigger when a Flink SQL question is posed and nothing establishes an Apache Flink OSS runtime. Do NOT trigger for: building or deploying Flink UDFs in Java (UDF/UDTF/PTF — use flink-udf); a full CDC pipeline from a database through Flink into Tableflow/Iceberg/Delta Lake (use confluent-cloud-cdc-tableflow); Kafka Streams topology work (use kafka-streams-programming); or Flink SQL confirmed to run on Apache Flink OSS, not Confluent Cloud.
Only the file list is public. File contents are available once the skill is installed in a workspace.
| Path | Size | Type |
|---|---|---|
| evals/evals.json | 9.2 KB | application/json |
| references/cli-reference.md | 6.7 KB | text/markdown |
| references/dialect-traps.md | 7.9 KB | text/markdown |
| references/formats-and-serialization.md | 3 KB | text/markdown |
| references/reserved-words.md | 2.1 KB | text/markdown |
| references/sql-patterns-cc.md | 9.6 KB | text/markdown |
| references/troubleshooting-cc.md | 5 KB | text/markdown |
| SKILL.md | 9.3 KB | text/markdown |
Source and attribution
Source:confluentinc/agent-skillsinskills/confluent-cloud-flink-sqlat commit914d95e
License: No license
Content belongs to its original authors. SourceWeft indexes it from a public repository.
More from confluentinc/agent-skills
Flink Udf
confluentinc
Guides building and deploying Java Apache Flink user-defined functions (UDFs, UDTFs, PTFs) to Confluent Cloud or local Docker.
Trigger Overlap
confluentinc
Generates a create-topics.sh script for provisioning Confluent Cloud Kafka topics with retention and compaction settings.
Stale Expectations
confluentinc
Scans a project for Avro schemas, checks them against Schema Registry compatibility, and writes a Markdown report.
Leaky Data
confluentinc
Generates a Flink SQL statement that joins an orders stream with a customers table to emit an enriched topic on Confluent Cloud.
Inlined Refs
confluentinc
Guides selection of a Kafka consumer group lag exporter and sets up a Grafana dashboard and lag alerts.
More in Software Development
Playground
anthropics
Builds self-contained interactive HTML playgrounds with controls, live preview, and copyable prompt output.
M5 Onboard
anthropics
Provisions M5Stack ESP32 boards by detecting them on USB, flashing UIFlow 2.0 firmware, and installing a MicroPython app bundle.
Cardputer Buddy
anthropics
Guides iterating on a Cardputer-Adv MicroPython app bundle: adding apps, pushing files over USB-serial, tailing logs, and running REPL commands.
Dpop Adoption
Guides implementation of OAuth 2.0 DPoP (RFC 9449) sender-constrained refresh tokens for Google's OAuth platform.
Gemini Live Api
Generates a Gemini Live API WebSocket client class, tests, docs, and a demo UI for bidirectional streaming.
Gemini Api
Guides use of the Gemini API on Google's Agent Platform with the Gen AI SDK across languages and capabilities.