Skip to content

Commit b48d8eb

Browse files
authored
Add flink-cdc-flink*-compat to output t jar for source connector. (apache#4361)
Signed-off-by: Pei Yu <125331682@qq.com>
1 parent 1a1e81c commit b48d8eb

8 files changed

Lines changed: 35 additions & 0 deletions

File tree

flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-mongodb-cdc/pom.xml

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -59,6 +59,7 @@ limitations under the License.
5959
<include>org.apache.flink:flink-cdc-common</include>
6060
<include>org.apache.flink:flink-connector-debezium</include>
6161
<include>org.apache.flink:flink-connector-mongodb-cdc</include>
62+
<include>org.apache.flink:flink-cdc-flink*-compat</include>
6263
<include>org.mongodb.kafka:mongo-kafka-connect</include>
6364
<include>org.mongodb:mongodb-driver-sync</include>
6465
<include>org.mongodb:mongodb-driver-core</include>

flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-mysql-cdc/pom.xml

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -60,6 +60,7 @@ limitations under the License.
6060
<include>org.apache.flink:flink-cdc-common</include>
6161
<include>org.apache.flink:flink-connector-debezium</include>
6262
<include>org.apache.flink:flink-connector-mysql-cdc</include>
63+
<include>org.apache.flink:flink-cdc-flink*-compat</include>
6364
<include>org.antlr:antlr4-runtime</include>
6465
<include>org.apache.kafka:*</include>
6566
<include>com.zendesk:mysql-binlog-connector-java</include>

flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-oceanbase-cdc/pom.xml

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -66,6 +66,7 @@ limitations under the License.
6666
<include>org.apache.flink:flink-cdc-common</include>
6767
<include>org.apache.flink:flink-connector-debezium</include>
6868
<include>org.apache.flink:flink-connector-mysql-cdc</include>
69+
<include>org.apache.flink:flink-cdc-flink*-compat</include>
6970
<include>org.antlr:antlr4-runtime</include>
7071
<include>org.apache.kafka:*</include>
7172
<include>com.zendesk:mysql-binlog-connector-java</include>

flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-oracle-cdc/pom.xml

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -61,6 +61,7 @@ limitations under the License.
6161
<include>org.apache.flink:flink-cdc-base</include>
6262
<include>org.apache.flink:flink-cdc-common</include>
6363
<include>org.apache.flink:flink-connector-oracle-cdc</include>
64+
<include>org.apache.flink:flink-cdc-flink*-compat</include>
6465
<include>org.antlr:antlr4-runtime</include>
6566
<include>com.github.jsqlparser:jsqlparser</include>
6667
<include>org.apache.kafka:*</include>

flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-postgres-cdc/pom.xml

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -60,6 +60,7 @@ limitations under the License.
6060
<include>org.apache.flink:flink-cdc-common</include>
6161
<include>org.apache.flink:flink-connector-debezium</include>
6262
<include>org.apache.flink:flink-connector-postgres-cdc</include>
63+
<include>org.apache.flink:flink-cdc-flink*-compat</include>
6364
<include>com.zaxxer:HikariCP</include>
6465
<include>com.google.protobuf:protobuf-java</include>
6566
<include>com.google.guava:*</include>

flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-sqlserver-cdc/pom.xml

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -60,6 +60,7 @@ limitations under the License.
6060
<include>org.apache.flink:flink-cdc-base</include>
6161
<include>org.apache.flink:flink-cdc-common</include>
6262
<include>org.apache.flink:flink-connector-sqlserver-cdc</include>
63+
<include>org.apache.flink:flink-cdc-flink*-compat</include>
6364
<include>com.microsoft.sqlserver:*</include>
6465
<include>org.apache.kafka:*</include>
6566
<include>com.fasterxml.*:*</include>

flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-tidb-cdc/pom.xml

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -55,6 +55,7 @@ limitations under the License.
5555
<include>org.apache.flink:flink-connector-debezium</include>
5656
<include>org.apache.flink:flink-connector-tidb-cdc</include>
5757
<include>org.tikv:tikv-client-java</include>
58+
<include>org.apache.flink:flink-cdc-flink*-compat</include>
5859
<include>com.google.protobuf:*</include>
5960
<include>io.grpc:*</include>
6061
<!-- Include fixed version 30.1.1-jre-14.0 of flink shaded guava -->

flink-cdc-connect/flink-cdc-source-connectors/pom.xml

Lines changed: 28 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -76,4 +76,32 @@ limitations under the License.
7676
</dependency>
7777
</dependencies>
7878

79+
<profiles>
80+
<!-- Default profile: use flink-cdc-flink1-compat -->
81+
<profile>
82+
<id>flink1</id>
83+
<activation>
84+
<activeByDefault>true</activeByDefault>
85+
</activation>
86+
<dependencies>
87+
<dependency>
88+
<groupId>org.apache.flink</groupId>
89+
<artifactId>flink-cdc-flink1-compat</artifactId>
90+
<version>${project.version}</version>
91+
</dependency>
92+
</dependencies>
93+
</profile>
94+
<!-- Flink 2 profile: use flink-cdc-flink2-compat -->
95+
<profile>
96+
<id>flink2</id>
97+
<dependencies>
98+
<dependency>
99+
<groupId>org.apache.flink</groupId>
100+
<artifactId>flink-cdc-flink2-compat</artifactId>
101+
<version>${project.version}</version>
102+
</dependency>
103+
</dependencies>
104+
</profile>
105+
</profiles>
106+
79107
</project>

0 commit comments

Comments
 (0)