Viewing Test Results

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)

When the preceding figure is displayed, log in to the Flink web page to view the throughput.

• Web page URL: IP address of the server where Flink is installed:8081
• Throughput = Records received (number of messages)/Duration (second)

1

cd /opt/yahoo-streaming-benchmark/data

In the data directory, the seen.txt file records the number of events of different activities, and the updated.txt file records the latency data.