This is an automated email from the ASF dual-hosted git repository. kunni pushed a commit to branch FLINK-38729-2 in repository https://gitbox.apache.org/repos/asf/flink-cdc.git
commit 557cd42c556bd0f3a9b255cf2973b3ab624c50af Author: lvyanquan <[email protected]> AuthorDate: Mon Mar 9 12:47:15 2026 +0800 Fix CI failure. --- .../flink/cdc/composer/flink/translator/DataSinkTranslator.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/translator/DataSinkTranslator.java b/flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/translator/DataSinkTranslator.java index 8a6bde5d1..c53d9f275 100644 --- a/flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/translator/DataSinkTranslator.java +++ b/flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/translator/DataSinkTranslator.java @@ -119,9 +119,7 @@ public class DataSinkTranslator { // Get sink provider EventSinkProvider eventSinkProvider = dataSink.getEventSinkProvider(); if (eventSinkProvider == null) { - throw new IllegalStateException( - "DataSink#getEventSinkProvider() must not return null. " - + "Please ensure the sink is correctly configured."); + return; } String sinkName = generateSinkName(sinkDef); if (eventSinkProvider instanceof FlinkSinkProvider) {
