Apache Flink源码阅读环境搭建

Posted 终回首

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了Apache Flink源码阅读环境搭建相关的知识，希望对你有一定的参考价值。

目录

版本
win7
jdk 1.8
maven 3.6.3
scala 2.11.8

这些必须提前安装好

1 下载源码

# 下载源码
git clone https://github.com/apache/spark.git
# flink是用branch区分不同版本的，切换到目标版本
 git checkout -b release1.13 remotes/origin/release-1.13

2 编译打包

在项目根目录打开Git Bash
运行如下命令

# 设置大一点的内存，防止内存溢出
export MAVEN_OPTS="-Xmx2g -XX:ReservedCodeCacheSize=512m"
# 执行打包命令，这里只是阅读源码所以用快速打包
mvn clean install -DskipTests -Dfast

打包完成

3 导入项目
File
New
Project from existing Sources...
选择clone的项目根目录
点击OK

4 debug

1.运行
双击shift搜索WordCount.scala，右键Run 'WordCount'

这里可能会报个错

点击Edit Configurations…，修改如下参数

  • Before lauch:Build,Activate tool window
点击build
点击 减号 -
点击 加号 +
点击Build
点击no error check
点击OK


再次右键Run 'WordCount'

D:\\Java\\jdk1.8.0_121\\bin\\java -javaagent:D:\\IntelliJ_IDEA\\idea2018\\lib\\idea_rt.jar=59227:D:\\IntelliJ_IDEA\\idea2018\\bin -Dfile.encoding=UTF-8 -classpath D:\\Java\\jdk1.8.0_121\\jre\\lib\\charsets.jar;D:\\Java\\jdk1.8.0_121\\jre\\lib\\deploy.jar;D:\\Java\\jdk1.8.0_121\\jre\\lib\\ext\\access-bridge-64.jar;D:\\Java\\jdk1.8.0_121\\jre\\lib\\ext\\cldrdata.jar;D:\\Java\\jdk1.8.0_121\\jre\\lib\\ext\\dnsns.jar;D:\\Java\\jdk1.8.0_121\\jre\\lib\\ext\\jaccess.jar;D:\\Java\\jdk1.8.0_121\\jre\\lib\\ext\\jfxrt.jar;D:\\Java\\jdk1.8.0_121\\jre\\lib\\ext\\localedata.jar;D:\\Java\\jdk1.8.0_121\\jre\\lib\\ext\\nashorn.jar;D:\\Java\\jdk1.8.0_121\\jre\\lib\\ext\\sunec.jar;D:\\Java\\jdk1.8.0_121\\jre\\lib\\ext\\sunjce_provider.jar;D:\\Java\\jdk1.8.0_121\\jre\\lib\\ext\\sunmscapi.jar;D:\\Java\\jdk1.8.0_121\\jre\\lib\\ext\\sunpkcs11.jar;D:\\Java\\jdk1.8.0_121\\jre\\lib\\ext\\zipfs.jar;D:\\Java\\jdk1.8.0_121\\jre\\lib\\javaws.jar;D:\\Java\\jdk1.8.0_121\\jre\\lib\\jce.jar;D:\\Java\\jdk1.8.0_121\\jre\\lib\\jfr.jar;D:\\Java\\jdk1.8.0_121\\jre\\lib\\jfxswt.jar;D:\\Java\\jdk1.8.0_121\\jre\\lib\\jsse.jar;D:\\Java\\jdk1.8.0_121\\jre\\lib\\management-agent.jar;D:\\Java\\jdk1.8.0_121\\jre\\lib\\plugin.jar;D:\\Java\\jdk1.8.0_121\\jre\\lib\\resources.jar;D:\\Java\\jdk1.8.0_121\\jre\\lib\\rt.jar;E:\\os_workspace\\flink\\flink-examples\\flink-examples-streaming\\target\\classes;E:\\os_workspace\\flink\\flink-streaming-java\\target\\classes;E:\\os_workspace\\flink\\flink-connectors\\flink-file-sink-common\\target\\classes;E:\\os_workspace\\flink\\flink-runtime\\target\\classes;E:\\os_workspace\\flink\\flink-queryable-state\\flink-queryable-state-client-java\\target\\classes;E:\\os_workspace\\flink\\flink-filesystems\\flink-hadoop-fs\\target\\classes;D:\\eclipse_boot\\repository-maven\\repository-maven\\commons-io\\commons-io\\2.7\\commons-io-2.7.jar;D:\\eclipse_boot\\repository-maven\\repository-maven\\org\\apache\\flink\\flink-shaded-netty\\4.1.49.Final-12.0\\flink-shaded-netty-4.1.49.Final-12.0.jar;D:\\eclipse_boot\\repository-maven\\repository-maven\\org\\apache\\flink\\flink-shaded-zookeeper-3\\3.4.14-12.0\\flink-shaded-zookeeper-3-3.4.14-12.0.jar;D:\\eclipse_boot\\repository-maven\\repository-maven\\org\\javassist\\javassist\\3.24.0-GA\\javassist-3.24.0-GA.jar;D:\\eclipse_boot\\repository-maven\\repository-maven\\com\\typesafe\\akka\\akka-actor_2.11\\2.5.21\\akka-actor_2.11-2.5.21.jar;D:\\eclipse_boot\\repository-maven\\repository-maven\\com\\typesafe\\config\\1.3.0\\config-1.3.0.jar;D:\\eclipse_boot\\repository-maven\\repository-maven\\org\\scala-lang\\modules\\scala-java8-compat_2.11\\0.7.0\\scala-java8-compat_2.11-0.7.0.jar;D:\\eclipse_boot\\repository-maven\\repository-maven\\com\\typesafe\\akka\\akka-remote_2.11\\2.5.21\\akka-remote_2.11-2.5.21.jar;D:\\eclipse_boot\\repository-maven\\repository-maven\\com\\typesafe\\akka\\akka-stream_2.11\\2.5.21\\akka-stream_2.11-2.5.21.jar;D:\\eclipse_boot\\repository-maven\\repository-maven\\org\\reactivestreams\\reactive-streams\\1.0.2\\reactive-streams-1.0.2.jar;D:\\eclipse_boot\\repository-maven\\repository-maven\\com\\typesafe\\ssl-config-core_2.11\\0.3.7\\ssl-config-core_2.11-0.3.7.jar;D:\\eclipse_boot\\repository-maven\\repository-maven\\com\\typesafe\\akka\\akka-protobuf_2.11\\2.5.21\\akka-protobuf_2.11-2.5.21.jar;D:\\eclipse_boot\\repository-maven\\repository-maven\\com\\typesafe\\akka\\akka-slf4j_2.11\\2.5.21\\akka-slf4j_2.11-2.5.21.jar;D:\\eclipse_boot\\repository-maven\\repository-maven\\org\\clapper\\grizzled-slf4j_2.11\\1.3.2\\grizzled-slf4j_2.11-1.3.2.jar;D:\\eclipse_boot\\repository-maven\\repository-maven\\com\\github\\scopt\\scopt_2.11\\3.5.0\\scopt_2.11-3.5.0.jar;D:\\eclipse_boot\\repository-maven\\repository-maven\\org\\xerial\\snappy\\snappy-java\\1.1.4\\snappy-java-1.1.4.jar;D:\\eclipse_boot\\repository-maven\\repository-maven\\com\\twitter\\chill_2.11\\0.7.6\\chill_2.11-0.7.6.jar;D:\\eclipse_boot\\repository-maven\\repository-maven\\com\\twitter\\chill-java\\0.7.6\\chill-java-0.7.6.jar;D:\\eclipse_boot\\repository-maven\\repository-maven\\org\\lz4\\lz4-java\\1.6.0\\lz4-java-1.6.0.jar;E:\\os_workspace\\flink\\flink-java\\target\\classes;D:\\eclipse_boot\\repository-maven\\repository-maven\\org\\apache\\flink\\flink-shaded-guava\\18.0-12.0\\flink-shaded-guava-18.0-12.0.jar;D:\\eclipse_boot\\repository-maven\\repository-maven\\org\\apache\\commons\\commons-math3\\3.5\\commons-math3-3.5.jar;E:\\os_workspace\\flink\\flink-streaming-scala\\target\\classes;E:\\os_workspace\\flink\\flink-scala\\target\\classes;D:\\eclipse_boot\\repository-maven\\repository-maven\\org\\scala-lang\\scala-reflect\\2.11.12\\scala-reflect-2.11.12.jar;D:\\eclipse_boot\\repository-maven\\repository-maven\\org\\scala-lang\\scala-library\\2.11.12\\scala-library-2.11.12.jar;D:\\eclipse_boot\\repository-maven\\repository-maven\\org\\scala-lang\\scala-compiler\\2.11.12\\scala-compiler-2.11.12.jar;D:\\eclipse_boot\\repository-maven\\repository-maven\\org\\scala-lang\\modules\\scala-xml_2.11\\1.0.5\\scala-xml_2.11-1.0.5.jar;D:\\eclipse_boot\\repository-maven\\repository-maven\\org\\scala-lang\\modules\\scala-parser-combinators_2.11\\1.1.1\\scala-parser-combinators_2.11-1.1.1.jar;E:\\os_workspace\\flink\\flink-clients\\target\\classes;E:\\os_workspace\\flink\\flink-optimizer\\target\\classes;D:\\eclipse_boot\\repository-maven\\repository-maven\\commons-cli\\commons-cli\\1.3.1\\commons-cli-1.3.1.jar;E:\\os_workspace\\flink\\flink-connectors\\flink-connector-twitter\\target\\classes;D:\\eclipse_boot\\repository-maven\\repository-maven\\com\\twitter\\hbc-core\\2.2.0\\hbc-core-2.2.0.jar;D:\\eclipse_boot\\repository-maven\\repository-maven\\org\\apache\\httpcomponents\\httpclient\\4.5.3\\httpclient-4.5.3.jar;D:\\eclipse_boot\\repository-maven\\repository-maven\\org\\apache\\httpcomponents\\httpcore\\4.4.6\\httpcore-4.4.6.jar;D:\\eclipse_boot\\repository-maven\\repository-maven\\commons-logging\\commons-logging\\1.1.3\\commons-logging-1.1.3.jar;D:\\eclipse_boot\\repository-maven\\repository-maven\\commons-codec\\commons-codec\\1.13\\commons-codec-1.13.jar;D:\\eclipse_boot\\repository-maven\\repository-maven\\com\\google\\guava\\guava\\14.0.1\\guava-14.0.1.jar;D:\\eclipse_boot\\repository-maven\\repository-maven\\com\\twitter\\joauth\\6.0.2\\joauth-6.0.2.jar;E:\\os_workspace\\flink\\flink-connectors\\flink-connector-kafka\\target\\classes;D:\\eclipse_boot\\repository-maven\\repository-maven\\org\\apache\\kafka\\kafka-clients\\2.4.1\\kafka-clients-2.4.1.jar;D:\\eclipse_boot\\repository-maven\\repository-maven\\com\\github\\luben\\zstd-jni\\1.4.3-1\\zstd-jni-1.4.3-1.jar;E:\\os_workspace\\flink\\flink-connectors\\flink-connector-base\\target\\classes;D:\\eclipse_boot\\repository-maven\\repository-maven\\org\\apache\\flink\\flink-shaded-jackson\\2.10.1-12.0\\flink-shaded-jackson-2.10.1-12.0.jar;D:\\eclipse_boot\\repository-maven\\repository-maven\\io\\netty\\netty\\3.10.6.Final\\netty-3.10.6.Final.jar;E:\\os_workspace\\flink\\flink-state-backends\\flink-statebackend-rocksdb\\target\\classes;D:\\eclipse_boot\\repository-maven\\repository-maven\\com\\data-artisans\\frocksdbjni\\5.17.2-artisans-2.0\\frocksdbjni-5.17.2-artisans-2.0.jar;D:\\eclipse_boot\\repository-maven\\repository-maven\\org\\jcuda\\jcuda\\10.0.0\\jcuda-10.0.0.jar;D:\\eclipse_boot\\repository-maven\\repository-maven\\org\\jcuda\\jcublas\\10.0.0\\jcublas-10.0.0.jar;E:\\os_workspace\\flink\\flink-core\\target\\classes;E:\\os_workspace\\flink\\flink-annotations\\target\\classes;E:\\os_workspace\\flink\\flink-metrics\\flink-metrics-core\\target\\classes;D:\\eclipse_boot\\repository-maven\\repository-maven\\org\\apache\\flink\\flink-shaded-asm-7\\7.1-12.0\\flink-shaded-asm-7-7.1-12.0.jar;D:\\eclipse_boot\\repository-maven\\repository-maven\\org\\apache\\commons\\commons-lang3\\3.3.2\\commons-lang3-3.3.2.jar;D:\\eclipse_boot\\repository-maven\\repository-maven\\com\\esotericsoftware\\kryo\\kryo\\2.24.0\\kryo-2.24.0.jar;D:\\eclipse_boot\\repository-maven\\repository-maven\\com\\esotericsoftware\\minlog\\minlog\\1.2\\minlog-1.2.jar;D:\\eclipse_boot\\repository-maven\\repository-maven\\commons-collections\\commons-collections\\3.2.2\\commons-collections-3.2.2.jar;D:\\eclipse_boot\\repository-maven\\repository-maven\\org\\apache\\commons\\commons-compress\\1.20\\commons-compress-1.20.jar;D:\\eclipse_boot\\repository-maven\\repository-maven\\org\\apache\\logging\\log4j\\log4j-slf4j-impl\\2.12.1\\log4j-slf4j-impl-2.12.1.jar;D:\\eclipse_boot\\repository-maven\\repository-maven\\org\\apache\\logging\\log4j\\log4j-api\\2.12.1\\log4j-api-2.12.1.jar;D:\\eclipse_boot\\repository-maven\\repository-maven\\org\\apache\\logging\\log4j\\log4j-core\\2.12.1\\log4j-core-2.12.1.jar;E:\\os_workspace\\flink\\tools\\force-shading\\target\\classes;D:\\eclipse_boot\\repository-maven\\repository-maven\\org\\slf4j\\slf4j-api\\1.7.15\\slf4j-api-1.7.15.jar;D:\\eclipse_boot\\repository-maven\\repository-maven\\com\\google\\code\\findbugs\\jsr305\\1.3.9\\jsr305-1.3.9.jar;D:\\eclipse_boot\\repository-maven\\repository-maven\\org\\objenesis\\objenesis\\2.1\\objenesis-2.1.jar org.apache.flink.streaming.scala.examples.wordcount.WordCount
Executing WordCount example with default inputs data set.
Use --input to specify file input.
Printing result to stdout. Use --output to specify output path.
2021-09-27 20:18:52,335 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutorResourceUtils [] - The configuration option taskmanager.cpu.cores required for local execution is not set, setting it to the maximal possible value.
2021-09-27 20:18:52,347 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutorResourceUtils [] - The configuration option taskmanager.memory.task.heap.size required for local execution is not set, setting it to the maximal possible value.
2021-09-27 20:18:52,347 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutorResourceUtils [] - The configuration option taskmanager.memory.task.off-heap.size required for local execution is not set, setting it to the maximal possible value.
2021-09-27 20:18:52,351 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutorResourceUtils [] - The configuration option taskmanager.memory.network.min required for local execution is not set, setting it to its default value 64 mb.
2021-09-27 20:18:52,351 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutorResourceUtils [] - The configuration option taskmanager.memory.network.max required for local execution is not set, setting it to its default value 64 mb.
2021-09-27 20:18:52,352 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutorResourceUtils [] - The configuration option taskmanager.memory.managed.size required for local execution is not set, setting it to its default value 128 mb.
2021-09-27 20:18:52,362 INFO  org.apache.flink.runtime.minicluster.MiniCluster             [] - Starting Flink Mini Cluster
2021-09-27 20:18:52,374 INFO  org.apache.flink.runtime.minicluster.MiniCluster             [] - Starting Metrics Registry
2021-09-27 20:18:52,493 INFO  org.apache.flink.runtime.metrics.MetricRegistryImpl          [] - No metrics reporter configured, no metrics will be exposed/reported.
2021-09-27 20:18:52,493 INFO  org.apache.flink.runtime.minicluster.MiniCluster             [] - Starting RPC Service(s)
2021-09-27 20:18:52,541 INFO  org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils        [] - Trying to start local actor system
2021-09-27 20:18:53,224 INFO  akka.event.slf4j.Slf4jLogger                                 [] - Slf4jLogger started
2021-09-27 20:18:53,511 INFO  org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils        [] - Actor system started at akka://flink
2021-09-27 20:18:53,540 INFO  org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils        [] - Trying to start local actor system
2021-09-27 20:18:53,565 INFO  akka.event.slf4j.Slf4jLogger                                 [] - Slf4jLogger started
2021-09-27 20:18:53,629 INFO  org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils        [] - Actor system started at akka://flink-metrics
2021-09-27 20:18:53,671 INFO  org.apache.flink.runtime.rpc.akka.AkkaRpcService             [] - Starting RPC endpoint for org.apache.flink.runtime.metrics.dump.MetricQueryService at akka://flink-metrics/user/rpc/MetricQueryService .
2021-09-27 20:18:53,722 INFO  org.apache.flink.runtime.minicluster.MiniCluster             [] - Starting high-availability services
2021-09-27 20:18:53,758 INFO  org.apache.flink.runtime.blob.BlobServer                     [] - Created BLOB server storage directory C:\\Users\\my\\AppData\\Local\\Temp\\blobStore-1d169db4-3046-4e75-9598-9d98705f0dc7
2021-09-27 20:18:53,784 INFO  org.apache.flink.runtime.blob.BlobServer                     [] - Started BLOB server at 0.0.0.0:59233 - max concurrent requests: 50 - max backlog: 1000
2021-09-27 20:18:53,795 INFO  org.apache.flink.runtime.blob.PermanentBlobCache             [] - Created BLOB cache storage directory C:\\Users\\my\\AppData\\Local\\Temp\\blobStore-e3cc8f0e-9152-47b9-98f0-e7ce09b469a5
2021-09-27 20:18:53,817 INFO  org.apache.flink.runtime.blob.TransientBlobCache             [] - Created BLOB cache storage directory C:\\Users\\my\\AppData\\Local\\Temp\\blobStore-febc9bfd-2937-48bc-b144-02d082819f9e
2021-09-27 20:18:53,819 INFO  org.apache.flink.runtime.minicluster.MiniCluster             [] - Starting 1 TaskManger(s)
2021-09-27 20:18:53,827 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] - Starting TaskManager with ResourceID: b975be99-d014-4a81-8dfc-4d58902928c6
2021-09-27 20:18:53,885 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerServices    [] - Temporary file directory 'C:\\Users\\my\\AppData\\Local\\Temp': total 60 GB, usable 11 GB (18.33% usable)
2021-09-27 20:18:53,896 INFO  org.apache.flink.runtime.io.disk.FileChannelManagerImpl      [] - FileChannelManager uses directory C:\\Users\\my\\AppData\\Local\\Temp\\flink-io-a63ea32f-88ba-4711-a824-dff0178aa6ba for spill files.
2021-09-27 20:18:53,912 INFO  org.apache.flink.runtime.io.disk.FileChannelManagerImpl      [] - FileChannelManager uses directory C:\\Users\\my\\AppData\\Local\\Temp\\flink-netty-shuffle-35bb8d57-1121-4813-8a53-8f2cdbba7a5e for spill files.
2021-09-27 20:18:53,991 INFO  org.apache.flink.runtime.io.network.buffer.NetworkBufferPool [] - Allocated 64 MB for network buffer pool (number of memory segments: 2048, bytes per segment: 32768).
2021-09-27 20:18:54,024 INFO  org.apache.flink.runtime.io.network.NettyShuffleEnvironment  [] - Starting the network environment and its components.
2021-09-27 20:18:54,027 INFO  org.apache.flink.runtime.taskexecutor.KvStateService         [] - Starting the kvState service and its components.
2021-09-27 20:18:54,077 INFO  org.apache.flink.runtime.rpc.akka.AkkaRpcService             [] - Starting RPC endpoint for org.apache.flink.runtime.taskexecutor.TaskExecutor at akka://flink/user/rpc/taskmanager_0 .
2021-09-27 20:18:54,103 INFO  org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService [] - Start job leader service.
2021-09-27 20:18:54,130 INFO  org.apache.flink.runtime.filecache.FileCache                 [] - User file cache uses directory C:\\Users\\my\\AppData\\Local\\Temp\\flink-dist-cache-012f2cb7-e2b3-40e8-b894-91612bafbdaf
2021-09-27 20:18:54,187 INFO  org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint   [] - Starting rest endpoint.
2021-09-27 20:18:54,192 INFO  org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint   [] - Failed to load web based job submission extension. Probable reason: flink-runtime-web is not in the classpath.
2021-09-27 20:18:54,710 WARN  org.apache.flink.runtime.webmonitor.WebMonitorUtils          [] - Log file environment variable 'log.file' is not set.
2021-09-27 20:18:54,710 WARN  org.apache.flink.runtime.webmonitor.WebMonitorUtils          [] - JobManager log files are unavailable in the web dashboard. Log file location not found in environment variable 'log.file' or configuration key 'web.log.path'.
2021-09-27 20:18:55,390 INFO  org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint   [] - Rest endpoint listening at localhost:59252
2021-09-27 20:18:55,391 INFO  org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService [] - Proposing leadership to contender http://localhost:59252
2021-09-27 20:18:55,398 INFO  org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint   [] - http://localhost:59252 was granted leadership with leaderSessionID=083cc8a0-49ba-4763-8d20-a8c4d13d200e
2021-09-27 20:18:55,399 INFO  org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService [] - Received confirmation of leadership for leader http://localhost:59252 , session=083cc8a0-49ba-4763-8d20-a8c4d13d200e
2021-09-27 20:18:55,441 INFO  org.apache.flink.runtime.rpc.akka.AkkaRpcService             [] - Starting RPC endpoint for org.apache.flink.runtime.resourcemanager.StandaloneResourceManager at akka://flink/user/rpc/resourcemanager_1 .
2021-09-27 20:18:55,467 INFO  org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService [] - Proposing leadership to contender LeaderContender: DefaultDispatcherRunner
2021-09-27 20:18:55,474 INFO  org.apache.flink.runtime.dispatcher.runner.DefaultDispatcherRunner [] - DefaultDispatcherRunner was granted leadership with leader id 0ad980b3-ff41-441b-a51e-eafb4c32ecdd. Creating new DispatcherLeaderProcess.
2021-09-27 20:18:55,511 INFO  org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess [] - Start SessionDispatcherLeaderProcess.
2021-09-27 20:18:55,515 INFO  org.apache.flink.runtime.resourcemanager.StandaloneResourceManager [] - Starting the resource manager.
2021-09-27 20:18:55,515 INFO  org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService [] - Proposing leadership to contender LeaderContender: StandaloneResourceManager
2021-09-27 20:18:55,520 INFO  org.apache.flink.runtime.minicluster.MiniCluster             [] - Flink Mini Cluster started successfully
2021-09-27 20:18:55,526 INFO  org.apache.flink.runtime.resourcemanager.StandaloneResourceManager [] - ResourceManager akka://flink/user/rpc/resourcemanager_1 was granted leadership with fencing token 9e2c7b196dc36f7579eec22bfcfd4e46
2021-09-27 20:18:55,528 INFO  org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess [] - Recover all persisted job graphs.
2021-09-27 20:18:55,534 INFO  org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess [] - Successfully recovered 0 persisted job graphs.
2021-09-27 20:18:55,545 INFO  org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService [] - Received confirmation of leadership for leader akka://flink/user/rpc/resourcemanager_1 , session=79eec22b-fcfd-4e46-9e2c-7b196dc36f75
2021-09-27 20:18:55,550 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor           [] - Connecting to ResourceManager akka://flink/user/rpc/resourcemanager_1(9e2c7b196dc36f7579eec22bfcfd4e46).
2021-09-27 20:18:55,556 INFO  org.apache.flink.runtime.rpc.akka.AkkaRpcService             [] - Starting RPC endpoint for org.apache.flink.runtime.dispatcher.StandaloneDispatcher at akka://flink/user/rpc/dispatcher_2 .
2021-09-27 20:18:55,569 INFO  org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService [] - Received confirmation of leadership for leader akka://flink/user/rpc/dispatcher_2 , session=0ad980b3-ff41-441b-a51e-eafb4c32ecdd
2021-09-27 20:18:55,596 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor           [] - Resolved ResourceManager address, beginning registration
2021-09-27 20:18:55,609 INFO  org.apache.flink.runtime.resourcemanager.StandaloneResourceManager [] - Registering TaskManager with ResourceID b975be99-d014-4a81-8dfc-4d58902928c6 (akka://flink/user/rpc/taskmanager_0) at ResourceManager
2021-09-27 20:18:55,614 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor           [] - Successful registration at resource manager akka://flink/user/rpc/resourcemanager_1 under registration id f89e44c884f54887158d9d3a77dbe505.
2021-09-27 20:18:55,632 INFO  org.apache.flink.runtime.dispatcher.StandaloneDispatcher     [] - Received JobGraph submission 3224db4a2c644bb378d49bc019a8f584 (Streaming WordCount).
2021-09-27 20:18:55,633 INFO  org.apache.flink.runtime.dispatcher.StandaloneDispatcher     [] - Submitting job 3224db4a2c644bb378d49bc019a8f584 (Streami
以上是关于Apache Flink源码阅读环境搭建的主要内容，如果未能解决你的问题，请参考以下文章
 

 如何使用Apache Flink阅读Cassandra？


 Apache Spark源码阅读环境搭建


 Apache Spark源码阅读环境搭建


 Idea1.5使用Maven搭建Apache Spark1.6源码阅读环境


 flink开发环境搭建maven环境搭建IDEA环境搭建


 Mac搭建Hadoop源码阅读环境