This is an automated email from the ASF dual-hosted git repository.
ruanhang1993 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git
The following commit(s) were added to refs/heads/master by this push:
new 1fb68a8d6 [FLINK-35325][transform] Skip insufficient_quota error when
running test case using ad model. (#3849)
1fb68a8d6 is described below
commit 1fb68a8d62c13c77276d90751e48d9b19e35a080
Author: Kunni <lvyanquan....@alibaba-inc.com>
AuthorDate: Fri Jan 10 18:54:25 2025 +0800
[FLINK-35325][transform] Skip insufficient_quota error when running test
case using ad model. (#3849)
---
.../org/apache/flink/cdc/composer/flink/FlinkPipelineUdfITCase.java | 2 ++
.../java/org/apache/flink/cdc/runtime/model/TestOpenAIChatModel.java | 2 ++
.../org/apache/flink/cdc/runtime/model/TestOpenAIEmbeddingModel.java | 2 ++
3 files changed, 6 insertions(+)
diff --git
a/flink-cdc-composer/src/test/java/org/apache/flink/cdc/composer/flink/FlinkPipelineUdfITCase.java
b/flink-cdc-composer/src/test/java/org/apache/flink/cdc/composer/flink/FlinkPipelineUdfITCase.java
index 5cf424cd3..f3161105e 100644
---
a/flink-cdc-composer/src/test/java/org/apache/flink/cdc/composer/flink/FlinkPipelineUdfITCase.java
+++
b/flink-cdc-composer/src/test/java/org/apache/flink/cdc/composer/flink/FlinkPipelineUdfITCase.java
@@ -40,6 +40,7 @@ import
org.apache.flink.shaded.guava31.com.google.common.collect.ImmutableMap;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.extension.RegisterExtension;
import org.junit.jupiter.params.ParameterizedTest;
import org.junit.jupiter.params.provider.Arguments;
@@ -839,6 +840,7 @@ public class FlinkPipelineUdfITCase {
@ParameterizedTest
@MethodSource("testParams")
+ @Disabled("For manual test as there is a limit for quota.")
void testTransformWithModel(ValuesDataSink.SinkApi sinkApi) throws
Exception {
FlinkPipelineComposer composer = FlinkPipelineComposer.ofMiniCluster();
diff --git
a/flink-cdc-pipeline-model/src/test/java/org/apache/flink/cdc/runtime/model/TestOpenAIChatModel.java
b/flink-cdc-pipeline-model/src/test/java/org/apache/flink/cdc/runtime/model/TestOpenAIChatModel.java
index bba2d8b25..cf275935d 100644
---
a/flink-cdc-pipeline-model/src/test/java/org/apache/flink/cdc/runtime/model/TestOpenAIChatModel.java
+++
b/flink-cdc-pipeline-model/src/test/java/org/apache/flink/cdc/runtime/model/TestOpenAIChatModel.java
@@ -21,11 +21,13 @@ import
org.apache.flink.cdc.common.configuration.Configuration;
import org.apache.flink.cdc.common.udf.UserDefinedFunctionContext;
import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;
/** A test for {@link OpenAIChatModel}. */
public class TestOpenAIChatModel {
@Test
+ @Disabled("For manual test as there is a limit for quota.")
public void testEval() {
OpenAIChatModel openAIChatModel = new OpenAIChatModel();
Configuration configuration = new Configuration();
diff --git
a/flink-cdc-pipeline-model/src/test/java/org/apache/flink/cdc/runtime/model/TestOpenAIEmbeddingModel.java
b/flink-cdc-pipeline-model/src/test/java/org/apache/flink/cdc/runtime/model/TestOpenAIEmbeddingModel.java
index 118fb5628..f6003dd0a 100644
---
a/flink-cdc-pipeline-model/src/test/java/org/apache/flink/cdc/runtime/model/TestOpenAIEmbeddingModel.java
+++
b/flink-cdc-pipeline-model/src/test/java/org/apache/flink/cdc/runtime/model/TestOpenAIEmbeddingModel.java
@@ -22,12 +22,14 @@ import org.apache.flink.cdc.common.data.ArrayData;
import org.apache.flink.cdc.common.udf.UserDefinedFunctionContext;
import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;
/** A test for {@link OpenAIEmbeddingModel}. */
public class TestOpenAIEmbeddingModel {
@Test
+ @Disabled("For manual test as there is a limit for quota.")
public void testEval() {
OpenAIEmbeddingModel openAIEmbeddingModel = new OpenAIEmbeddingModel();
Configuration configuration = new Configuration();
