You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by sh...@apache.org on 2025/12/08 01:53:24 UTC
(flink) branch release-2.2 updated (ad477178625 -> 8de272c7d96)
This is an automated email from the ASF dual-hosted git repository.
shengkai pushed a change to branch release-2.2
in repository https://gitbox.apache.org/repos/asf/flink.git
from ad477178625 [FLINK-38750][table] Validation of queries with functions erroneously invoked under `SELECT` fails with `StackOverflow`
new 3f79fac6080 [FLINK-38084][doc] Add download doc for model providers (#27296)
new 3546641020a [FLINK-38767][table] Fix vector search execnode transform name (#27304)
new 8de272c7d96 [FLINK-38773][table] Fix batch vector search excnode context (#27311)
The 3 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../docs/connectors/{table => models}/downloads.md | 15 ++++-----------
.../docs/connectors/{table => models}/downloads.md | 16 +++++-----------
.../archetype.properties => docs/data/sql_models.yml | 11 ++++++-----
...optional_connectors.html => sql_optional_models.html} | 7 ++++---
.../exec/batch/BatchExecVectorSearchTableFunction.java | 8 +++-----
.../exec/stream/StreamExecVectorSearchTableFunction.java | 2 +-
.../table/planner/plan/utils/ExecNodeMetadataUtil.java | 2 ++
.../async-vector-search/plan/async-vector-search.json | 4 ++--
.../sync-vector-search/plan/sync-vector-search.json | 4 ++--
.../plan/vector-search-with-runtime-config.json | 4 ++--
10 files changed, 31 insertions(+), 42 deletions(-)
copy docs/content.zh/docs/connectors/{table => models}/downloads.md (78%)
copy docs/content/docs/connectors/{table => models}/downloads.md (75%)
copy flink-quickstart/flink-quickstart-java/src/test/resources/projects/testArtifact/archetype.properties => docs/data/sql_models.yml (78%)
copy docs/layouts/shortcodes/{sql_optional_connectors.html => sql_optional_models.html} (94%)
(flink) 02/03: [FLINK-38767][table] Fix vector search execnode transform name (#27304)
Posted by sh...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
shengkai pushed a commit to branch release-2.2
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 3546641020afb5563ef708dd5fc288cfd9f80f7d
Author: Hao Li <11...@users.noreply.github.com>
AuthorDate: Wed Dec 3 17:35:08 2025 -0800
[FLINK-38767][table] Fix vector search execnode transform name (#27304)
---
.../plan/nodes/exec/batch/BatchExecVectorSearchTableFunction.java | 3 +--
.../plan/nodes/exec/stream/StreamExecVectorSearchTableFunction.java | 2 +-
2 files changed, 2 insertions(+), 3 deletions(-)
diff --git a/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecVectorSearchTableFunction.java b/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecVectorSearchTableFunction.java
index 51f32a685c5..6fcbc4ec4b5 100644
--- a/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecVectorSearchTableFunction.java
+++ b/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecVectorSearchTableFunction.java
@@ -28,7 +28,6 @@ import org.apache.flink.table.planner.plan.nodes.exec.SingleTransformationTransl
import org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecVectorSearchTableFunction;
import org.apache.flink.table.planner.plan.nodes.exec.spec.VectorSearchSpec;
import org.apache.flink.table.planner.plan.nodes.exec.spec.VectorSearchTableSourceSpec;
-import org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecMLPredictTableFunction;
import org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecVectorSearchTableFunction;
import org.apache.flink.table.planner.plan.utils.FunctionCallUtil;
import org.apache.flink.table.types.logical.RowType;
@@ -50,7 +49,7 @@ import java.util.List;
"table.exec.async-vector-search.timeout",
"table.exec.async-vector-search.output-mode"
},
- producedTransformations = StreamExecMLPredictTableFunction.ML_PREDICT_TRANSFORMATION,
+ producedTransformations = CommonExecVectorSearchTableFunction.VECTOR_SEARCH_TRANSFORMATION,
minPlanVersion = FlinkVersion.v2_2,
minStateVersion = FlinkVersion.v2_2)
public class BatchExecVectorSearchTableFunction extends CommonExecVectorSearchTableFunction
diff --git a/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecVectorSearchTableFunction.java b/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecVectorSearchTableFunction.java
index 101a58dabde..849a6b68788 100644
--- a/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecVectorSearchTableFunction.java
+++ b/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecVectorSearchTableFunction.java
@@ -49,7 +49,7 @@ import java.util.List;
"table.exec.async-vector-search.timeout",
"table.exec.async-vector-search.output-mode"
},
- producedTransformations = StreamExecMLPredictTableFunction.ML_PREDICT_TRANSFORMATION,
+ producedTransformations = CommonExecVectorSearchTableFunction.VECTOR_SEARCH_TRANSFORMATION,
minPlanVersion = FlinkVersion.v2_2,
minStateVersion = FlinkVersion.v2_2)
public class StreamExecVectorSearchTableFunction extends CommonExecVectorSearchTableFunction
(flink) 01/03: [FLINK-38084][doc] Add download doc for model providers (#27296)
Posted by sh...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
shengkai pushed a commit to branch release-2.2
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 3f79fac6080a77356d3f7c9e705e83955978da7e
Author: Hao Li <11...@users.noreply.github.com>
AuthorDate: Tue Dec 2 18:27:45 2025 -0800
[FLINK-38084][doc] Add download doc for model providers (#27296)
---
.../content.zh/docs/connectors/models/downloads.md | 41 +++++++++++++
docs/content/docs/connectors/models/downloads.md | 42 ++++++++++++++
docs/data/sql_models.yml | 22 +++++++
docs/layouts/shortcodes/sql_optional_models.html | 67 ++++++++++++++++++++++
4 files changed, 172 insertions(+)
diff --git a/docs/content.zh/docs/connectors/models/downloads.md b/docs/content.zh/docs/connectors/models/downloads.md
new file mode 100644
index 00000000000..0eb85a304aa
--- /dev/null
+++ b/docs/content.zh/docs/connectors/models/downloads.md
@@ -0,0 +1,41 @@
+---
+title: 下载页面
+weight: 100
+type: docs
+bookToc: false
+aliases:
+ - /zh/dev/table/connectors/downloads.html
+---
+<!--
+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.
+-->
+
+# SQL Models 下载页面
+
+{{< unstable >}}
+{{< hint info >}}
+Download links are available only for stable releases.
+{{< /hint >}}
+{{< /unstable >}}
+
+The page contains links to optional sql-client models that are not part of the binary distribution.
+
+# 可选的 SQL Models
+-------------------
+
+{{< sql_optional_models >}}
diff --git a/docs/content/docs/connectors/models/downloads.md b/docs/content/docs/connectors/models/downloads.md
new file mode 100644
index 00000000000..6b5119f333a
--- /dev/null
+++ b/docs/content/docs/connectors/models/downloads.md
@@ -0,0 +1,42 @@
+---
+title: Download
+weight: 100
+type: docs
+bookToc: false
+aliases:
+ - /dev/table/models/downloads.html
+---
+<!--
+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.
+-->
+
+# SQL Models download page
+
+{{< unstable >}}
+{{< hint info >}}
+Download links are available only for stable releases.
+{{< /hint >}}
+{{< /unstable >}}
+
+The page contains links to optional SQL Client models that are not part of the binary distribution.
+
+# Optional SQL models
+-------------------
+
+{{< sql_optional_models >}}
+
diff --git a/docs/data/sql_models.yml b/docs/data/sql_models.yml
new file mode 100644
index 00000000000..74cd32b1e87
--- /dev/null
+++ b/docs/data/sql_models.yml
@@ -0,0 +1,22 @@
+# 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
+
+openai:
+ name: OpenAI
+ category: model
+ maven: flink-model-openai
+ sql_url: https://repo.maven.apache.org/maven2/org/apache/flink/flink-model-openai/$version/flink-model-openai-$version.jar
diff --git a/docs/layouts/shortcodes/sql_optional_models.html b/docs/layouts/shortcodes/sql_optional_models.html
new file mode 100644
index 00000000000..ad93dbc9814
--- /dev/null
+++ b/docs/layouts/shortcodes/sql_optional_models.html
@@ -0,0 +1,67 @@
+{{/*
+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.
+*/}}{{/*
+ Generates the SQL download model table.
+*/}}
+
+<table class="table table-bordered">
+ <thead>
+ <tr>
+ <th style="text-align: left">Name</th>
+ <th style="text-align: left">Version</th>
+ <th style="text-align: left">Download Link</th>
+ </tr>
+ </thead>
+ <tbody>
+ {{ range .Site.Data.sql_models }}
+ {{ if eq .category "model" }}{{ if eq .builtin nil }}
+ {{ if eq .versions nil }}
+ <tr>
+ <td style="text-align: left">{{- .name -}}</td>
+ <td></td>
+ <td style="text-align: left">
+ {{ if $.Site.Params.IsStable }}
+ <a href="{{- partial "docs/interpolate" .sql_url -}}">Download</a>
+ (<a href="{{- partial "docs/interpolate" .sql_url -}}.asc">asc</a>,
+ <a href="{{- partial "docs/interpolate" .sql_url -}}.sha1">sha1</a>) </td>
+ {{ else }}
+ Only available for stable versions.</td>
+ {{ end }}
+ </tr>
+ {{ else }}
+ {{ $name := .name }}
+ {{ range .versions }}
+ <tr>
+ <td style="text-align: left">{{- $name -}}</td>
+ <td>{{- .version -}}</td>
+ <td style="text-align: left">
+ {{ if $.Site.Params.IsStable }}
+ <a href="{{- partial "docs/interpolate" .sql_url -}}">Download</a>
+ (<a href="{{- partial "docs/interpolate" .sql_url -}}.asc">asc</a>,
+ <a href="{{- partial "docs/interpolate" .sql_url -}}.sha1">sha1</a>) </td>
+ {{ else }}
+ Only available for stable versions.</td>
+ {{ end }}
+ </tr>
+ {{ end }}
+ {{ end }}
+ {{ end }}{{ end }}
+ {{ end }}
+ </tbody>
+</table>
+