This is an automated email from the ASF dual-hosted git repository.
snuyanzin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 6dec8b4af65 [FLINK-40680] Bump openai-java dependency to 4.63.1
6dec8b4af65 is described below
commit 6dec8b4af65211c71faa945683a4f816a7d5427c
Author: Sergey Nuyanzin <[email protected]>
AuthorDate: Wed Sep 16 13:29:03 2026 +0200
[FLINK-40680] Bump openai-java dependency to 4.63.1
---
flink-models/flink-model-openai/pom.xml | 2 +-
.../flink/model/openai/OpenAIEmbeddingModelFunction.java | 4 +---
.../flink-model-openai/src/main/resources/META-INF/NOTICE | 11 ++++++++---
.../model/openai/ModelFunctionErrorHandlingStrategyTest.java | 2 +-
4 files changed, 11 insertions(+), 8 deletions(-)
diff --git a/flink-models/flink-model-openai/pom.xml
b/flink-models/flink-model-openai/pom.xml
index c1f30521919..b34d2125259 100644
--- a/flink-models/flink-model-openai/pom.xml
+++ b/flink-models/flink-model-openai/pom.xml
@@ -33,7 +33,7 @@ under the License.
<name>Flink : Models : OpenAI</name>
<properties>
- <openai.version>1.6.1</openai.version>
+ <openai.version>4.63.1</openai.version>
<openai.kotlin.version>1.9.10</openai.kotlin.version>
<okhttp.version>4.12.0</okhttp.version>
<test.gson.version>2.11.0</test.gson.version>
diff --git
a/flink-models/flink-model-openai/src/main/java/org/apache/flink/model/openai/OpenAIEmbeddingModelFunction.java
b/flink-models/flink-model-openai/src/main/java/org/apache/flink/model/openai/OpenAIEmbeddingModelFunction.java
index dbe47fa69af..15007d34947 100644
---
a/flink-models/flink-model-openai/src/main/java/org/apache/flink/model/openai/OpenAIEmbeddingModelFunction.java
+++
b/flink-models/flink-model-openai/src/main/java/org/apache/flink/model/openai/OpenAIEmbeddingModelFunction.java
@@ -105,9 +105,7 @@ public class OpenAIEmbeddingModelFunction extends
AbstractOpenAIModelFunction {
rowData.setField(
outputColumnIndex,
new GenericArrayData(
- embedding.embedding().stream()
- .map(Double::floatValue)
- .toArray(Float[]::new)));
+
embedding.embedding().stream().toArray(Float[]::new)));
return rowData;
})
.collect(Collectors.toList());
diff --git a/flink-models/flink-model-openai/src/main/resources/META-INF/NOTICE
b/flink-models/flink-model-openai/src/main/resources/META-INF/NOTICE
index d76f10857e8..6f864d8759f 100644
--- a/flink-models/flink-model-openai/src/main/resources/META-INF/NOTICE
+++ b/flink-models/flink-model-openai/src/main/resources/META-INF/NOTICE
@@ -6,6 +6,7 @@ The Apache Software Foundation (http://www.apache.org/).
This project bundles the following dependencies under the Apache Software
License 2.0 (http://www.apache.org/licenses/LICENSE-2.0.txt)
+- com.fasterxml:classmate:1.7.0
- com.fasterxml.jackson.core:jackson-annotations:2.22
- com.fasterxml.jackson.core:jackson-core:2.22.2
- com.fasterxml.jackson.core:jackson-databind:2.22.2
@@ -13,9 +14,9 @@ This project bundles the following dependencies under the
Apache Software Licens
- com.fasterxml.jackson.datatype:jackson-datatype-jsr310:2.22.2
- com.fasterxml.jackson.module:jackson-module-kotlin:2.22.2
- com.google.errorprone:error_prone_annotations:2.33.0
-- com.openai:openai-java:1.6.1
-- com.openai:openai-java-client-okhttp:1.6.1
-- com.openai:openai-java-core:1.6.1
+- com.openai:openai-java:4.63.1
+- com.openai:openai-java-client-okhttp:4.63.1
+- com.openai:openai-java-core:4.63.1
- com.squareup.okhttp3:logging-interceptor:4.12.0
- com.squareup.okhttp3:okhttp:4.12.0
- com.squareup.okio:okio:3.6.0
@@ -29,6 +30,10 @@ This project bundles the following dependencies under the
Apache Software Licens
- org.jetbrains.kotlin:kotlin-stdlib-common:1.9.10
- org.jetbrains.kotlin:kotlin-stdlib-jdk7:1.9.10
- org.jetbrains.kotlin:kotlin-stdlib-jdk8:1.9.10
+- io.swagger.core.v3:swagger-annotations:2.2.31
+- com.github.victools:jsonschema-generator:4.38.0
+- com.github.victools:jsonschema-module-jackson:4.38.0
+- com.github.victools:jsonschema-module-swagger-2:4.38.0
This project bundles the following dependencies under the MIT
(https://opensource.org/licenses/MIT)
diff --git
a/flink-models/flink-model-openai/src/test/java/org/apache/flink/model/openai/ModelFunctionErrorHandlingStrategyTest.java
b/flink-models/flink-model-openai/src/test/java/org/apache/flink/model/openai/ModelFunctionErrorHandlingStrategyTest.java
index 066048fa2e3..c085fd569d8 100644
---
a/flink-models/flink-model-openai/src/test/java/org/apache/flink/model/openai/ModelFunctionErrorHandlingStrategyTest.java
+++
b/flink-models/flink-model-openai/src/test/java/org/apache/flink/model/openai/ModelFunctionErrorHandlingStrategyTest.java
@@ -201,7 +201,7 @@ public class ModelFunctionErrorHandlingStrategyTest {
assertThat(result.get(0).getArity()).isEqualTo(5);
assertThat((String)
result.get(0).getFieldAs(0)).isEqualTo(RETRYABLE_INPUT_DATA);
assertThat((String) result.get(0).getFieldAs(1))
- .isEqualTo("com.openai.errors.RateLimitException: 429: null");
+ .isEqualTo("com.openai.errors.RateLimitException: 429:
Unknown");
assertThat(result.get(0).getField(2)).isNull();
assertThat((Integer) result.get(0).getFieldAs(3)).isEqualTo(429);
assertThat((Map<String, String[]>) result.get(0).getFieldAs(4))
