This is an automated email from the ASF dual-hosted git repository.
KevinyhZou 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 ddfa85f7c3 [GLUTEN-12457][FLINK] configure FLINK preset before
Velox4j.initialize (#12458)
ddfa85f7c3 is described below
commit ddfa85f7c3621f6bde79e23f18daf966e2fa6fc4
Author: GGboom <[email protected]>
AuthorDate: Fri Aug 28 12:15:21 2026 +0800
[GLUTEN-12457][FLINK] configure FLINK preset before Velox4j.initialize
(#12458)
* [FLINK] configure FLINK preset before Velox4j.initialize
---
.github/workflows/flink.yml | 4 ++--
gluten-flink/docs/Flink.md | 2 +-
.../java/org/apache/flink/runtime/taskexecutor/TaskManagerRunner.java | 3 +++
.../apache/gluten/table/runtime/stream/common/Velox4jEnvironment.java | 2 ++
4 files changed, 8 insertions(+), 3 deletions(-)
diff --git a/.github/workflows/flink.yml b/.github/workflows/flink.yml
index 27b5aad5b4..ef8c36c311 100644
--- a/.github/workflows/flink.yml
+++ b/.github/workflows/flink.yml
@@ -71,7 +71,7 @@ jobs:
ccache-flink-centos8
- name: Prepare and build velox4j
run: |
- source /opt/rh/gcc-toolset-11/enable
+ source /opt/rh/gcc-toolset-12/enable
sudo dnf install -y patchelf ccache
export CCACHE_DIR=${CCACHE_DIR}
export CCACHE_MAXSIZE=2G
@@ -88,7 +88,7 @@ jobs:
export fmt_SOURCE=BUNDLED
export folly_SOURCE=BUNDLED
git clone -b gluten-0530 https://github.com/bigo-sg/velox4j.git
- cd velox4j && git reset --hard
feb921eabe637bff88eda0fc753d36bbe422fe87
+ cd velox4j && git reset --hard
42a77de002707b6811791ba2d728f169aeb5d7bb
git apply $GITHUB_WORKSPACE/gluten-flink/patches/fix-velox4j.patch
$GITHUB_WORKSPACE/build/mvn clean install -DskipTests -Dgpg.skip
-Dspotless.skip=true
cd ..
diff --git a/gluten-flink/docs/Flink.md b/gluten-flink/docs/Flink.md
index 3fc46f25d1..3a4fcf9fdb 100644
--- a/gluten-flink/docs/Flink.md
+++ b/gluten-flink/docs/Flink.md
@@ -48,7 +48,7 @@ As some features have not been committed to upstream, you
have to use the follow
## fetch velox4j code
git clone -b gluten-0530 https://github.com/bigo-sg/velox4j.git
cd velox4j
-git reset --hard feb921eabe637bff88eda0fc753d36bbe422fe87
+git reset --hard 42a77de002707b6811791ba2d728f169aeb5d7bb
mvn clean install -DskipTests -Dgpg.skip -Dspotless.skip=true
```
**Get gluten**
diff --git
a/gluten-flink/runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerRunner.java
b/gluten-flink/runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerRunner.java
index 6d1afaecd4..cb4f5d9cc8 100644
---
a/gluten-flink/runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerRunner.java
+++
b/gluten-flink/runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerRunner.java
@@ -508,6 +508,9 @@ public class TaskManagerRunner implements FatalErrorHandler
{
StateChangelogStorageLoader.initialize(pluginManager);
// --- Begin Gluten-specific code changes ---
+ Velox4j.configure(
+ io.github.zhztheplayer.velox4j.config.Preset.KEY,
+ io.github.zhztheplayer.velox4j.config.Preset.FLINK);
Velox4j.initialize();
// --- End Gluten-specific code changes ---
diff --git
a/gluten-flink/ut/src/test/java/org/apache/gluten/table/runtime/stream/common/Velox4jEnvironment.java
b/gluten-flink/ut/src/test/java/org/apache/gluten/table/runtime/stream/common/Velox4jEnvironment.java
index b896819231..b3265c8353 100644
---
a/gluten-flink/ut/src/test/java/org/apache/gluten/table/runtime/stream/common/Velox4jEnvironment.java
+++
b/gluten-flink/ut/src/test/java/org/apache/gluten/table/runtime/stream/common/Velox4jEnvironment.java
@@ -17,6 +17,7 @@
package org.apache.gluten.table.runtime.stream.common;
import io.github.zhztheplayer.velox4j.Velox4j;
+import io.github.zhztheplayer.velox4j.config.Preset;
public class Velox4jEnvironment {
private static class Holder {
@@ -24,6 +25,7 @@ public class Velox4jEnvironment {
}
private Velox4jEnvironment() {
+ Velox4j.configure(Preset.KEY, Preset.FLINK);
Velox4j.initialize();
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
