The ratio could be directly logged. That would be easier that estimating the ratio from potentially hundreds of log statements of several data sources. On Jun 20, 2015 22:49, "Robert Metzger (JIRA)" <j...@apache.org> wrote:
> > [ > https://issues.apache.org/jira/browse/FLINK-2252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14594800#comment-14594800 > ] > > Robert Metzger commented on FLINK-2252: > --------------------------------------- > > By not logging the local splits anymore, users can not easily get the > local/remote assignment ratio. > I'm still not convinced of this change. > > > 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.ap...
