Confluent Confluent
Documentation Deploy and Manage Statements in Confluent Manager for Apache Flink
Confluent Developer Marketplace Get started
Home Confluent Cloud Confluent Platform Connectors Clients
  1. Home
  2. Flink Jobs

Deploy and Manage Statements in Confluent Manager for Apache Flink

  • Overview
  • Flink Versions
  • Create Statements
  • Manage Statements
  • Carry Over Offsets
  • Batch Statements
  • Table Operations
  • User-Defined Functions
  • Process Table Functions
  • Custom Connectors
  • Views
  • Examples
  • Use Interactive Shell
  • Use the SQL Assistant
  • Model Inference
  • Forecast
  • Anomaly Detection
  • Set Up AI Functions
  • Features and Support
Ask the community Confluent Support Portal Last updated: Nov 04, 2026
Terms & Conditions | Privacy Policy | Do Not Sell My Information | Modern Slavery Policy | Cookie Settings | Feedback

Copyright © Confluent, Inc. 2014- Apache®, Apache Kafka®, Kafka®, Apache Flink®, Flink®, Apache Iceberg®, Iceberg® and associated open source project names are trademarks of the Apache Software Foundation

Flink
  • Overview
  • Installation and Upgrade
    • Overview
    • Versions and Interoperability
    • Install with Helm
    • Install on OpenShift
    • Build Container Images
    • Configure Authentication
    • Configure Authorization
    • Configure Embedded MDS
    • Configure the CMF UI
    • Configure Storage
    • Configure Encryption
    • Configure SQL Statements
    • Configure SQL Compilers and Compile Workers
    • Configure Usage Telemetry
    • Configure Custom Validators
    • Upgrade
  • Get Started
    • Overview
    • Get Started with Applications
    • Get Started with Statements
  • Architecture and Features
    • Overview
    • Understand Flink
    • Confluent Manager for Apache Flink
  • Configure Components and Access Control
    • Overview
    • Manage Multiple Kubernetes Clusters (Multi-Cluster)
    • Manage Environments
    • Manage Environment Catalogs
    • Manage Kafka Catalogs and Databases
    • Manage Compute Pools
    • Manage Artifacts
    • Configure Access Control
  • Deploy and Manage Flink Jobs
    • Overview
    • Applications
      • Overview
      • Create Applications
      • Manage Applications
      • Application Instances
      • Package Flink Jobs
      • Package PyFlink Jobs
      • Package Python UDFs with the Java Table API
      • Run Flink Agents
      • Supported Features
    • SQL Statements
      • Overview
      • Flink Versions
      • Create Statements
      • Manage Statements
      • Carry Over Offsets
      • Batch Statements
      • Table Operations
      • User-Defined Functions
      • Process Table Functions
      • Custom Connectors
      • Views
      • Examples
        • Set Up Your Environment
        • Redact a Column with a UDF
        • Round-Trip an Iceberg Table
        • Read CSV from Object Storage
        • Use the MongoDB Connector
      • Use Interactive Shell
      • Use the SQL Assistant
      • Model Inference
      • Forecast
      • Anomaly Detection
      • Set Up AI Functions
      • Features and Support
    • Events
    • Manage Savepoints
    • Job Configuration
      • Overview
      • Checkpointing
      • Logging
      • Metrics
      • Security
  • Disaster Recovery
    • Overview
    • Prepare for Disaster Recovery
    • Back Up and Restore SQLite Metadata
    • Recover onto a Replacement Cluster
    • SQL Statement Recovery
    • Troubleshoot Disaster Recovery
  • Clients and APIs
    • Overview
    • Use the CMF UI
    • Use REST APIs
    • Use CLI Operations
    • Use the MCP Server
    • Use Confluent for Kubernetes
  • How-to Guides
    • Overview
    • Checkpoint to S3
  • FAQ
  • Get Help
  • What's New
Deploy and Manage Statements in Confluent Manager for Apache Flink
Get started
    Home Confluent Cloud Confluent Platform Connectors Clients
    • Overview
    • Installation and Upgrade
      • Overview
      • Versions and Interoperability
      • Install with Helm
      • Install on OpenShift
      • Build Container Images
      • Configure Authentication
      • Configure Authorization
      • Configure Embedded MDS
      • Configure the CMF UI
      • Configure Storage
      • Configure Encryption
      • Configure SQL Statements
      • Configure SQL Compilers and Compile Workers
      • Configure Usage Telemetry
      • Configure Custom Validators
      • Upgrade
    • Get Started
      • Overview
      • Get Started with Applications
      • Get Started with Statements
    • Architecture and Features
      • Overview
      • Understand Flink
      • Confluent Manager for Apache Flink
    • Configure Components and Access Control
      • Overview
      • Manage Multiple Kubernetes Clusters (Multi-Cluster)
      • Manage Environments
      • Manage Environment Catalogs
      • Manage Kafka Catalogs and Databases
      • Manage Compute Pools
      • Manage Artifacts
      • Configure Access Control
    • Deploy and Manage Flink Jobs
      • Overview
      • Applications
        • Overview
        • Create Applications
        • Manage Applications
        • Application Instances
        • Package Flink Jobs
        • Package PyFlink Jobs
        • Package Python UDFs with the Java Table API
        • Run Flink Agents
        • Supported Features
      • SQL Statements
        • Overview
        • Flink Versions
        • Create Statements
        • Manage Statements
        • Carry Over Offsets
        • Batch Statements
        • Table Operations
        • User-Defined Functions
        • Process Table Functions
        • Custom Connectors
        • Views
        • Examples
          • Set Up Your Environment
          • Redact a Column with a UDF
          • Round-Trip an Iceberg Table
          • Read CSV from Object Storage
          • Use the MongoDB Connector
        • Use Interactive Shell
        • Use the SQL Assistant
        • Model Inference
        • Forecast
        • Anomaly Detection
        • Set Up AI Functions
        • Features and Support
      • Events
      • Manage Savepoints
      • Job Configuration
        • Overview
        • Checkpointing
        • Logging
        • Metrics
        • Security
    • Disaster Recovery
      • Overview
      • Prepare for Disaster Recovery
      • Back Up and Restore SQLite Metadata
      • Recover onto a Replacement Cluster
      • SQL Statement Recovery
      • Troubleshoot Disaster Recovery
    • Clients and APIs
      • Overview
      • Use the CMF UI
      • Use REST APIs
      • Use CLI Operations
      • Use the MCP Server
      • Use Confluent for Kubernetes
    • How-to Guides
      • Overview
      • Checkpoint to S3
    • FAQ
    • Get Help
    • What's New