Skip to content

Commit fe74aa3

Browse files
yuxiqian.yxqlvyanquan
authored andcommitted
[FLINK-35888][cdc-connector][paimon] Add e2e test for Paimon Sink.
1 parent 7025537 commit fe74aa3

File tree

6 files changed

+548
-11
lines changed

6 files changed

+548
-11
lines changed

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/pom.xml

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -285,6 +285,19 @@ limitations under the License.
285285
</execution>
286286
</executions>
287287
</plugin>
288+
289+
<plugin>
290+
<groupId>org.apache.maven.plugins</groupId>
291+
<artifactId>maven-jar-plugin</artifactId>
292+
<executions>
293+
<execution>
294+
<id>test-jar</id>
295+
<goals>
296+
<goal>test-jar</goal>
297+
</goals>
298+
</execution>
299+
</executions>
300+
</plugin>
288301
</plugins>
289302
</build>
290303

flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/pom.xml

Lines changed: 41 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,6 +32,7 @@ limitations under the License.
3232
<flink-1.20>1.20.0</flink-1.20>
3333
<mysql.driver.version>8.0.27</mysql.driver.version>
3434
<starrocks.connector.version>1.2.10_flink-${flink.major.version}</starrocks.connector.version>
35+
<paimon.version>0.8.2</paimon.version>
3536
</properties>
3637

3738
<dependencies>
@@ -98,6 +99,19 @@ limitations under the License.
9899
<type>test-jar</type>
99100
<scope>test</scope>
100101
</dependency>
102+
<dependency>
103+
<groupId>org.apache.flink</groupId>
104+
<artifactId>flink-cdc-pipeline-connector-paimon</artifactId>
105+
<version>${project.version}</version>
106+
<type>test-jar</type>
107+
<scope>test</scope>
108+
</dependency>
109+
<dependency>
110+
<groupId>org.apache.paimon</groupId>
111+
<artifactId>paimon-flink-${flink.major.version}</artifactId>
112+
<version>${paimon.version}</version>
113+
<scope>test</scope>
114+
</dependency>
101115
<dependency>
102116
<groupId>org.apache.flink</groupId>
103117
<artifactId>flink-connector-test-util</artifactId>
@@ -184,7 +198,6 @@ limitations under the License.
184198
</executions>
185199
<configuration>
186200
<artifactItems>
187-
188201
<artifactItem>
189202
<groupId>mysql</groupId>
190203
<artifactId>mysql-connector-java</artifactId>
@@ -244,6 +257,33 @@ limitations under the License.
244257
<outputDirectory>${project.build.directory}/dependencies
245258
</outputDirectory>
246259
</artifactItem>
260+
<artifactItem>
261+
<groupId>org.apache.flink</groupId>
262+
<artifactId>flink-cdc-pipeline-connector-paimon</artifactId>
263+
<version>${project.version}</version>
264+
<destFileName>paimon-cdc-pipeline-connector.jar</destFileName>
265+
<type>jar</type>
266+
<outputDirectory>${project.build.directory}/dependencies
267+
</outputDirectory>
268+
</artifactItem>
269+
<artifactItem>
270+
<groupId>org.apache.flink</groupId>
271+
<artifactId>flink-shaded-hadoop-2-uber</artifactId>
272+
<version>2.8.3-10.0</version>
273+
<destFileName>flink-shade-hadoop.jar</destFileName>
274+
<type>jar</type>
275+
<outputDirectory>${project.build.directory}/dependencies
276+
</outputDirectory>
277+
</artifactItem>
278+
<artifactItem>
279+
<groupId>org.apache.paimon</groupId>
280+
<artifactId>paimon-flink-${flink.major.version}</artifactId>
281+
<version>${paimon.version}</version>
282+
<destFileName>paimon-sql-connector.jar</destFileName>
283+
<type>jar</type>
284+
<outputDirectory>${project.build.directory}/dependencies
285+
</outputDirectory>
286+
</artifactItem>
247287

248288
<artifactItem>
249289
<groupId>org.apache.flink</groupId>

0 commit comments

Comments
 (0)