Add Flink2 support for pipeline source connector.

Author: lvyanquan

flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/MySqlToDorisE2eITCase.java

@@ -27,6 +27,7 @@
 import org.junit.jupiter.api.BeforeAll;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.condition.EnabledIfSystemProperty;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.testcontainers.containers.wait.strategy.LogMessageWaitStrategy;
@@ -49,6 +50,7 @@
 import java.util.stream.Stream;
 
 /** End-to-end tests for mysql cdc to Doris pipeline job. */
+@EnabledIfSystemProperty(named = "specifiedFlinkVersion", matches = "^1.*")
 class MySqlToDorisE2eITCase extends PipelineTestEnvironment {
     private static final Logger LOG = LoggerFactory.getLogger(MySqlToDorisE2eITCase.class);