This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 3b4fa6c424b [FLINK-34103][examples] Include flink-connector-datagen
for AsyncIO example and bundle it into the dist by default
3b4fa6c424b is described below
commit 3b4fa6c424b713398fbce21f5dfbfd0053231a87
Author: Zhanghao Chen <[email protected]>
AuthorDate: Sun Jan 28 00:43:18 2024 +0800
[FLINK-34103][examples] Include flink-connector-datagen for AsyncIO example
and bundle it into the dist by default
---
flink-examples/flink-examples-streaming/pom.xml | 60 +++++++++++++++----------
1 file changed, 36 insertions(+), 24 deletions(-)
diff --git a/flink-examples/flink-examples-streaming/pom.xml
b/flink-examples/flink-examples-streaming/pom.xml
index 04ad7e1adde..1168e8129c1 100644
--- a/flink-examples/flink-examples-streaming/pom.xml
+++ b/flink-examples/flink-examples-streaming/pom.xml
@@ -188,30 +188,6 @@ under the License.
</configuration>
</execution>
- <!-- Async I/O -->
- <execution>
- <id>AsyncIO</id>
- <phase>package</phase>
- <goals>
- <goal>jar</goal>
- </goals>
- <configuration>
-
<classifier>AsyncIO</classifier>
-
- <archive>
-
<manifestEntries>
-
<program-class>org.apache.flink.streaming.examples.async.AsyncIOExample</program-class>
-
</manifestEntries>
- </archive>
-
- <includes>
-
<include>org/apache/flink/streaming/examples/async/*.class</include>
-
<include>META-INF/LICENSE</include>
-
<include>META-INF/NOTICE</include>
- </includes>
- </configuration>
- </execution>
-
<!-- WordCount -->
<execution>
<id>WordCount</id>
@@ -274,6 +250,42 @@ under the License.
<createDependencyReducedPom>false</createDependencyReducedPom>
</configuration>
<executions>
+ <!-- Async I/O -->
+ <execution>
+ <id>AsyncIO</id>
+ <phase>package</phase>
+ <goals>
+ <goal>shade</goal>
+ </goals>
+ <configuration>
+
<shadeTestJar>false</shadeTestJar>
+
<finalName>AsyncIO</finalName>
+
<shadedArtifactAttached>true</shadedArtifactAttached>
+
<shadedClassifierName>AsyncIO</shadedClassifierName>
+ <artifactSet>
+ <includes>
+
<include>org.apache.flink:flink-connector-datagen</include>
+ </includes>
+ </artifactSet>
+ <filters>
+ <filter>
+
<artifact>org.apache.flink:*</artifact>
+
<includes>
+
<include>org/apache/flink/connector/datagen/**</include>
+
<include>org/apache/flink/streaming/examples/async/*.class</include>
+
<include>META-INF/LICENSE</include>
+
<include>META-INF/NOTICE</include>
+
</includes>
+ </filter>
+ </filters>
+ <transformers>
+ <transformer
implementation="org.apache.maven.plugins.shade.resource.ManifestResourceTransformer">
+
<mainClass>org.apache.flink.streaming.examples.async.AsyncIOExample</mainClass>
+ </transformer>
+ </transformers>
+ </configuration>
+ </execution>
+
<!-- MatrixVectorMul. It is not bundled
with Flink dist, nor deployed in Maven repo,
as it is platform-dependent. Users are
expected to compile and run it with custom
jcuda version specified by themselves
with the "jcuda.version" property.-->
