flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Stephan Ewen (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-2252) Reduce local input split assignment log level from INFO to DEBUG
Date Mon, 22 Jun 2015 16:22:01 GMT

    [ https://issues.apache.org/jira/browse/FLINK-2252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14596164#comment-14596164 ] 

Stephan Ewen commented on FLINK-2252:
-------------------------------------

Has this number of log line become a bad problem at any point, really? We are pretty sparsely logging right now anyways. I would keep it unless it poses an issue. Some day you'll be happy to find this in a log of a program that a user sends you.

> Reduce local input split assignment log level from INFO to DEBUG
> ----------------------------------------------------------------
>
>                 Key: FLINK-2252
>                 URL: https://issues.apache.org/jira/browse/FLINK-2252
>             Project: Flink
>          Issue Type: Wish
>          Components: JobManager
>            Reporter: Maximilian Michels
>            Priority: Minor
>
> Should we reduce the log level for local input split assignments messages to from INFO to DEBUG? It causes quite some spam in the jobmanager log.
> {noformat}
> 23:48:57,692 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 23:48:57,696 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 23:48:59,130 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 23:48:59,145 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 23:48:59,353 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 23:48:59,504 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 23:48:59,625 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 23:48:59,631 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 23:49:00,404 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 23:49:00,998 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 23:49:01,828 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 23:49:02,646 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 23:49:03,271 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 23:49:03,585 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 23:49:03,660 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 23:49:04,116 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 23:49:06,075 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 23:49:06,111 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 23:49:08,597 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 23:49:09,449 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 23:49:53,969 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 23:49:54,714 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 23:49:57,847 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 23:49:57,913 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 23:49:57,998 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 23:49:58,294 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 23:49:58,357 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 23:49:59,294 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 23:49:59,699 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 23:50:00,555 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 23:50:01,115 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 23:50:01,479 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 23:50:01,708 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 23:50:03,755 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 23:50:04,049 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 23:50:04,964 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 23:50:09,975 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 23:50:10,049 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 23:50:15,064 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 23:50:16,413 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 23:50:50,342 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 23:50:50,720 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 23:50:56,113 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 23:50:56,813 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 23:50:56,983 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 23:50:57,552 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 23:50:58,329 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 23:50:58,376 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 23:50:58,860 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 23:50:59,373 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 23:50:59,882 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 23:51:00,178 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 23:51:00,900 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 23:51:03,200 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 23:51:05,717 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 23:51:06,502 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 23:51:06,704 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 23:51:06,915 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 23:51:12,248 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 23:51:12,983 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 23:51:12,994 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 23:51:13,971 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 23:51:14,021 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 23:51:14,482 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 23:51:14,508 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 23:51:14,680 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 23:51:15,636 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 23:51:16,352 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 23:51:16,498 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 23:51:17,462 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 23:51:19,323 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 23:51:22,025 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 23:51:22,844 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 23:51:23,575 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 23:51:24,229 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 23:51:31,200 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 23:51:31,899 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 23:51:39,320 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 23:51:40,821 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 23:51:57,585 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 23:52:03,390 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 23:52:03,979 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 23:52:10,978 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 23:52:11,033 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 23:52:11,292 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 23:52:11,869 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 23:52:13,553 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 23:52:13,661 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 23:52:14,289 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 23:52:14,352 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 23:52:15,515 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 23:52:15,664 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 23:52:16,906 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 23:52:19,075 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 23:52:24,066 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 23:52:24,815 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 23:52:35,058 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 23:52:36,222 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 23:52:46,541 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 23:52:48,086 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 23:52:59,604 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 23:53:00,108 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 23:53:09,276 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 23:53:09,478 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 23:53:10,304 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 23:53:10,688 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 23:53:12,833 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 23:53:13,141 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 23:53:13,312 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 23:53:13,884 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 23:53:14,002 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 23:53:14,865 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 23:53:16,476 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 23:53:18,629 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 23:53:24,958 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 23:53:25,505 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 23:53:39,144 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 23:53:39,747 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 23:53:52,528 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 23:53:55,199 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 23:53:56,530 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 23:53:56,729 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 23:54:07,018 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 23:54:07,753 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 23:54:09,375 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 23:54:10,535 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 23:54:11,486 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 23:54:11,845 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 23:54:12,719 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 23:54:13,491 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 23:54:14,222 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 23:54:14,379 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 23:54:16,246 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 23:54:18,224 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 23:54:25,995 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 23:54:26,244 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 23:54:43,131 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 23:54:44,411 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 23:54:52,789 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 23:54:53,080 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 23:54:59,923 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 23:55:02,522 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 23:55:05,277 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 23:55:05,693 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 23:55:07,985 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 23:55:08,797 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 23:55:08,922 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 23:55:10,069 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 23:55:10,477 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 23:55:11,301 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 23:55:12,983 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 23:55:13,426 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 23:55:13,470 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 23:55:15,569 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 23:55:17,685 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 23:55:21,445 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 23:55:21,562 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 23:55:24,053 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 23:55:25,234 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 23:55:26,519 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 23:55:26,793 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 23:55:27,200 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 23:55:27,634 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 23:55:28,961 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 23:55:29,387 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 23:55:29,914 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 23:55:32,111 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 23:55:33,999 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 23:55:44,087 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 23:55:44,534 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 23:55:46,987 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 23:55:47,744 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 23:55:48,636 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 23:56:04,106 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 23:56:04,886 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 23:56:05,109 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 23:56:05,784 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 23:56:06,305 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 23:56:09,225 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 23:56:10,375 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 23:56:19,670 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 23:56:20,388 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 23:56:23,052 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 23:56:23,761 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 23:56:23,855 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 23:56:24,885 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 23:56:25,442 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 23:56:26,607 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 23:56:27,520 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 23:56:28,241 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 23:56:28,453 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 23:56:29,510 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 23:56:32,445 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 23:56:32,974 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 23:56:46,086 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 23:56:46,268 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 23:57:01,443 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 23:57:01,605 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 23:57:07,818 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 23:57:08,160 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 23:57:17,361 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 23:57:18,331 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 23:57:22,504 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 23:57:22,655 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 23:57:24,176 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 23:57:24,559 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 23:57:25,914 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 23:57:27,552 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 23:57:27,726 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 23:57:29,170 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 23:57:30,562 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 23:57:31,953 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 23:57:32,880 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 23:57:35,215 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 23:57:48,233 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 23:57:48,944 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 23:57:57,570 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 23:57:57,977 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 23:58:11,831 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 23:58:12,077 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 23:58:14,969 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 23:58:15,969 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 23:58:20,634 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 23:58:21,141 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 23:58:22,210 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 23:58:25,043 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 23:58:25,309 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 23:58:26,153 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 23:58:26,383 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 23:58:28,586 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 23:58:31,437 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 23:58:32,161 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 23:58:37,457 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 23:58:42,805 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 23:58:49,532 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 23:58:50,546 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 23:58:54,028 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 23:58:56,311 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 23:59:12,247 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 23:59:13,366 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 23:59:16,057 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 23:59:16,512 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 23:59:19,358 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 23:59:19,401 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 23:59:20,246 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 23:59:24,251 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 23:59:24,444 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 23:59:24,988 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 23:59:26,117 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 23:59:28,194 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 23:59:28,256 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 23:59:29,418 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 23:59:30,990 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 23:59:32,237 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 23:59:35,180 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 23:59:35,265 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 23:59:36,583 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 23:59:40,658 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 23:59:40,936 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 23:59:41,715 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 23:59:43,929 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 23:59:47,619 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 23:59:48,026 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 23:59:49,768 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 23:59:50,609 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 23:59:50,794 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 23:59:51,530 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 23:59:54,365 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:00:06,745 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:00:07,339 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:00:08,509 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:00:10,435 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:00:20,303 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:00:20,486 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:00:22,529 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:00:25,190 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:00:27,205 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:00:29,014 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:00:34,053 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:00:34,075 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:00:35,130 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:00:37,411 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:00:37,618 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:00:38,979 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:00:40,028 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:00:40,086 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:00:40,694 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:00:45,604 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:00:48,120 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:00:48,257 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:00:50,488 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:00:56,512 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:01:03,036 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:01:06,619 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:01:07,505 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:01:09,006 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:01:09,400 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:01:13,328 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:01:22,206 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:01:24,853 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:01:31,869 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:01:32,388 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:01:33,393 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:01:37,357 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:01:39,178 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:01:39,438 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:01:40,139 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:01:41,029 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:01:41,441 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:01:45,273 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:01:47,320 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:01:47,648 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:02:00,231 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:02:02,513 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:02:09,722 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:02:09,891 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:02:13,765 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:02:19,156 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:02:21,500 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:02:22,337 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:02:29,179 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:02:29,919 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:02:31,389 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:02:35,213 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:02:38,364 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:02:38,651 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:02:38,933 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:02:44,626 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:02:44,834 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:02:44,838 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:02:47,198 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:02:47,247 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:02:56,461 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:02:58,975 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:03:10,192 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:03:11,228 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:03:15,495 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:03:20,248 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:03:20,267 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:03:26,081 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:03:27,047 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:03:29,175 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:03:29,438 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:03:31,297 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:03:33,245 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:03:35,953 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:03:37,492 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:03:37,796 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:03:39,311 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:03:42,350 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:03:43,823 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:03:45,499 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:03:45,888 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:03:47,016 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:03:48,565 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:03:48,729 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:03:52,220 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:03:53,583 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:03:54,141 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:03:55,005 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:03:56,370 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:04:01,878 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:04:03,265 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:04:08,247 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:04:10,731 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:04:11,977 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:04:12,463 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:04:24,950 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:04:26,875 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:04:27,686 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:04:28,308 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:04:29,055 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:04:32,159 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:04:33,809 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:04:37,070 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:04:39,958 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:04:40,975 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:04:42,767 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:04:43,574 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:04:48,559 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:04:52,076 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:04:52,520 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:04:52,754 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:04:52,978 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:04:53,763 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:04:59,297 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:05:01,637 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:05:02,924 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:05:04,272 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:05:09,339 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:05:09,561 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:05:09,842 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:05:25,506 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:05:28,602 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:05:30,182 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:05:30,476 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:05:33,592 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:05:38,527 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:05:39,320 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:05:42,010 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:05:45,555 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:05:46,477 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:05:50,845 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:05:50,863 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:05:51,341 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:05:52,799 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:05:59,615 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:06:00,992 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:06:01,567 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:06:02,465 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:06:05,954 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:06:13,658 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:06:14,042 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:06:23,202 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:06:28,019 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:06:29,502 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:06:31,850 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:06:36,804 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:06:37,449 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:06:41,454 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:06:44,115 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:06:49,353 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:06:50,212 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:06:51,705 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:06:54,454 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:06:57,281 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:06:57,708 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:07:00,367 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:07:00,946 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:07:01,486 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:07:02,962 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:07:11,462 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:07:17,987 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:07:18,958 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:07:20,149 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:07:25,639 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:07:30,682 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:07:32,293 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:07:35,430 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:07:35,795 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:07:36,155 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:07:39,384 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:07:41,292 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:07:42,371 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:07:48,937 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:07:49,412 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:07:50,234 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:07:50,852 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:07:54,196 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:07:58,534 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:08:00,005 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:08:01,128 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:08:01,306 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:08:03,930 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:08:04,807 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:08:05,628 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:08:06,037 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:08:10,295 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:08:14,494 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:08:17,266 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:08:17,396 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:08:18,781 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:08:21,536 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:08:23,923 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:08:31,928 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:08:33,017 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:08:33,304 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:08:33,364 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:08:37,558 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:08:39,020 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:08:40,864 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:08:48,473 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:08:48,846 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:08:48,964 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:08:50,211 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:08:53,882 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:08:57,343 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:08:59,624 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:09:04,149 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:09:04,698 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:09:04,905 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:09:06,608 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:09:10,703 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:09:11,180 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:09:16,222 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:09:16,437 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:09:17,427 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:09:25,219 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:09:26,036 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:09:27,638 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:09:30,997 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:09:35,797 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:09:42,563 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:09:44,827 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:09:46,042 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:09:46,922 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:09:49,502 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:09:51,126 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:09:52,107 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:09:56,253 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:10:03,082 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:10:03,297 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:10:03,767 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:10:04,929 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:10:07,259 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:10:15,644 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:10:16,424 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:10:17,985 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:10:18,259 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:10:28,001 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:10:32,626 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:10:33,170 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:10:35,874 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:10:43,648 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:10:44,295 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:10:46,598 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:10:48,844 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:10:49,445 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:10:50,469 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:10:53,177 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:10:55,078 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:10:59,876 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:11:02,339 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:11:03,076 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:11:03,548 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:11:04,233 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:11:15,296 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:11:16,465 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:11:18,174 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:11:24,719 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:11:29,886 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:11:40,396 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:11:40,586 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:11:41,036 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:11:41,853 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:11:42,681 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:11:45,752 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:11:48,451 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:11:50,101 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:11:51,820 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:11:53,487 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:11:53,585 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:11:55,154 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:11:56,196 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:11:56,555 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:11:57,627 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:11:59,992 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:12:01,377 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:12:03,036 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:12:03,357 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:12:12,185 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:12:14,664 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:12:15,671 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:12:16,895 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:12:17,977 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:12:18,929 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:12:19,252 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:12:33,153 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:12:35,382 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:12:37,251 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:12:39,518 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:12:42,437 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:12:46,612 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:12:49,213 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:12:51,820 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:12:53,674 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:12:53,694 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:12:54,021 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:12:55,148 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:12:56,481 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:12:57,793 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:13:02,669 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:13:03,204 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:13:04,914 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:13:08,116 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:13:09,216 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:13:11,204 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:13:12,015 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:13:14,002 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:13:14,069 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:13:16,522 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:13:17,865 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:13:18,574 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:13:30,669 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:13:32,835 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:13:34,124 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:13:36,213 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:13:39,420 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:13:50,824 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:13:52,748 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:13:55,628 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:13:58,506 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:14:01,276 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:14:02,090 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:14:05,264 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:14:06,281 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:14:08,189 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:14:12,961 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:14:13,248 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:14:15,536 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:14:16,107 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:14:16,601 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:14:17,201 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:14:17,279 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:14:19,578 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:14:29,669 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:14:30,922 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:14:32,767 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:14:36,553 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:14:36,772 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:14:48,232 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:14:50,306 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:15:00,282 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:15:02,193 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:15:03,291 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:15:05,549 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:15:05,644 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:15:15,691 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:15:16,367 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:15:16,416 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:15:17,923 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:15:18,391 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:15:21,028 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:15:21,965 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:15:22,996 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:15:24,735 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:15:29,188 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:15:30,215 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:15:33,344 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:15:35,091 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:15:39,926 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:15:45,180 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:15:47,872 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:15:49,036 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:15:50,905 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:15:58,890 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:15:59,020 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:16:02,879 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:16:04,359 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:16:15,610 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:16:15,835 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:16:17,444 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:16:17,644 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:16:18,036 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:16:19,319 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:16:20,444 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:16:25,616 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:16:29,938 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:16:30,480 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:16:31,522 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:16:32,356 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:16:33,380 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:16:33,403 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:16:34,101 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:16:41,281 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:16:42,665 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:16:45,552 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:16:46,726 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:16:47,643 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:16:48,517 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:16:49,934 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:16:57,447 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:16:58,705 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:17:01,068 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:17:02,222 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:17:04,186 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:17:12,047 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:17:14,184 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:17:15,233 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:17:16,259 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:17:20,707 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:17:21,065 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:17:21,494 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:17:29,557 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:17:30,213 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:17:30,513 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:17:32,635 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:17:33,356 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:17:35,625 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:17:38,656 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:17:39,466 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:17:40,051 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:17:44,287 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:17:46,260 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:17:49,706 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:17:55,817 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:17:57,416 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:17:58,365 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:17:58,776 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:18:08,223 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:18:12,594 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:18:13,366 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:18:19,604 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:18:22,195 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:18:29,498 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:18:30,780 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:18:31,844 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:18:35,094 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:18:35,893 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:18:39,452 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:18:39,600 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:18:39,737 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:18:40,970 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:18:45,603 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:18:47,368 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:18:49,340 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:18:52,356 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:18:54,650 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:18:55,835 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:18:56,618 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:18:59,509 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:19:03,202 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:19:04,681 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:19:08,904 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:19:11,266 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:19:17,604 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:19:28,265 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:19:29,245 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:19:31,396 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:19:33,184 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:19:38,294 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:19:40,673 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:19:40,700 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:19:44,877 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:19:48,608 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:19:49,039 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:19:50,945 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:19:52,374 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:19:53,834 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:19:54,188 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:19:56,871 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:20:00,018 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:20:00,644 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:20:01,083 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:20:05,109 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:20:09,341 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:20:11,051 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:20:16,621 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:20:16,732 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:20:20,993 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:20:26,793 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:20:26,989 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:20:31,153 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:20:41,614 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:20:41,866 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:20:42,697 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:20:43,774 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:20:45,629 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:20:47,522 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:20:47,557 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:20:48,443 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:20:49,820 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:20:50,894 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:21:00,551 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:21:00,644 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:21:01,513 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:21:03,777 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:21:03,911 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:21:04,160 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:21:06,903 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:21:07,918 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:21:12,784 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:21:14,777 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:21:17,018 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:21:17,775 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:21:18,494 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:21:18,510 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:21:24,471 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:21:24,660 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:21:31,218 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:21:35,245 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:21:40,644 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:21:41,702 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:21:41,876 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:21:42,865 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:21:42,911 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:21:42,914 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:21:46,284 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:21:47,593 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:21:59,436 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:21:59,995 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:22:01,174 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:22:03,221 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:22:03,789 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:22:04,958 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:22:08,903 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:22:09,470 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:22:13,742 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:22:17,958 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:22:22,472 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:22:24,621 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:22:30,418 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:22:38,737 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:22:39,072 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:22:40,735 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:22:41,643 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:22:43,693 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:22:45,115 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:22:45,181 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:22:57,953 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:22:58,262 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:23:00,751 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:23:01,049 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:23:01,438 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:23:02,351 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:23:05,310 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:23:09,194 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:23:10,693 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:23:13,427 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:23:19,052 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:23:21,149 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:23:21,166 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:23:26,479 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:23:27,701 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:23:30,515 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:23:31,154 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:23:36,090 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:23:37,539 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:23:39,841 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:23:41,787 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:23:44,769 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:23:49,467 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:23:52,167 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:23:55,573 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:23:57,340 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:23:57,461 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:23:57,673 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:24:01,347 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:24:01,795 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:24:01,802 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:24:06,860 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:24:11,355 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:24:16,813 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:24:19,253 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:24:20,292 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:24:22,787 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:24:26,045 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:24:30,692 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:24:34,760 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:24:35,487 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:24:37,496 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:24:37,742 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:24:38,085 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:24:42,508 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:24:43,702 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:24:49,663 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:24:53,413 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:24:53,825 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:24:54,889 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:24:55,040 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:24:56,426 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:24:57,103 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:24:59,843 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:25:01,402 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:25:02,778 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:25:05,073 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:25:09,632 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:25:10,239 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:25:12,753 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:25:13,364 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:25:17,528 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:25:19,323 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:25:21,660 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:25:33,866 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:25:34,919 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:25:37,761 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:25:37,964 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:25:40,496 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:25:44,315 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:25:46,772 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:25:51,459 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:25:52,127 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:25:52,129 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:25:59,075 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:26:02,434 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:26:03,989 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:26:04,533 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:26:05,780 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:26:05,948 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:26:07,094 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:26:09,593 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:26:12,499 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:26:15,092 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:26:17,214 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:26:20,992 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:26:21,578 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:26:32,010 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:26:38,537 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:26:38,897 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:26:38,997 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:26:41,691 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:26:44,155 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:26:49,189 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:26:51,275 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:26:51,715 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:26:58,433 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:27:02,953 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:27:03,966 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:27:05,799 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:27:07,050 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:27:09,232 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:27:11,403 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:27:11,824 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:27:16,755 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:27:21,639 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:27:22,265 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:27:23,980 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:27:28,606 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:27:30,069 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:27:37,675 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:27:39,489 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:27:41,124 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:27:42,290 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:27:45,907 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:27:46,214 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:27:50,923 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:27:51,494 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:27:57,637 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:27:58,562 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:27:59,416 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:28:00,479 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:28:01,674 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:28:02,102 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:28:03,045 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:28:07,730 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:28:12,421 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:28:16,452 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:28:16,546 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:28:17,160 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:28:18,220 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:28:23,175 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:28:23,533 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:28:24,843 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:28:28,191 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:28:35,923 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:28:36,491 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:28:40,397 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:28:44,535 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:28:49,416 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:28:49,979 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:28:52,602 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:28:56,560 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:28:56,676 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:28:59,510 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:29:00,037 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:29:03,275 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:29:05,464 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:29:05,858 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:29:07,963 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:29:11,360 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:29:12,485 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:29:14,199 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:29:14,459 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:29:15,242 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:29:15,736 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:29:19,551 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:29:24,235 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:29:24,536 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:29:25,677 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:29:27,819 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:29:31,830 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:29:41,128 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:29:42,411 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:29:43,906 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:29:44,486 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:29:51,213 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:29:53,966 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:29:57,202 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:29:58,077 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:30:01,177 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:30:04,103 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:30:04,259 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:30:07,737 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:30:10,100 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:30:12,090 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:30:12,815 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:30:13,198 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:30:13,856 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:30:15,928 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker0
> 00:30:25,487 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:30:27,095 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:30:27,212 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:30:31,560 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:30:42,199 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:30:42,928 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:30:49,370 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:30:49,408 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:30:50,641 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:30:54,767 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:30:58,304 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:31:02,615 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:31:03,113 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:31:05,892 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning remote split to host nightly-benchmark-worker0
> 00:31:08,643 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:31:10,957 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:31:11,792 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:31:11,963 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:31:12,098 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:31:12,324 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning remote split to host nightly-benchmark-worker0
> 00:31:17,154 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:31:21,542 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning remote split to host nightly-benchmark-worker0
> 00:31:26,130 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:31:28,670 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:31:30,810 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:31:40,656 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:31:44,295 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:31:45,380 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:31:47,051 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:31:47,554 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:31:51,709 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:31:56,374 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:31:59,345 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:32:01,192 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:32:01,619 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:32:02,878 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:32:07,337 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:32:08,967 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning remote split to host nightly-benchmark-worker0
> 00:32:10,450 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:32:10,709 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:32:12,721 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:32:15,572 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:32:17,222 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:32:17,517 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning remote split to host nightly-benchmark-worker0
> 00:32:21,734 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:32:24,645 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning remote split to host nightly-benchmark-worker0
> 00:32:25,078 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:32:26,730 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:32:31,282 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:32:32,754 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:32:38,166 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:32:38,833 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:32:45,300 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:32:46,337 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:32:46,810 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:33:00,169 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:33:00,202 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:33:00,296 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:33:00,334 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:33:03,235 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:33:03,585 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:33:04,626 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:33:08,348 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:33:11,590 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:33:13,572 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning remote split to host nightly-benchmark-worker0
> 00:33:15,978 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:33:16,309 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:33:22,566 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning remote split to host nightly-benchmark-worker0
> 00:33:24,438 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:33:24,480 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:33:25,128 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:33:25,544 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:33:27,824 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:33:31,176 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:33:35,754 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:33:37,346 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:33:40,917 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:33:43,024 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:33:47,051 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:33:47,346 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:33:47,382 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:33:52,430 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:33:57,667 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:34:01,461 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:34:01,535 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:34:02,242 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:34:10,206 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning remote split to host nightly-benchmark-worker0
> 00:34:10,501 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:34:14,804 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:34:15,960 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:34:18,624 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning remote split to host nightly-benchmark-worker0
> 00:34:19,121 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:34:22,370 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:34:22,872 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:34:27,944 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:34:28,740 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:34:33,044 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:34:39,832 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:34:41,299 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:34:46,585 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:34:47,041 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:34:47,829 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:34:48,961 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:34:50,510 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:34:50,660 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:34:54,606 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:34:58,801 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:35:00,843 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:35:04,892 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:35:06,186 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning remote split to host nightly-benchmark-worker0
> 00:35:13,791 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:35:14,928 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:35:15,025 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning remote split to host nightly-benchmark-worker0
> 00:35:19,734 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:35:20,617 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:35:20,705 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:35:21,682 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning remote split to host nightly-benchmark-worker0
> 00:35:26,694 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:35:35,813 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:35:39,261 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:35:45,042 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:35:46,578 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:35:49,026 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:35:49,967 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:35:50,667 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:35:51,722 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:35:55,808 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:35:57,382 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:36:00,210 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:36:07,169 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:36:07,419 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:36:07,463 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:36:11,497 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:36:12,186 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning remote split to host nightly-benchmark-worker0
> 00:36:13,706 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:36:14,120 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:36:17,888 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning remote split to host nightly-benchmark-worker0
> 00:36:18,712 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:36:19,621 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:36:20,341 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:36:26,331 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:36:27,458 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning remote split to host nightly-benchmark-worker0
> 00:36:34,737 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:36:38,489 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:36:43,326 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:36:46,794 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:36:47,992 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:36:49,070 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:36:54,530 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:36:58,033 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:37:04,638 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:37:04,789 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:37:06,419 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:37:07,927 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:37:08,998 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:37:09,419 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:37:11,508 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:37:13,416 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:37:13,689 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:37:14,254 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:37:14,283 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning remote split to host nightly-benchmark-worker0
> 00:37:17,447 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:37:20,631 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:37:23,536 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning remote split to host nightly-benchmark-worker0
> 00:37:24,504 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:37:29,388 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:37:29,849 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker8
> 00:37:32,823 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:37:33,485 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:37:39,467 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:37:40,706 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:37:45,785 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:37:46,492 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:37:50,944 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:38:02,327 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:38:02,751 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:38:03,390 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:38:06,466 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:38:08,202 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:38:10,580 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:38:10,806 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker7
> 00:38:10,884 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning remote split to host nightly-benchmark-worker0
> 00:38:12,228 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:38:12,235 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:38:15,423 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker9
> 00:38:19,265 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning remote split to host nightly-benchmark-worker0
> 00:38:20,688 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:38:29,259 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning remote split to host nightly-benchmark-worker8
> 00:38:29,576 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning remote split to host nightly-benchmark-worker8
> 00:38:30,632 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:38:32,118 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker2
> 00:38:36,944 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker4
> 00:38:38,954 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning remote split to host nightly-benchmark-worker4
> 00:38:39,179 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker3
> 00:38:56,153 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning remote split to host nightly-benchmark-worker3
> 00:38:57,307 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker5
> 00:38:59,602 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker1
> 00:39:00,924 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning local split to host nightly-benchmark-worker6
> 00:39:03,417 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning remote split to host nightly-benchmark-worker3
> 00:39:03,623 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning remote split to host nightly-benchmark-worker1
> 00:39:06,606 INFO  org.apache.flink.api.common.io.LocatableInputSplitAssigner    - Assigning remote split to host nightly-benchmark-worker0
> {noformat}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Mime
View raw message