flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Fabian Hueske <fhue...@gmail.com>
Subject Re: [jira] [Commented] (FLINK-2252) Reduce local input split assignment log level from INFO to DEBUG
Date Sat, 20 Jun 2015 21:00:01 GMT
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)" <jira@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...

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message