See
<https://builds.apache.org/job/beam_PostCommit_Java_Nexmark_Flink/933/display/redirect?page=changes>
Changes:
[lukasz.gajowy] [BEAM-5875] Add missing dependency in test-utils module
------------------------------------------
[...truncated 35.66 MB...]
INFO: Ensuring all FileSystem streams are closed for task
Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(13/16) (f7142da879b6918518a46733d7f0942b) [FINISHED]
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for Query12/Count.PerElement/Combine.perKey(Count)
-> Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(16/16) (4e1584691d6b04a45834232d2dd07b92).
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for Query12/Count.PerElement/Combine.perKey(Count)
-> Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(12/16) (9bdeb3fe3f03db03f085ef289d19a4ef).
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task
Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(16/16) (4e1584691d6b04a45834232d2dd07b92) [FINISHED]
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task
Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(12/16) (9bdeb3fe3f03db03f085ef289d19a4ef) [FINISHED]
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
fe644b885b057759cb157d859ee9be52.
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
15ab35d257a057af59d84fca4bd9886c.
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(1/16) (81f7d0529c1e64fb1aed81fb39ea6b01) switched from RUNNING to FINISHED.
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
f7142da879b6918518a46733d7f0942b.
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(11/16) (fe644b885b057759cb157d859ee9be52) switched from RUNNING to FINISHED.
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
4e1584691d6b04a45834232d2dd07b92.
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
9bdeb3fe3f03db03f085ef289d19a4ef.
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(7/16) (15ab35d257a057af59d84fca4bd9886c) switched from RUNNING to FINISHED.
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(4/16) (7da2ab737d6bb47222325c1ce8bfbe8e) switched from RUNNING to FINISHED.
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for Query12/Count.PerElement/Combine.perKey(Count)
-> Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(4/16) (7da2ab737d6bb47222325c1ce8bfbe8e).
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task
Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(4/16) (7da2ab737d6bb47222325c1ce8bfbe8e) [FINISHED]
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
7da2ab737d6bb47222325c1ce8bfbe8e.
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(13/16) (f7142da879b6918518a46733d7f0942b) switched from RUNNING to FINISHED.
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(16/16) (4e1584691d6b04a45834232d2dd07b92) switched from RUNNING to FINISHED.
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(12/16) (9bdeb3fe3f03db03f085ef289d19a4ef) switched from RUNNING to FINISHED.
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(4/16) (7da2ab737d6bb47222325c1ce8bfbe8e) switched from RUNNING to FINISHED.
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(5/16) (932866899882fb5ff5fc2eb61b5f55a4) switched from RUNNING to FINISHED.
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for Query12/Count.PerElement/Combine.perKey(Count)
-> Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(5/16) (932866899882fb5ff5fc2eb61b5f55a4).
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task
Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(5/16) (932866899882fb5ff5fc2eb61b5f55a4) [FINISHED]
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
932866899882fb5ff5fc2eb61b5f55a4.
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(5/16) (932866899882fb5ff5fc2eb61b5f55a4) switched from RUNNING to FINISHED.
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(3/16) (7a36573740a0ff4e1dc445bc7a8269a2) switched from RUNNING to FINISHED.
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(14/16) (d71f1673e204626e6e743e4af3936705) switched from RUNNING to FINISHED.
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(9/16) (0eba49ec0da57780ae8ebb4c213257c2) switched from RUNNING to FINISHED.
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for Query12/Count.PerElement/Combine.perKey(Count)
-> Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(14/16) (d71f1673e204626e6e743e4af3936705).
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for Query12/Count.PerElement/Combine.perKey(Count)
-> Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(3/16) (7a36573740a0ff4e1dc445bc7a8269a2).
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for Query12/Count.PerElement/Combine.perKey(Count)
-> Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(9/16) (0eba49ec0da57780ae8ebb4c213257c2).
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task
Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(14/16) (d71f1673e204626e6e743e4af3936705) [FINISHED]
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task
Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(9/16) (0eba49ec0da57780ae8ebb4c213257c2) [FINISHED]
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task
Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(3/16) (7a36573740a0ff4e1dc445bc7a8269a2) [FINISHED]
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
d71f1673e204626e6e743e4af3936705.
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(15/16) (2568a424e666929524b5a80711b95743) switched from RUNNING to FINISHED.
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for Query12/Count.PerElement/Combine.perKey(Count)
-> Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(15/16) (2568a424e666929524b5a80711b95743).
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task
Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(15/16) (2568a424e666929524b5a80711b95743) [FINISHED]
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(8/16) (fc14b4e0b3a84590598613f02915e3ee) switched from RUNNING to FINISHED.
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for Query12/Count.PerElement/Combine.perKey(Count)
-> Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(8/16) (fc14b4e0b3a84590598613f02915e3ee).
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task
Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(8/16) (fc14b4e0b3a84590598613f02915e3ee) [FINISHED]
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
0eba49ec0da57780ae8ebb4c213257c2.
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
7a36573740a0ff4e1dc445bc7a8269a2.
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(14/16) (d71f1673e204626e6e743e4af3936705) switched from RUNNING to FINISHED.
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
2568a424e666929524b5a80711b95743.
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
fc14b4e0b3a84590598613f02915e3ee.
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(9/16) (0eba49ec0da57780ae8ebb4c213257c2) switched from RUNNING to FINISHED.
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(3/16) (7a36573740a0ff4e1dc445bc7a8269a2) switched from RUNNING to FINISHED.
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(15/16) (2568a424e666929524b5a80711b95743) switched from RUNNING to FINISHED.
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(8/16) (fc14b4e0b3a84590598613f02915e3ee) switched from RUNNING to FINISHED.
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(10/16) (bc9de7575d7c3c02f4ddffac9035c038) switched from RUNNING to FINISHED.
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Freeing task resources for Query12/Count.PerElement/Combine.perKey(Count)
-> Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(10/16) (bc9de7575d7c3c02f4ddffac9035c038).
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.taskmanager.Task run
INFO: Ensuring all FileSystem streams are closed for task
Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(10/16) (bc9de7575d7c3c02f4ddffac9035c038) [FINISHED]
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
bc9de7575d7c3c02f4ddffac9035c038.
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Forget/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(10/16) (bc9de7575d7c3c02f4ddffac9035c038) switched from RUNNING to FINISHED.
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.executiongraph.ExecutionGraph
transitionState
INFO: Job run-jenkins-1027215928-b47cf88b (db133972a27a0c3963d5156d359b8615)
switched from state RUNNING to FINISHED.
Oct 27, 2018 9:59:40 PM
org.apache.flink.runtime.checkpoint.CheckpointCoordinator shutdown
INFO: Stopping checkpoint coordinator for job db133972a27a0c3963d5156d359b8615.
Oct 27, 2018 9:59:40 PM
org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore shutdown
INFO: Shutting down
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.dispatcher.Dispatcher
jobReachedGloballyTerminalState
INFO: Job db133972a27a0c3963d5156d359b8615 reached globally terminal state
FINISHED.
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.jobmaster.JobMaster postStop
INFO: Stopping the JobMaster for job
run-jenkins-1027215928-b47cf88b(db133972a27a0c3963d5156d359b8615).
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job db133972a27a0c3963d5156d359b8615.
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.jobmaster.JobMaster
dissolveResourceManagerConnection
INFO: Close ResourceManager connection 957c88b26bb045118a5be3d4f87c36cf:
JobManager is shutting down..
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.jobmaster.slotpool.SlotPool
suspend
INFO: Suspending SlotPool.
Oct 27, 2018 9:59:40 PM
org.apache.flink.runtime.resourcemanager.ResourceManager
closeJobManagerConnection
INFO: Disconnect job manager
833c34450f36bfb06686a4e3c8c4422a@akka://flink/user/jobmanager_25 for job
db133972a27a0c3963d5156d359b8615 from the resource manager.
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.jobmaster.slotpool.SlotPool
postStop
INFO: Stopping SlotPool.
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.minicluster.MiniCluster
closeAsync
INFO: Shutting down Flink Mini Cluster
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.rest.RestServerEndpoint
closeAsync
INFO: Shutting down rest endpoint.
Oct 27, 2018 9:59:40 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:6, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{a3879fbc657eb7caff12ecdfe2f3707b}, jobId:
db133972a27a0c3963d5156d359b8615).
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.dispatcher.Dispatcher postStop
INFO: Stopping dispatcher
akka://flink/user/dispatcher214fd681-fff5-4db9-bc89-c480145bb7a3.
Oct 27, 2018 9:59:40 PM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager close
INFO: Closing the SlotManager.
Oct 27, 2018 9:59:40 PM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager suspend
INFO: Suspending the SlotManager.
Oct 27, 2018 9:59:40 PM
org.apache.flink.runtime.registration.RetryingRegistration
lambda$startRegistration$1
INFO: Could not resolve JobManager address akka://flink/user/jobmanager_25,
retrying in 10000 ms: Could not connect to rpc endpoint under address
akka://flink/user/jobmanager_25..
Oct 27, 2018 9:59:40 PM
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager
unregisterTaskManager
INFO: Unregister TaskManager 9e5c070e9320e06eb901332aef2bbf9c from the
SlotManager.
Oct 27, 2018 9:59:40 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:9, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{c2a6e95e2fc2aeda39d59d9da1de3180}, jobId:
db133972a27a0c3963d5156d359b8615).
Oct 27, 2018 9:59:40 PM
org.apache.flink.runtime.taskexecutor.TaskExecutor$JobLeaderListenerImpl
jobManagerLostLeadership
INFO: JobManager for job db133972a27a0c3963d5156d359b8615 with leader id
833c34450f36bfb06686a4e3c8c4422a lost leadership.
Oct 27, 2018 9:59:40 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:12, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{2c5a586467ace4a359124c25ed4a3dad}, jobId:
db133972a27a0c3963d5156d359b8615).
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.dispatcher.Dispatcher
terminateJobManagerRunners
INFO: Stopping all currently running jobs of dispatcher
akka://flink/user/dispatcher214fd681-fff5-4db9-bc89-c480145bb7a3.
Oct 27, 2018 9:59:40 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:5, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{13150813bee78dae19ee0a015d1ba08a}, jobId:
db133972a27a0c3963d5156d359b8615).
Oct 27, 2018 9:59:40 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:15, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{3daaa1174af17b667e083889eea0a840}, jobId:
db133972a27a0c3963d5156d359b8615).
Oct 27, 2018 9:59:40 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:7, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{34c54d6fafeeb122a792c9180f1da5a2}, jobId:
db133972a27a0c3963d5156d359b8615).
Oct 27, 2018 9:59:40 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:11, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{f9ecbe477698538f1389852622f07752}, jobId:
db133972a27a0c3963d5156d359b8615).
Oct 27, 2018 9:59:40 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:0, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{d875dafe25eb6fac7e8f9a8198431a8c}, jobId:
db133972a27a0c3963d5156d359b8615).
Oct 27, 2018 9:59:40 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:1, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{baef164f91f4a1be1db6695d3544c529}, jobId:
db133972a27a0c3963d5156d359b8615).
Oct 27, 2018 9:59:40 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:14, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{2e105707689aaab118cee6bd56ffc06d}, jobId:
db133972a27a0c3963d5156d359b8615).
Oct 27, 2018 9:59:40 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:10, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{50c042f871ade8b7703a6486e53b5301}, jobId:
db133972a27a0c3963d5156d359b8615).
Oct 27, 2018 9:59:40 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:8, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{6a73ee8c16ad1d7d1aca84ce42f9ba96}, jobId:
db133972a27a0c3963d5156d359b8615).
Oct 27, 2018 9:59:40 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:13, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{ac69b62a20069dfd94f060f5caa255eb}, jobId:
db133972a27a0c3963d5156d359b8615).
Oct 27, 2018 9:59:40 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:4, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{d65d1178d08bc6389e1aad13c3a56a26}, jobId:
db133972a27a0c3963d5156d359b8615).
Oct 27, 2018 9:59:40 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:2, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{1352ce87590a4ca37d385bb540b1dded}, jobId:
db133972a27a0c3963d5156d359b8615).
Oct 27, 2018 9:59:40 PM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable freeSlot
INFO: Free slot TaskSlot(index:3, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{cbbcaff572c8fd478c01d3fba402da2f}, jobId:
db133972a27a0c3963d5156d359b8615).
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.taskexecutor.JobLeaderService
removeJob
INFO: Remove job db133972a27a0c3963d5156d359b8615 from job leader monitoring.
Oct 27, 2018 9:59:40 PM
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
shutDown
INFO: Shutting down stack trace sample coordinator.
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
closeJobManagerConnection
INFO: Close JobManager connection for job db133972a27a0c3963d5156d359b8615.
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.dispatcher.Dispatcher
lambda$postStop$0
INFO: Stopped dispatcher
akka://flink/user/dispatcher214fd681-fff5-4db9-bc89-c480145bb7a3.
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
postStop
INFO: Stopping TaskExecutor akka://flink/user/taskmanager_24.
Oct 27, 2018 9:59:40 PM
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO: Shutting down TaskExecutorLocalStateStoresManager.
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint
lambda$shutDownInternal$4
INFO: Removing cache directory /tmp/flink-web-ui
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.io.disk.iomanager.IOManager
shutdown
INFO: I/O manager removed spill file directory
/tmp/flink-io-61befa3f-7335-4e91-b45b-30d7f82f6eb5
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.io.network.NetworkEnvironment
shutdown
INFO: Shutting down the network environment and its components.
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.taskexecutor.JobLeaderService
stop
INFO: Stop job leader service.
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
postStop
INFO: Stopped TaskExecutor akka://flink/user/taskmanager_24.
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService
stopService
INFO: Stopping Akka RPC service.
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.blob.BlobServer close
INFO: Stopped BLOB server at 0.0.0.0:41263
Oct 27, 2018 9:59:40 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService
lambda$stopService$4
INFO: Stopped Akka RPC service.
Oct 27, 2018 9:59:40 PM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: Execution finished in 10890 msecs
Oct 27, 2018 9:59:40 PM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: Final accumulator values:
Oct 27, 2018 9:59:40 PM org.apache.beam.runners.flink.FlinkRunner
createPipelineResult
INFO: __metricscontainers :
org.apache.beam.runners.core.metrics.MetricsContainerStepMap@961362bb
2018-10-27T21:59:40.295Z Waiting for main pipeline to 'finish'
2018-10-27T21:59:40.295Z DONE Query12
2018-10-27T21:59:40.295Z 1 samples not enough to calculate steady-state event
rate
> Task :beam-sdks-java-nexmark:run FAILED
:beam-sdks-java-nexmark:run (Thread[Task worker for ':' Thread 10,5,main])
completed. Took 46.802 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':beam-sdks-java-nexmark:run'.
> Process 'command '/usr/local/asfpackages/java/jdk1.8.0_172/bin/java''
> finished with non-zero exit value 1
* Try:
Run with --stacktrace option to get the stack trace. Run with --debug option to
get more log output. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with
Gradle 5.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See
https://docs.gradle.org/4.10.2/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 2m 22s
68 actionable tasks: 15 executed, 53 up-to-date
Publishing build scan...
https://gradle.com/s/cdaiuibrqmzkk
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
