This is an automated email from the ASF dual-hosted git repository.
zhouyuan pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/gluten.git
The following commit(s) were added to refs/heads/main by this push:
new 488e02621c [FLINK] Bump Flink to 1.19.3 (#13233)
488e02621c is described below
commit 488e02621c4070387fb7be21c9792151275d98ae
Author: Yuan <[email protected]>
AuthorDate: Sat Oct 10 14:27:48 2026 +0100
[FLINK] Bump Flink to 1.19.3 (#13233)
---
gluten-flink/docs/Flink.md | 4 +--
gluten-flink/pom.xml | 29 ++++++++++++----------
.../operators/GlutenAbstractStreamOperator.java | 6 ++---
3 files changed, 21 insertions(+), 18 deletions(-)
diff --git a/gluten-flink/docs/Flink.md b/gluten-flink/docs/Flink.md
index b5586eea22..808f05216a 100644
--- a/gluten-flink/docs/Flink.md
+++ b/gluten-flink/docs/Flink.md
@@ -8,7 +8,7 @@ nav_order: 1
| Type | Version |
|-------|------------------------------|
-| Flink | 1.19.2 |
+| Flink | 1.19.3 |
| OS | Ubuntu20.04/22.04, Centos7/8 |
| jdk | openjdk11/jdk17 |
| scala | 2.12 |
@@ -17,7 +17,7 @@ nav_order: 1
Currently, with static build Gluten+Flink+Velox backend supports all the Linux
OSes, but is only tested on **Ubuntu20.04**. With dynamic build, Gluten+Velox
backend support **Ubuntu20.04/Ubuntu22.04/Centos7/Centos8** and their variants.
-Currently, the officially supported Flink version is 1.19.2.
+Currently, the officially supported Flink version is 1.19.3.
We need to set up the `JAVA_HOME` env. Currently, Gluten supports **java 11**
and **java 17**.
diff --git a/gluten-flink/pom.xml b/gluten-flink/pom.xml
index 3f436cc6c1..339a76ea48 100644
--- a/gluten-flink/pom.xml
+++ b/gluten-flink/pom.xml
@@ -1,17 +1,20 @@
<?xml version="1.0" encoding="UTF-8"?>
<!--
- Licensed 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.
--->
+ ~ 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>
@@ -29,7 +32,7 @@
</modules>
<properties>
- <flink.version>1.19.2</flink.version>
+ <flink.version>1.19.3</flink.version>
<velox4j.version>0.1.0-SNAPSHOT</velox4j.version>
<scala.binary.version>2.12</scala.binary.version>
<maven.compiler.source>11</maven.compiler.source>
diff --git
a/gluten-flink/runtime/src/main/java/org/apache/gluten/streaming/api/operators/GlutenAbstractStreamOperator.java
b/gluten-flink/runtime/src/main/java/org/apache/gluten/streaming/api/operators/GlutenAbstractStreamOperator.java
index 7c8202d32a..af4b1412f7 100644
---
a/gluten-flink/runtime/src/main/java/org/apache/gluten/streaming/api/operators/GlutenAbstractStreamOperator.java
+++
b/gluten-flink/runtime/src/main/java/org/apache/gluten/streaming/api/operators/GlutenAbstractStreamOperator.java
@@ -103,7 +103,7 @@ import static
org.apache.flink.util.Preconditions.checkState;
* AbstractStreamOperatorV2}. However as {@link AbstractStreamOperatorV2} is
currently experimental,
* {@link AbstractStreamOperator} has not been deprecated just yet.
*
- * <p>This class is a Gluten-local copy of Flink 1.19.2 {@link
AbstractStreamOperator}. Gluten needs
+ * <p>This class is a Gluten-local copy of Flink 1.19.3 {@link
AbstractStreamOperator}. Gluten needs
* this fork because Flink's watermark status entrypoints are final in both
operator base classes:
* {@code AbstractStreamOperator.processWatermarkStatus1/2(...)} and {@code
* AbstractStreamOperatorV2.processWatermarkStatus(...)}. Those methods route
two-input {@code
@@ -113,7 +113,7 @@ import static
org.apache.flink.util.Preconditions.checkState;
* base class would prevent {@code GlutenTwoInputOperator} from overriding the
status handling,
* while not using a base class at all would lose the runtime, state,
key-context, timer, latency,
* and checkpoint behavior implemented by {@code AbstractStreamOperator}. Keep
this file aligned
- * with Flink 1.19.2 except for making {@code processWatermarkStatus1/2(...)}
overridable.
+ * with Flink 1.19.3 except for making {@code processWatermarkStatus1/2(...)}
overridable.
*
* @param <OUT> The output type of the operator.
*/
@@ -147,7 +147,7 @@ public abstract class GlutenAbstractStreamOperator<OUT>
// Concrete two-input subclasses (e.g. GlutenTwoInputOperator) override
those entrypoints to
// forward each input's watermark/status directly to native, bypassing this
Java-side combined
// watermark. The field and the private indexed overloads are kept to stay
aligned with Flink
- // 1.19.2's AbstractStreamOperator and to serve any future subclass that
wants the default
+ // 1.19.3's AbstractStreamOperator and to serve any future subclass that
wants the default
// behavior; they are effectively dead code for the current Gluten operators.
private transient IndexedCombinedWatermarkStatus combinedWatermark;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
