tree: 86b705ca612d8c69390b801bcc5b4bfdd043dd46 [path history] [tgz]
  1. fluss-flink-1.18/
  2. fluss-flink-1.19/
  3. fluss-flink-1.20/
  4. fluss-flink-2.1/
  5. fluss-flink-common/
  6. fluss-flink-tiering/
  7. pom.xml
  8. README.md
fluss-flink/README.md

Multi-Version Support for Flink Engine

Fluss supports multiple versions of Apache Flink by providing dedicated modules for each version. The fluss-flink-common module always targets the latest version of Flink, while the fluss-flink-${flink.version} modules depend on both fluss-flink-common and the corresponding Flink version.

Occasionally, Flink's interfaces may change across versions. For example, the class org.apache.flink.api.connector.sink2.WriterInitContext was introduced in Flink v1.19, while older APIs were deprecated or removed. In such cases, we address compatibility issues within the specific fluss-flink-${flink.version} module. This may involve introducing placeholder classes, such as org.apache.flink.api.connector.sink2.WriterInitContext, to ensure successful compilation.