Skip to content

Commit 3dff34f

Browse files
committed
Add Flink2 support for pipeline source connector.
1 parent 85a930a commit 3dff34f

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/test/java/org/apache/flink/cdc/connectors/postgres/table/PostgreSQLConnectorITCase.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -34,6 +34,7 @@
3434
import org.junit.jupiter.api.AfterAll;
3535
import org.junit.jupiter.api.BeforeAll;
3636
import org.junit.jupiter.api.Test;
37+
import org.junit.jupiter.api.condition.DisabledIfSystemProperty;
3738
import org.junit.jupiter.api.extension.RegisterExtension;
3839
import org.junit.jupiter.params.ParameterizedTest;
3940
import org.junit.jupiter.params.provider.ValueSource;
@@ -55,6 +56,7 @@
5556
import static org.testcontainers.containers.PostgreSQLContainer.POSTGRESQL_PORT;
5657

5758
/** Integration tests for PostgreSQL Table source. */
59+
@DisabledIfSystemProperty(named = "flink.profile", matches = "flink2")
5860
class PostgreSQLConnectorITCase extends PostgresTestBase {
5961

6062
private final StreamExecutionEnvironment env =

0 commit comments

Comments
 (0)