This documentation is for an out-of-date version of Apache Flink. We recommend you use
the latest stable version
.
v1.10
Home
Getting Started
Overview
Code Walkthroughs
DataStream API
Table API
Docker Playgrounds
Flink Operations Playground
Tutorials
API Tutorials
Python API
Setup Tutorials
Local Setup
Running Flink on Windows
Examples
Overview
Batch Examples
Concepts
Programming Model
Distributed Runtime
Glossary
Application Development
Project Build Setup
Project Template for Java
Project Template for Scala
Configuring Dependencies, Connectors, Libraries
Basic API Concepts
Overview
Scala API Extensions
Java Lambda Expressions
Streaming (DataStream API)
Overview
Event Time
Overview
Generating Timestamps / Watermarks
Pre-defined Timestamp Extractors / Watermark Emitters
State & Fault Tolerance
Overview
Working with State
The Broadcast State Pattern
Checkpointing
Queryable State
State Backends
State Schema Evolution
Custom State Serialization
Operators
Overview
Windows
Joining
Process Function
Async I/O
Connectors
Overview
Fault Tolerance Guarantees
Kafka
Cassandra
Kinesis
Elasticsearch
Hadoop FileSystem
Streaming File Sink
RabbitMQ
NiFi
Google Cloud PubSub
Twitter
Side Outputs
Testing
Experimental Features
Batch (DataSet API)
Overview
Transformations
Iterations
Zipping Elements
Connectors
Hadoop Compatibility
Local Execution
Cluster Execution
Table API & SQL
Overview
Concepts & Common API
Streaming Concepts
Overview
Dynamic Tables
Time Attributes
Joins in Continuous Queries
Temporal Tables
Detecting Patterns
Query Configuration
Data Types
Table API
SQL
Overview
Queries
CREATE Statements
DROP Statements
ALTER Statements
INSERT Statement
Connect to External Systems
Functions
Overview
System (Built-in) Functions
User-defined Functions
Modules
Catalogs
SQL Client
Hive Integration
Overview
HiveCatalog
Reading & Writing Hive Tables
Hive functions
Python Table API
Overview
Installation
User-defined Functions
Dependency Management
Configuration
Common Questions
Configuration
Performance Tuning
Streaming Aggregation
User-defined Sources & Sinks
Data Types & Serialization
Overview
Custom Serializers
Managing Execution
Execution Configuration
Program Packaging
Parallel Execution
Execution Plans
Task Failure Recovery
Libraries
Event Processing (CEP)
State Processor API
Graphs: Gelly
Overview
Graph API
Iterative Graph Processing
Library Methods
Graph Algorithms
Graph Generators
Bipartite Graph
API Migration Guides
Deployment & Operations
Clusters & Deployment
Standalone Cluster
YARN
Mesos
Docker
Kubernetes
Native Kubernetes
Hadoop Integration
High Availability (HA)
State & Fault Tolerance
Checkpoints
Savepoints
State Backends
Tuning Checkpoints and Large State
Configuration
Memory Configuration
Set up Task Executor Memory
Detailed Memory Model
Memory tuning guide
Troubleshooting
Migration Guide
Production Readiness Checklist
CLI
Python REPL
Scala REPL
Kerberos
SSL Setup
File Systems
Overview
Common Configurations
Amazon S3
Aliyun OSS
Azure Blob Storage
Upgrading Applications and Flink Versions
Plugins
Debugging & Monitoring
Metrics
Logging
History Server
Monitoring Checkpointing
Monitoring Back Pressure
Monitoring REST API
Debugging Windows & Event Time
Debugging Classloading
Application Profiling & Debugging
Flink Development
Importing Flink into an IDE
Building Flink from Source
Internals
Component Stack
Fault Tolerance for Data Streaming
Jobs and Scheduling
Task Lifecycle
File Systems
Javadocs
Scaladocs
Pythondocs
Project Page
Go
Pick Docs Version
v1.9
v1.8
v1.7
v1.6
v1.5
v1.4
v1.3
v1.2
v1.1
v1.0
中文版
Page 'Fault Tolerance' Has Moved
The
Fault Tolerance
has been moved. Redirecting to
//ci.apache.org/projects/flink/flink-docs-release-1.10/dev/task_failure_recovery.html
in 1 second.
v1.10 v1.10