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();