测试结果查看
- 查看吞吐量。
INFO tart flink processing... Starting taskmanager daemon on host serverl. (2020-11-15 15:26:41,793] INFO Closing socket connection to /127.0.0.1. (kafka.network.Processor) INFO Start to load data... 11/15/2020 15:26:42 Job execution switched to status RUNNING. 11/15/2020 15:26:42 Source: Custom Source -> Flat Map(1/1) switched to SCHEDULED 11/15/2020 15:26:42 Source: Custom Source -> Flat Map(1/1) switched to DEPLOYING 11/15/2020 15:26:42 Flat Map -> Filter -> Projection -> Flat Map(1/1) switched to SCHEDULED 11/15/2020 15:26:42 Flat Map -> Filter -> Projection -> Flat Map(1/1) switched to DEPLOYING 11/15/2020 15:26:42 Flat Map(1/1) switched to SCHEDULED 11/15/2020 15:26:42 Flat Map(1/1) switched to DEPLOYING 11/15/2020 15:26:43 Source: Custom Source -> Flat Map(1/1) switched to RUNNING 11/15/2020 15:26:43 Flat Map -> Filter -> Projection -> Flat Map(1/1) switched to RUNNING 11/15/2020 15:26:43 Flat Map(1/1) switched to RUNNING 29108 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2181] INFO 0.a.s.s.0.a.z.s.NIOServerCnxnFactory - Accepted socket connection from /127.0.0.1:33000 29111 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2181] INFO 0.a.s.s.o.a.z.s.Zookeeperserver - Client attempting to establish new session at /127.0.0.1:33000 29118 [SyncThread:0] INFO -0.a.s.s.0.a.z.s.ZooKeeperServer - Established session 0x175cacc23cb0003 with negotiated timeout 40000 for client /127.0.0.1:33000 [2020-11-15 15:26:44,222] INFO Closing socket connection to /127.0.0.1. (kafka.network.Processor)
当运行到上图时,需要进入Flink的Web界面查看吞吐量。
- Web界面地址链接:Flink的安装服务器IPaddress:8081
- 吞吐量= Records received(消息数)/Duration(秒)
- 查看时延。
1
cd /opt/yahoo-streaming-benchmark/data
在“data”目录下,seen.txt文件记录不同的活动的事件数量,updated.txt文件记录延迟数据。