此案例使用的是IDEA开发工具，项目属于maven项目
使用Flink JavaAPI实现的流处理、批处理（其中还包括Table API的使用和SQL API的使用），主要针对（《Flink入门与实战》徐葳著）教材中的实验使用
2022-05-30 18:04:28
41.65MB
1
使用时配合https://blog.csdn.net/qq_43431735/category_9653567.html这个专栏使用，将三个sh文件添加权限，chmon +x 文件名，三个文件放在一个目录下，同时可以将目录路径添加到环境变量，这样在Linux那个位置都可以使用文件。
通过测试，hdfs与yarn组件启动后有以下进程：
node1 jps：4个进程
NameNode、JournalNode、DFSZKFailoverController、Jps
node2 jps：7个进程
DFSZKFailoverController、NodeManager、JournalNode、QuorumPeerMain、DataNode、Jps、NameNode
node3 jps：6个进程
ResourceManager、DataNode、QuorumPeerMain、JournalNode、Jps、NodeManager
node4 jps：5个进程
NodeManager、DataNode、QuorumPeerMain、ResourceManager、Jps
2022-05-29 19:06:16
1KB
1