鲲鹏社区首页
中文
注册
我要评分
文档获取效率
文档正确性
内容完整性
文档易理解
在线提单
论坛求助

测试结果查看

  1. 查看吞吐量。
    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(秒)

  2. 查看时延。
    1
    cd /opt/yahoo-streaming-benchmark/data
    

    “data”目录下,seen.txt文件记录不同的活动的事件数量,updated.txt文件记录延迟数据。