[FLINK-34103][examples] Include flink-connector-datagen for AsyncIO example and bundle it into the dist by default

[X-czh]

What is the purpose of the change

Include flink-connector-datagen for AsyncIO example to fix dep missing problem and bundle it into the dist by default.

Brief change log

• Use maven shade to package AsyncIO example instead, including flink-connector-datagen deps.

Note that it was not bundled with the dist previously because we will only bundle those example jars with shortened names using the rewrite rule:

<!--simplify the name of example JARs for build-target/examples -->
			<plugin>
				<groupId>org.apache.maven.plugins</groupId>
				<artifactId>maven-antrun-plugin</artifactId>
				<executions>
					<execution>
						<id>rename</id>
						<configuration>
							<target>
								<copy file="${project.basedir}/target/flink-examples-streaming-${project.version}-WindowJoin.jar" tofile="${project.basedir}/target/WindowJoin.jar" />
								<copy file="${project.basedir}/target/flink-examples-streaming-${project.version}-WordCount.jar" tofile="${project.basedir}/target/WordCount.jar" />
								<copy file="${project.basedir}/target/flink-examples-streaming-${project.version}-SocketWindowWordCount.jar" tofile="${project.basedir}/target/SocketWindowWordCount.jar" />
							</target>
						</configuration>
					</execution>
				</executions>
			</plugin>

This change also integrates the name rewriting rule in the shade plugin config so that it is bundled by default.

Verifying this change

Manually verified it by submitting it to a standalone cluster. Note that since the AsyncIO example itself mocks instable connection randomly, the job will soon fail on its own.

Does this pull request potentially affect one of the following parts:

• Dependencies (does it add or upgrade a dependency): (yes / no) no
• The public API, i.e., is any changed class annotated with @Public(Evolving): (yes / no) no
• The serializers: (yes / no / don't know) no
• The runtime per-record code paths (performance sensitive): (yes / no / don't know) no
• Anything that affects deployment or recovery: JobManager (and its components), Checkpointing, Kubernetes/Yarn, ZooKeeper: (yes / no / don't know) no
• The S3 file system connector: (yes / no / don't know) no

Documentation

• Does this pull request introduce a new feature? (yes / no) no
• If yes, how is the feature documented? (not applicable / docs / JavaDocs / not documented) not applicable

[flinkbot]

CI report:

• 96770db Azure: SUCCESS

Bot commands

The @flinkbot bot supports the following commands:

• @flinkbot run azure re-run the last Azure build

[JunRuiLee]

@X-czh Thanks for contribution, nice work. LGTM

[reswqa]

Thanks for the fix. Could you please resolve the conflict also?

[X-czh]

@reswqa Rebased, could you help merge it?