Recently I was running a job and the only way to tell how far it was and to make sure that it was still running were the JM logs with the current split assignments.
I like Fabians suggestion. But as long as we don't have good runtime monitoring in place there is a valid use case for the logs (which I otherwise find to verbose as well). On Saturday, June 20, 2015, Fabian Hueske <fhue...@gmail.com> wrote: > 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 > <javascript:;>> 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 >
