Skip to content

Commit 6893783

Browse files
committed
[FLINK-37389] Add flink-sql-connector-kudu module
1 parent a100b29 commit 6893783

File tree

4 files changed

+154
-11
lines changed

4 files changed

+154
-11
lines changed

flink-connector-kudu/pom.xml

+25-5
Original file line numberDiff line numberDiff line change
@@ -34,41 +34,61 @@ under the License.
3434
<packaging>jar</packaging>
3535

3636
<dependencies>
37-
<dependency>
38-
<groupId>org.apache.flink</groupId>
39-
<artifactId>flink-clients</artifactId>
40-
</dependency>
41-
4237
<dependency>
4338
<groupId>org.apache.flink</groupId>
4439
<artifactId>flink-streaming-java</artifactId>
40+
<scope>provided</scope>
4541
</dependency>
4642

4743
<dependency>
4844
<groupId>org.apache.flink</groupId>
4945
<artifactId>flink-table-api-java-bridge</artifactId>
46+
<scope>provided</scope>
5047
</dependency>
5148

5249
<dependency>
5350
<groupId>org.apache.flink</groupId>
5451
<artifactId>flink-table-common</artifactId>
52+
<scope>provided</scope>
5553
</dependency>
5654

5755
<dependency>
5856
<groupId>org.apache.flink</groupId>
5957
<artifactId>flink-table-planner-loader</artifactId>
58+
<scope>provided</scope>
6059
</dependency>
6160

6261
<dependency>
6362
<groupId>org.apache.flink</groupId>
6463
<artifactId>flink-table-runtime</artifactId>
64+
<scope>provided</scope>
6565
</dependency>
6666

6767
<dependency>
6868
<groupId>org.apache.kudu</groupId>
6969
<artifactId>kudu-client</artifactId>
7070
</dependency>
7171

72+
<dependency>
73+
<groupId>org.apache.flink</groupId>
74+
<artifactId>flink-test-utils</artifactId>
75+
<scope>test</scope>
76+
</dependency>
77+
78+
<dependency>
79+
<groupId>org.apache.flink</groupId>
80+
<artifactId>flink-test-utils-junit</artifactId>
81+
<scope>test</scope>
82+
</dependency>
83+
84+
<dependency>
85+
<groupId>org.apache.flink</groupId>
86+
<artifactId>flink-runtime</artifactId>
87+
<version>${flink.version}</version>
88+
<type>test-jar</type>
89+
<scope>test</scope>
90+
</dependency>
91+
7292
<dependency>
7393
<groupId>org.apache.kudu</groupId>
7494
<artifactId>kudu-test-utils</artifactId>

flink-sql-connector-kudu/pom.xml

+93
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,93 @@
1+
<?xml version="1.0" encoding="UTF-8"?>
2+
<!--
3+
Licensed to the Apache Software Foundation (ASF) under one
4+
or more contributor license agreements. See the NOTICE file
5+
distributed with this work for additional information
6+
regarding copyright ownership. The ASF licenses this file
7+
to you under the Apache License, Version 2.0 (the
8+
"License"); you may not use this file except in compliance
9+
with the License. You may obtain a copy of the License at
10+
11+
http://www.apache.org/licenses/LICENSE-2.0
12+
13+
Unless required by applicable law or agreed to in writing,
14+
software distributed under the License is distributed on an
15+
"AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
16+
KIND, either express or implied. See the License for the
17+
specific language governing permissions and limitations
18+
under the License.
19+
-->
20+
<project xmlns="http://maven.apache.org/POM/4.0.0"
21+
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
22+
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
23+
24+
<modelVersion>4.0.0</modelVersion>
25+
26+
<parent>
27+
<groupId>org.apache.flink</groupId>
28+
<artifactId>flink-connector-kudu-parent</artifactId>
29+
<version>2.0-SNAPSHOT</version>
30+
</parent>
31+
32+
<artifactId>flink-sql-connector-kudu</artifactId>
33+
<name>Flink : Connectors : SQL : Kudu</name>
34+
<packaging>jar</packaging>
35+
36+
<dependencies>
37+
<dependency>
38+
<groupId>org.apache.flink</groupId>
39+
<artifactId>flink-connector-kudu</artifactId>
40+
<version>${project.version}</version>
41+
</dependency>
42+
</dependencies>
43+
44+
<build>
45+
<plugins>
46+
<plugin>
47+
<groupId>org.apache.maven.plugins</groupId>
48+
<artifactId>maven-shade-plugin</artifactId>
49+
<executions>
50+
<execution>
51+
<id>shade-flink</id>
52+
<phase>package</phase>
53+
<goals>
54+
<goal>shade</goal>
55+
</goals>
56+
<configuration>
57+
<artifactSet>
58+
<includes>
59+
<include>*:*</include>
60+
</includes>
61+
<excludes>
62+
<exclude>com.google.code.findbugs:jsr305</exclude>
63+
<exclude>org.apache.yetus:*</exclude>
64+
<exclude>org.slf4j:*</exclude>
65+
</excludes>
66+
</artifactSet>
67+
<filters>
68+
<filter>
69+
<artifact>*:*</artifact>
70+
<excludes>
71+
<exclude>META-INF/native/libnetty**</exclude>
72+
<exclude>META-INF/native-image/**</exclude>
73+
<exclude>META-INF/services/reactor.blockhound.integration.BlockHoundIntegration</exclude>
74+
<exclude>META-INF/io.netty.versions.properties</exclude>
75+
<exclude>META-INF/micrometer-core.properties</exclude>
76+
<exclude>META-INF/LICENSE.txt</exclude>
77+
</excludes>
78+
</filter>
79+
</filters>
80+
<relocations>
81+
<relocation>
82+
<pattern>org.apache.kudu</pattern>
83+
<shadedPattern>org.apache.flink.kudu.shaded.org.apache.kudu</shadedPattern>
84+
</relocation>
85+
</relocations>
86+
</configuration>
87+
</execution>
88+
</executions>
89+
</plugin>
90+
</plugins>
91+
</build>
92+
93+
</project>
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,13 @@
1+
flink-sql-connector-kudu
2+
Copyright 2014-2025 The Apache Software Foundation
3+
4+
This product includes software developed at
5+
The Apache Software Foundation (http://www.apache.org/).
6+
7+
This project bundles the following dependencies under the Apache Software License 2.0. (http://www.apache.org/licenses/LICENSE-2.0.txt)
8+
9+
- org.apache.kudu:kudu-client:1.17.1
10+
11+
This project bundles the following dependencies under the BSD-3 license (https://opensource.org/license/BSD-3-Clause).
12+
13+
- com.stumbleupon:async:1.4.1

pom.xml

+23-6
Original file line numberDiff line numberDiff line change
@@ -74,6 +74,7 @@ under the License.
7474

7575
<modules>
7676
<module>flink-connector-kudu</module>
77+
<module>flink-sql-connector-kudu</module>
7778
</modules>
7879

7980
<dependencies>
@@ -116,12 +117,6 @@ under the License.
116117
<!-- This section defines the module versions that are used if nothing else is specified. -->
117118
<dependencyManagement>
118119
<dependencies>
119-
<dependency>
120-
<groupId>org.apache.flink</groupId>
121-
<artifactId>flink-clients</artifactId>
122-
<version>${flink.version}</version>
123-
</dependency>
124-
125120
<dependency>
126121
<groupId>org.apache.flink</groupId>
127122
<artifactId>flink-streaming-java</artifactId>
@@ -156,6 +151,22 @@ under the License.
156151
<groupId>org.apache.flink</groupId>
157152
<artifactId>flink-test-utils</artifactId>
158153
<version>${flink.version}</version>
154+
<exclusions>
155+
<exclusion>
156+
<groupId>org.apache.yetus</groupId>
157+
<artifactId>audience-annotations</artifactId>
158+
</exclusion>
159+
<exclusion>
160+
<groupId>org.xerial.snappy</groupId>
161+
<artifactId>snappy-java</artifactId>
162+
</exclusion>
163+
</exclusions>
164+
</dependency>
165+
166+
<dependency>
167+
<groupId>org.apache.flink</groupId>
168+
<artifactId>flink-test-utils-junit</artifactId>
169+
<version>${flink.version}</version>
159170
</dependency>
160171

161172
<!-- Flink ArchUnit -->
@@ -254,6 +265,12 @@ under the License.
254265
<version>2.24.0</version>
255266
</dependency>
256267

268+
<dependency>
269+
<groupId>org.apache.commons</groupId>
270+
<artifactId>commons-compress</artifactId>
271+
<version>1.26.0</version>
272+
</dependency>
273+
257274
<dependency>
258275
<groupId>org.apache.commons</groupId>
259276
<artifactId>commons-lang3</artifactId>

0 commit comments

Comments
 (0)