Confluent Confluent
Documentation Flink Jobs and Confluent Manager for Apache Flink
Confluent Developer Marketplace Get started
Home Confluent Cloud Confluent Platform Connectors Clients
Flink Jobs and 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
      • 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
        • Events
        • Package Flink Jobs
        • Package PyFlink Jobs
        • Package Python UDFs with the Java Table API
        • Run Flink Agents
        • Supported Features
      • SQL Statements
        • Overview
        • Create Statements
        • Manage Statements
        • Table Operations
        • User-Defined Functions
        • Custom Connectors
        • 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
        • Forecast
        • Anomaly Detection
        • Features and Support
      • Manage Savepoints
      • Job Configuration
        • Overview
        • Checkpointing
        • Logging
        • Metrics
        • Security
    • Disaster Recovery
    • Confluent Platform for Apache Flink Operations
      • 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
    Table of contents
    • 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
      • 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
        • Events
        • Package Flink Jobs
        • Package PyFlink Jobs
        • Package Python UDFs with the Java Table API
        • Run Flink Agents
        • Supported Features
      • SQL Statements
        • Overview
        • Create Statements
        • Manage Statements
        • Table Operations
        • User-Defined Functions
        • Custom Connectors
        • 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
        • Forecast
        • Anomaly Detection
        • Features and Support
      • Manage Savepoints
      • Job Configuration
        • Overview
        • Checkpointing
        • Logging
        • Metrics
        • Security
    • Disaster Recovery
    • Confluent Platform for Apache Flink Operations
      • 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
    1. Home
    2. Flink Jobs

    Flink Jobs for Confluent Manager for Apache Flink

    Flink applications are deployed in Confluent Platform with Confluent Manager for Apache Flink® (CMF), which is a central management component that enables users to securely manage a fleet of Flink jobs across multiple environments.

    CMF supports two ways to create and manage Flink jobs.

    • Applications offer the full flexibility of Flink programs. You can use all JVM-based APIs (DataStream, Table, SQL) and submit and manage applications packaged as JAR files.

    • Statements offer the ease-of-use of a native SQL interface. You can run table operations, interactive SQL statements, or submit and manage long-running SQL statements.

    Applications and Statements offer all Flink configuration options and can be tuned to meet their performance, fault-tolerance, and security requirements.

    Ask the community Confluent Support Portal Last published: Apr 13, 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