This is an automated email from the ASF dual-hosted git repository.
xuba pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/amoro.git
The following commit(s) were added to refs/heads/master by this push:
new 45f074df1 [AMORO-4127] Add mixed Flink 1.19 support (#4141)
45f074df1 is described below
commit 45f074df18c25e7baec37f6f8baecfa133d6a56b
Author: Jiwon Park <[email protected]>
AuthorDate: Sat Mar 28 16:07:08 2026 +0900
[AMORO-4127] Add mixed Flink 1.19 support (#4141)
* [AMORO-4127][mixed-flink] Add mixed Flink 1.19 support
- Add v1.19/amoro-mixed-flink-1.19 and v1.19/amoro-mixed-flink-runtime-1.19
modules
- Register new modules in parent pom.xml
- Update documentation to include Flink 1.19 in supported version matrix
- Add kind cluster config for local E2E testing
Signed-off-by: Jiwon Park <[email protected]>
---
README.md | 2 +-
.../amoro-mixed-flink-common/pom.xml | 8 +-
.../amoro/flink/write/MixedFormatWriter.java | 4 +
.../amoro/flink/catalog/TestMixedCatalog.java | 4 +-
amoro-format-mixed/amoro-mixed-flink/pom.xml | 2 +
.../v1.19/amoro-mixed-flink-1.19/pom.xml | 99 +++++++++
.../v1.19/amoro-mixed-flink-runtime-1.19/pom.xml | 238 +++++++++++++++++++++
docs/_index.md | 2 +-
docs/engines/flink/flink-get-started.md | 2 +-
docs/engines/flink/using-logstore.md | 2 +
10 files changed, 355 insertions(+), 8 deletions(-)
diff --git a/README.md b/README.md
index d3c3e8783..1d15247aa 100644
--- a/README.md
+++ b/README.md
@@ -82,7 +82,7 @@ Amoro support multiple processing engines for Mixed format as
below:
| Processing Engine | Version | Batch Read | Batch Write |
Batch Overwrite | Streaming Read | Streaming Write | Create Table | Alter Table
|
|-------------------|------------------------|-------------|-------------|-----------------|----------------|-----------------|--------------|-------------|
-| Flink | 1.17.x, 1.18.x | ✔ | ✔ |
✖ | ✔ | ✔ | ✔ | ✖
|
+| Flink | 1.17.x, 1.18.x, 1.19.x | ✔ | ✔ |
✖ | ✔ | ✔ | ✔ | ✖
|
| Spark | 3.3, 3.4, 3.5 | ✔ | ✔ |
✔ | ✖ | ✖ | ✔ | ✔
|
| Hive | 2.x, 3.x | ✔ | ✖ |
✔ | ✖ | ✖ | ✖ | ✔ |
| Trino | 406 | ✔ | ✖ |
✔ | ✖ | ✖ | ✖ | ✔ |
diff --git
a/amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/pom.xml
b/amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/pom.xml
index c147dad91..60d5d7b36 100644
--- a/amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/pom.xml
+++ b/amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/pom.xml
@@ -34,7 +34,7 @@
<properties>
<assertj.version>3.21.0</assertj.version>
- <flink.version>1.18.1</flink.version>
+ <flink.version>1.19.1</flink.version>
</properties>
<dependencies>
@@ -63,7 +63,7 @@
<dependency>
<groupId>org.apache.iceberg</groupId>
- <artifactId>iceberg-flink-1.18</artifactId>
+ <artifactId>iceberg-flink-1.19</artifactId>
<version>${iceberg.version}</version>
<scope>provided</scope>
<exclusions>
@@ -84,7 +84,7 @@
<dependency>
<groupId>org.apache.paimon</groupId>
- <artifactId>paimon-flink-1.18</artifactId>
+ <artifactId>paimon-flink-1.19</artifactId>
<version>${paimon.version}</version>
<scope>provided</scope>
</dependency>
@@ -219,7 +219,7 @@
<dependency>
<groupId>org.apache.iceberg</groupId>
- <artifactId>iceberg-flink-1.18</artifactId>
+ <artifactId>iceberg-flink-1.19</artifactId>
<version>${iceberg.version}</version>
<classifier>tests</classifier>
<scope>test</scope>
diff --git
a/amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/write/MixedFormatWriter.java
b/amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/write/MixedFormatWriter.java
index e5dfb7a4a..690672b75 100644
---
a/amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/write/MixedFormatWriter.java
+++
b/amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/write/MixedFormatWriter.java
@@ -32,6 +32,7 @@ import
org.apache.flink.streaming.api.operators.OneInputStreamOperator;
import org.apache.flink.streaming.api.operators.Output;
import org.apache.flink.streaming.api.watermark.Watermark;
import org.apache.flink.streaming.runtime.streamrecord.LatencyMarker;
+import org.apache.flink.streaming.runtime.streamrecord.RecordAttributes;
import org.apache.flink.streaming.runtime.streamrecord.StreamRecord;
import org.apache.flink.streaming.runtime.tasks.StreamTask;
import org.apache.flink.streaming.runtime.watermarkstatus.WatermarkStatus;
@@ -212,6 +213,9 @@ public class MixedFormatWriter<OUT> extends
AbstractStreamOperator<OUT>
@Override
public void emitLatencyMarker(LatencyMarker latencyMarker) {}
+ @Override
+ public void emitRecordAttributes(RecordAttributes recordAttributes) {}
+
@Override
public void close() {}
};
diff --git
a/amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/test/java/org/apache/amoro/flink/catalog/TestMixedCatalog.java
b/amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/test/java/org/apache/amoro/flink/catalog/TestMixedCatalog.java
index 5e4bb582b..b0a009251 100644
---
a/amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/test/java/org/apache/amoro/flink/catalog/TestMixedCatalog.java
+++
b/amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/test/java/org/apache/amoro/flink/catalog/TestMixedCatalog.java
@@ -116,9 +116,11 @@ public class TestMixedCatalog extends CatalogTestBase {
@After
public void after() {
sql("DROP TABLE IF EXISTS " + catalogName + "." + DB + "." + TABLE);
+ // Switch away from the catalog before dropping the database.
+ // Flink 1.19+ rejects dropping the currently active database.
+ sql("USE CATALOG default_catalog");
sql("DROP DATABASE IF EXISTS " + catalogName + "." + DB);
Assert.assertTrue(CollectionUtil.isNullOrEmpty(getMixedFormatCatalog().listDatabases()));
- sql("USE CATALOG default_catalog");
sql("DROP CATALOG " + catalogName);
}
diff --git a/amoro-format-mixed/amoro-mixed-flink/pom.xml
b/amoro-format-mixed/amoro-mixed-flink/pom.xml
index 28773c0b1..399691563 100644
--- a/amoro-format-mixed/amoro-mixed-flink/pom.xml
+++ b/amoro-format-mixed/amoro-mixed-flink/pom.xml
@@ -40,6 +40,8 @@
<module>v1.17/amoro-mixed-flink-runtime-1.17</module>
<module>v1.18/amoro-mixed-flink-1.18</module>
<module>v1.18/amoro-mixed-flink-runtime-1.18</module>
+ <module>v1.19/amoro-mixed-flink-1.19</module>
+ <module>v1.19/amoro-mixed-flink-runtime-1.19</module>
</modules>
<properties>
diff --git
a/amoro-format-mixed/amoro-mixed-flink/v1.19/amoro-mixed-flink-1.19/pom.xml
b/amoro-format-mixed/amoro-mixed-flink/v1.19/amoro-mixed-flink-1.19/pom.xml
new file mode 100644
index 000000000..2295bcab1
--- /dev/null
+++ b/amoro-format-mixed/amoro-mixed-flink/v1.19/amoro-mixed-flink-1.19/pom.xml
@@ -0,0 +1,99 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+ ~ Licensed to the Apache Software Foundation (ASF) under one
+ ~ or more contributor license agreements. See the NOTICE file
+ ~ distributed with this work for additional information
+ ~ regarding copyright ownership. The ASF licenses this file
+ ~ to you under the Apache License, Version 2.0 (the
+ ~ "License"); you may not use this file except in compliance
+ ~ with the License. You may obtain a copy of the License at
+ ~
+ ~ http://www.apache.org/licenses/LICENSE-2.0
+ ~
+ ~ Unless required by applicable law or agreed to in writing, software
+ ~ distributed under the License is distributed on an "AS IS" BASIS,
+ ~ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ ~ See the License for the specific language governing permissions and
+ ~ limitations under the License.
+ -->
+<project xmlns="http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
+ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
http://maven.apache.org/xsd/maven-4.0.0.xsd";>
+ <modelVersion>4.0.0</modelVersion>
+ <parent>
+ <groupId>org.apache.amoro</groupId>
+ <artifactId>amoro-mixed-flink</artifactId>
+ <version>0.9-SNAPSHOT</version>
+ <relativePath>../../pom.xml</relativePath>
+ </parent>
+
+ <artifactId>amoro-format-mixed-flink-1.19</artifactId>
+
+ <packaging>jar</packaging>
+ <name>Amoro Project Mixed Format Flink 1.19</name>
+ <url>https://amoro.apache.org</url>
+
+ <properties>
+ <kafka.version>3.2.3</kafka.version>
+ <assertj.version>3.21.0</assertj.version>
+ <flink.version>1.19.1</flink.version>
+ </properties>
+
+ <dependencies>
+ <dependency>
+ <groupId>org.apache.amoro</groupId>
+ <artifactId>amoro-mixed-flink-common</artifactId>
+ <version>${project.parent.version}</version>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.iceberg</groupId>
+ <artifactId>iceberg-flink-1.19</artifactId>
+ <version>${iceberg.version}</version>
+ <exclusions>
+ <exclusion>
+ <groupId>org.slf4j</groupId>
+ <artifactId>slf4j-api</artifactId>
+ </exclusion>
+ <exclusion>
+ <groupId>org.apache.parquet</groupId>
+ <artifactId>parquet-column</artifactId>
+ </exclusion>
+ <exclusion>
+ <groupId>org.apache.parquet</groupId>
+ <artifactId>parquet-avro</artifactId>
+ </exclusion>
+ </exclusions>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.paimon</groupId>
+ <artifactId>paimon-flink-1.19</artifactId>
+ <version>${paimon.version}</version>
+ </dependency>
+ </dependencies>
+
+ <build>
+ <plugins>
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-shade-plugin</artifactId>
+ <executions>
+ <execution>
+ <id>shade-amoro</id>
+ <goals>
+ <goal>shade</goal>
+ </goals>
+ <phase>package</phase>
+ <configuration>
+ <artifactSet>
+ <includes combine.children="append">
+
<include>org.apache.amoro:amoro-format-mixed-flink-common</include>
+ </includes>
+ </artifactSet>
+ </configuration>
+ </execution>
+ </executions>
+ </plugin>
+ </plugins>
+ </build>
+</project>
diff --git
a/amoro-format-mixed/amoro-mixed-flink/v1.19/amoro-mixed-flink-runtime-1.19/pom.xml
b/amoro-format-mixed/amoro-mixed-flink/v1.19/amoro-mixed-flink-runtime-1.19/pom.xml
new file mode 100644
index 000000000..1f3916dae
--- /dev/null
+++
b/amoro-format-mixed/amoro-mixed-flink/v1.19/amoro-mixed-flink-runtime-1.19/pom.xml
@@ -0,0 +1,238 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+ ~ Licensed to the Apache Software Foundation (ASF) under one
+ ~ or more contributor license agreements. See the NOTICE file
+ ~ distributed with this work for additional information
+ ~ regarding copyright ownership. The ASF licenses this file
+ ~ to you under the Apache License, Version 2.0 (the
+ ~ "License"); you may not use this file except in compliance
+ ~ with the License. You may obtain a copy of the License at
+ ~
+ ~ http://www.apache.org/licenses/LICENSE-2.0
+ ~
+ ~ Unless required by applicable law or agreed to in writing, software
+ ~ distributed under the License is distributed on an "AS IS" BASIS,
+ ~ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ ~ See the License for the specific language governing permissions and
+ ~ limitations under the License.
+ -->
+<project xmlns="http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
+ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
http://maven.apache.org/xsd/maven-4.0.0.xsd";>
+ <modelVersion>4.0.0</modelVersion>
+ <parent>
+ <groupId>org.apache.amoro</groupId>
+ <artifactId>amoro-mixed-flink</artifactId>
+ <version>0.9-SNAPSHOT</version>
+ <relativePath>../../pom.xml</relativePath>
+ </parent>
+
+ <artifactId>amoro-format-mixed-flink-runtime-1.19</artifactId>
+ <name>Amoro Project Mixed Format Flink 1.19 Runtime</name>
+ <url>https://amoro.apache.org</url>
+
+ <properties>
+ <flink.version>1.19.1</flink.version>
+ <flink-kafka.version>3.3.0-1.19</flink-kafka.version>
+ </properties>
+
+ <dependencies>
+ <dependency>
+ <groupId>org.apache.amoro</groupId>
+ <artifactId>amoro-format-mixed-flink-1.19</artifactId>
+ <version>${project.parent.version}</version>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.flink</groupId>
+ <artifactId>flink-connector-kafka</artifactId>
+ <version>${flink-kafka.version}</version>
+ <exclusions>
+ <exclusion>
+ <groupId>com.github.luben</groupId>
+ <artifactId>zstd-jni</artifactId>
+ </exclusion>
+ </exclusions>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.kafka</groupId>
+ <artifactId>kafka-clients</artifactId>
+ <version>${kafka.version}</version>
+ <exclusions>
+ <exclusion>
+ <groupId>com.github.luben</groupId>
+ <artifactId>zstd-jni</artifactId>
+ </exclusion>
+ </exclusions>
+ </dependency>
+ </dependencies>
+
+ <build>
+ <plugins>
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-shade-plugin</artifactId>
+ <executions>
+ <execution>
+ <id>shade-amoro</id>
+ <goals>
+ <goal>shade</goal>
+ </goals>
+ <phase>package</phase>
+ <configuration>
+ <filters>
+ <filter>
+
<artifact>com.fasterxml.jackson.core:jackson-core</artifact>
+ <excludes>
+ <exclude>META-INF/versions/**</exclude>
+ </excludes>
+ </filter>
+ </filters>
+
<createDependencyReducedPom>false</createDependencyReducedPom>
+ <artifactSet>
+ <includes combine.children="append">
+ <include>org.apache.amoro:*</include>
+ <include>org.apache.iceberg:*</include>
+
<include>com.fasterxml.jackson.core:*</include>
+ <include>org.apache.parquet:*</include>
+ <include>org.apache.commons:*</include>
+ <include>commons-lang:*</include>
+
<include>com.github.ben-manes.caffeine:*</include>
+ <include>org.apache.avro:*</include>
+ <include>org.apache.orc:*</include>
+ <include>io.airlift:*</include>
+ <include>commons-collections:*</include>
+ <include>cglib:*</include>
+ <include>com.google.guava:*</include>
+ <include>asm:*</include>
+
<include>org.apache.httpcomponents.client5:*</include>
+
<include>org.apache.httpcomponents.core5:*</include>
+
<include>org.apache.flink:flink-connector-kafka</include>
+ <include>org.apache.kafka:*</include>
+ <include>com.github.luben:*</include>
+ <include>com.github.luben:*</include>
+ </includes>
+ </artifactSet>
+
+ <relocations>
+ <relocation>
+ <pattern>org.apache.iceberg</pattern>
+
<shadedPattern>org.apache.amoro.shade.org.apache.iceberg</shadedPattern>
+ <excludes>
+
<exclude>org.apache.iceberg.mr.hive.*</exclude>
+ </excludes>
+ </relocation>
+
+ <relocation>
+ <pattern>org.apache.parquet</pattern>
+
<shadedPattern>org.apache.amoro.shade.org.apache.parquet</shadedPattern>
+ </relocation>
+
+ <relocation>
+ <pattern>org.apache.commons</pattern>
+
<shadedPattern>org.apache.amoro.shade.org.apache.commons</shadedPattern>
+ </relocation>
+
+ <relocation>
+ <pattern>org.apache.avro</pattern>
+
<shadedPattern>org.apache.amoro.shade.org.apache.avro</shadedPattern>
+ </relocation>
+
+ <relocation>
+ <pattern>org.apache.orc</pattern>
+
<shadedPattern>org.apache.amoro.shade.org.apache.orc</shadedPattern>
+ </relocation>
+
+ <relocation>
+ <pattern>org.apache.hc</pattern>
+
<shadedPattern>org.apache.amoro.shade.org.apache.hc</shadedPattern>
+ </relocation>
+
+ <relocation>
+ <pattern>org.apache.jute</pattern>
+
<shadedPattern>org.apache.amoro.shade.org.apache.jute</shadedPattern>
+ </relocation>
+
+ <relocation>
+ <pattern>org.apache.kafka</pattern>
+
<shadedPattern>org.apache.amoro.shade.org.apache.kafka</shadedPattern>
+ </relocation>
+
+ <relocation>
+ <pattern>shaded.parquet</pattern>
+
<shadedPattern>org.apache.amoro.shade.shaded.parquet</shadedPattern>
+ </relocation>
+
+ <relocation>
+ <pattern>com.fasterxml</pattern>
+
<shadedPattern>org.apache.amoro.shade.com.fasterxml</shadedPattern>
+ </relocation>
+
+ <relocation>
+
<pattern>com.github.benmanes.caffeine</pattern>
+
<shadedPattern>org.apache.amoro.shade.com.github.benmanes.caffeine</shadedPattern>
+ </relocation>
+
+ <relocation>
+ <pattern>org.threeten.extra</pattern>
+
<shadedPattern>org.apache.amoro.shade.org.threeten.extra</shadedPattern>
+ </relocation>
+
+ <relocation>
+ <pattern>net.sf.cglib</pattern>
+
<shadedPattern>org.apache.amoro.shade.net.sf.cglib</shadedPattern>
+ </relocation>
+
+ <relocation>
+ <pattern>com.google</pattern>
+
<shadedPattern>org.apache.amoro.shade.com.google</shadedPattern>
+ </relocation>
+
+ <relocation>
+ <pattern>org.objectweb.asm</pattern>
+
<shadedPattern>org.apache.amoro.shade.org.objectweb.asm</shadedPattern>
+ </relocation>
+
+ <relocation>
+ <pattern>com.facebook.fb303</pattern>
+
<shadedPattern>org.apache.amoro.shade.com.facebook.fb303</shadedPattern>
+ </relocation>
+
+ <relocation>
+ <pattern>io.airlift</pattern>
+
<shadedPattern>org.apache.amoro.shade.io.airlift</shadedPattern>
+ </relocation>
+
+ <!-- flink-sql-connector-kafka -->
+ <relocation>
+
<pattern>org.apache.flink.connector.kafka</pattern>
+
<shadedPattern>org.apache.amoro.shade.org.apache.flink.connector.kafka</shadedPattern>
+ </relocation>
+ <relocation>
+
<pattern>org.apache.flink.streaming.connectors.kafka</pattern>
+
<shadedPattern>org.apache.amoro.shade.org.apache.flink.streaming.connectors.kafka</shadedPattern>
+ </relocation>
+ <relocation>
+
<pattern>org.apache.flink.streaming.util.serialization.JSONKeyValueDeserializationSchema</pattern>
+
<shadedPattern>org.apache.amoro.shade.org.apache.flink.streaming.util.serialization.JSONKeyValueDeserializationSchema</shadedPattern>
+ </relocation>
+ <relocation>
+
<pattern>org.apache.flink.streaming.util.serialization.KeyedDeserializationSchema</pattern>
+
<shadedPattern>org.apache.amoro.shade.org.apache.flink.streaming.util.serialization.KeyedDeserializationSchema</shadedPattern>
+ </relocation>
+ <relocation>
+
<pattern>org.apache.flink.streaming.util.serialization.KeyedSerializationSchema</pattern>
+
<shadedPattern>org.apache.amoro.shade.org.apache.flink.streaming.util.serialization.KeyedSerializationSchema</shadedPattern>
+ </relocation>
+ <relocation>
+
<pattern>org.apache.flink.streaming.util.serialization.TypeInformationKeyValueSerializationSchema</pattern>
+
<shadedPattern>org.apache.amoro.shade.org.apache.flink.streaming.util.serialization.TypeInformationKeyValueSerializationSchema</shadedPattern>
+ </relocation>
+ </relocations>
+ </configuration>
+ </execution>
+ </executions>
+ </plugin>
+ </plugins>
+ </build>
+</project>
diff --git a/docs/_index.md b/docs/_index.md
index 063721585..7c3a7a4b3 100644
--- a/docs/_index.md
+++ b/docs/_index.md
@@ -69,7 +69,7 @@ Amoro support multiple processing engines for Mixed format as
below:
| Processing Engine | Version | Batch Read | Batch Write |
Batch Overwrite | Streaming Read | Streaming Write | Create Table | Alter Table
|
|-------------------|------------------------|-------------|-------------|-----------------|----------------|-----------------|--------------|-------------|
-| Flink | 1.17.x, 1.18.x | ✔ | ✔ |
✖ | ✔ | ✔ | ✔ | ✖
|
+| Flink | 1.17.x, 1.18.x, 1.19.x | ✔ | ✔ |
✖ | ✔ | ✔ | ✔ | ✖
|
| Spark | 3.3, 3.4, 3.5 | ✔ | ✔ |
✔ | ✖ | ✖ | ✔ | ✔
|
| Hive | 2.x, 3.x | ✔ | ✖ |
✔ | ✖ | ✖ | ✖ | ✔ |
| Trino | 406 | ✔ | ✖ |
✔ | ✖ | ✖ | ✖ | ✔ |
diff --git a/docs/engines/flink/flink-get-started.md
b/docs/engines/flink/flink-get-started.md
index 0c6e1d3cd..a29511830 100644
--- a/docs/engines/flink/flink-get-started.md
+++ b/docs/engines/flink/flink-get-started.md
@@ -59,7 +59,7 @@ The Amoro project can be self-compiled to obtain the runtime
jar.
The Flink Runtime Jar is located in the
`amoro-format-mixed/amoro-mixed-flink/v1.17/amoro-mixed-flink-runtime-1.17/target`
directory.
## Environment preparation
-Download Flink and related dependencies, and download Flink 1.17/1.18 as
needed. Taking Flink 1.17 as an example:
+Download Flink and related dependencies, and download Flink 1.17/1.18/1.19 as
needed. Taking Flink 1.17 as an example:
```shell
# Replace version value with the latest Amoro version if needed
AMORO_VERSION=0.8.0-incubating
diff --git a/docs/engines/flink/using-logstore.md
b/docs/engines/flink/using-logstore.md
index 30803dc93..0ecd50095 100644
--- a/docs/engines/flink/using-logstore.md
+++ b/docs/engines/flink/using-logstore.md
@@ -44,6 +44,7 @@ Users can enable LogStore by configuring the following
parameters when creating
|------------|----------|
| Flink 1.17 | ✔ |
| Flink 1.18 | ✔ |
+| Flink 1.19 | ✔ |
Kafka as LogStore Version Description:
@@ -51,6 +52,7 @@ Kafka as LogStore Version Description:
|---------------| ----------------- |
| 1.17.x | 0.10.2.\*<br> 0.11.\*<br> 1.\*<br> 2.\*<br> 3.\* |
| 1.18.x | 0.10.2.\*<br> 0.11.\*<br> 1.\*<br> 2.\*<br> 3.\* |
+| 1.19.x | 0.10.2.\*<br> 0.11.\*<br> 1.\*<br> 2.\*<br> 3.\* |
