Use Aiven for Apache Flink® applications

Aiven for Flink applications in Aiven for Apache Flink® servers as a container that includes everything connected to a Flink job, including source and sink connections and data processing logic.

Using the Aiven Console, you can create applications that run SQL queries or deploy custom JARs, catering to diverse data processing requirements. The console's guided wizard simplifies the application configuration process, from selecting source and sink tables for SQL applications to uploading and managing JAR files for custom job execution.

important

Custom JARs for Aiven for Apache Flink is a limited availability feature. If you're interested in trying out this feature, contact the sales team at sales@aiven.io.

Create an SQL application

Build data processing pipelines in Aiven for Apache Flink® by creating SQL applications using Apache Flink SQL. Set up source and sink tables, define processing logic, and manage your deployments.

Create a JAR application

Aiven for Apache Flink® enables you to upload and deploy custom code as a JAR file, enhancing your Apache Flink applications with advanced data processing capabilities.

Manage Aiven for Apache Flink® applications

This section provides information on managing your Aiven for Apache Flink® applications.

Restart strategy in SQL and JAR applications

Learn how Aiven for Apache Flink® applications uses restart strategies to recover from job failures, ensuring high availability and fault tolerance for your distributed applications.

Credential management for JAR applications

Learn how to use the AVNCREDENTIALSDIR environment variable to securely manage credentials for custom JARs in Aiven for Apache Flink®.