# confluent-cloud-flink-sql

> Claude/Codex skill by [@confluentinc](https://omgskills.com/library/confluentinc/index.md) · 59 stars · Updated 2026-10-06

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.

Tags: ai, cdc, confluent, confluent-cloud, flink, flinksql, kafka, kafka-streams, skills

## Install

```sh
git clone https://github.com/confluentinc/agent-skills /tmp/agent-skills && ln -s /tmp/agent-skills/skills/confluent-cloud-flink-sql ~/.claude/skills/confluent-cloud-flink-sql
```

## From README

Confluent Cloud Flink SQL Enforce the CC-Flink-vs-OSS-Flink dialect boundary and the CLI-driven verification loop for any Confluent Cloud Flink SQL work. Apache Flink OSS training data is a trap — CC rejects or silently mishandles a long list of otherwise-valid Flink SQL constructs. Scope note: this skill's reference material is built around the OSS-vs-CC dialect boundary — traps in constructs that exist in both dialects but behave differently. It does not yet catalog CC-only DDL that has no OSS counterpart (e.g. CREATE MATERIALIZED TABLE, CREATE MODEL/AICOMPLETE, CREATE AGENT, USE CATALOG). For those, verify directly against the CC Flink SQL reference rather than expecting a trap entry here. Non-negotiables CC Flink ≠ Apache Flink. Verify every API, SQL construct, and runtime behavior against: Confluent Cloud Flink docs CC Flink SQL reference Confluent Terraform provider Live confluent flink shell against the user's compute pool No mocks in verification.

## Links

- HTML page: https://omgskills.com/library/confluentinc/agent-skills/skills/confluent-cloud-flink-sql/
- GitHub: https://github.com/confluentinc/agent-skills
- Author: [@confluentinc](https://omgskills.com/library/confluentinc/index.md)

## More from this repo

- [confluent-cloud-cdc-tableflow](https://omgskills.com/library/confluentinc/agent-skills/skills/confluent-cloud-cdc-tableflow/index.md) — Set up end-to-end Change Data Capture (CDC) pipelines on Confluent Cloud using Debezium source connectors, Flink for...
   - [@confluentinc](https://omgskills.com/library/confluentinc/index.md) · 59 stars
- [confluent-tuning-advisor](https://omgskills.com/library/confluentinc/agent-skills/skills/confluent-tuning-advisor/index.md) — Advisory-only Kafka tuning for Confluent Cloud or Confluent Platform by priority: latency, throughput, availability, or...
   - [@confluentinc](https://omgskills.com/library/confluentinc/index.md) · 59 stars
- [developing-kafka-java-client](https://omgskills.com/library/confluentinc/agent-skills/skills/developing-kafka-java-client/index.md) — Used when the user wants to integrate a Kafka client into an existing application or scaffold a Java Kafka client...
   - [@confluentinc](https://omgskills.com/library/confluentinc/index.md) · 59 stars