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