diff --git a/flink-cdc-composer/src/test/java/org/apache/flink/cdc/composer/flink/FlinkPipelineTransformITCase.java b/flink-cdc-composer/src/test/java/org/apache/flink/cdc/composer/flink/FlinkPipelineTransformITCase.java
index 77f89a37a4f..64057683efd 100644
--- a/flink-cdc-composer/src/test/java/org/apache/flink/cdc/composer/flink/FlinkPipelineTransformITCase.java
+++ b/flink-cdc-composer/src/test/java/org/apache/flink/cdc/composer/flink/FlinkPipelineTransformITCase.java
@@ -220,6 +220,7 @@ void testTransformWithTemporalFunction() throws Exception {
                                         null,
                                         null,
                                         null)),
+                        Collections.emptyList(),
                         pipelineConfig);
 
         // Execute the pipeline