See
<https://builds.apache.org/job/beam_PostCommit_Java_Nexmark_Flink/5279/display/redirect>
Changes:
------------------------------------------
[...truncated 31.08 MB...]
INFO: Query12/Query12/Count.PerElement/Combine.perKey(Count) ->
Query12/Query12/Query12.ToResult/ParMultiDo(Anonymous) ->
Query12/Query12.Debug/ParMultiDo(Monitor) ->
Query12/Query12.Stamp/ParMultiDo(Anonymous) ->
Query12.Format/ParMultiDo(Anonymous) -> Query12.DevNull/ParMultiDo(Anonymous)
(16/16) (836a3b363ca4f619321e9f7ac794aac6) switched from DEPLOYING to RUNNING.
Mar 15, 2020 6:36:13 PM
org.apache.flink.runtime.state.heap.HeapKeyedStateBackend <init>
INFO: Initializing heap keyed state backend with stream factory.
Mar 15, 2020 6:36:13 PM
org.apache.flink.runtime.state.heap.HeapKeyedStateBackend <init>
INFO: Initializing heap keyed state backend with stream factory.
Mar 15, 2020 6:36:13 PM
org.apache.flink.runtime.state.heap.HeapKeyedStateBackend <init>
INFO: Initializing heap keyed state backend with stream factory.
Mar 15, 2020 6:36:13 PM
org.apache.flink.runtime.state.heap.HeapKeyedStateBackend <init>
INFO: Initializing heap keyed state backend with stream factory.
Mar 15, 2020 6:36:13 PM
org.apache.flink.runtime.state.heap.HeapKeyedStateBackend <init>
INFO: Initializing heap keyed state backend with stream factory.
Mar 15, 2020 6:36:13 PM
org.apache.flink.runtime.state.heap.HeapKeyedStateBackend <init>
INFO: Initializing heap keyed state backend with stream factory.
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (7/16) (c0938c81a15d8534ec8f16a4ba0f802a) switched from RUNNING
to FINISHED.
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Freeing task resources for Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (7/16) (c0938c81a15d8534ec8f16a4ba0f802a).
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Ensuring all FileSystem streams are closed for task Source:
Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (7/16) (c0938c81a15d8534ec8f16a4ba0f802a) [FINISHED]
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (7/16) c0938c81a15d8534ec8f16a4ba0f802a.
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (7/16) (c0938c81a15d8534ec8f16a4ba0f802a) switched from RUNNING
to FINISHED.
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (2/16) (208de6c0c50aa709b972ff501dca8044) switched from RUNNING
to FINISHED.
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Freeing task resources for Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (2/16) (208de6c0c50aa709b972ff501dca8044).
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Ensuring all FileSystem streams are closed for task Source:
Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (2/16) (208de6c0c50aa709b972ff501dca8044) [FINISHED]
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (2/16) 208de6c0c50aa709b972ff501dca8044.
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (2/16) (208de6c0c50aa709b972ff501dca8044) switched from RUNNING
to FINISHED.
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (5/16) (fa819d931671fa834969836112694e6b) switched from RUNNING
to FINISHED.
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Freeing task resources for Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (5/16) (fa819d931671fa834969836112694e6b).
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Ensuring all FileSystem streams are closed for task Source:
Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (5/16) (fa819d931671fa834969836112694e6b) [FINISHED]
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (5/16) fa819d931671fa834969836112694e6b.
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (5/16) (fa819d931671fa834969836112694e6b) switched from RUNNING
to FINISHED.
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (8/16) (7891b576da082589594062ec34665004) switched from RUNNING
to FINISHED.
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (10/16) (74d06758f9a2beaf8844a7d29e864927) switched from
RUNNING to FINISHED.
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Freeing task resources for Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (8/16) (7891b576da082589594062ec34665004).
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Freeing task resources for Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (10/16) (74d06758f9a2beaf8844a7d29e864927).
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Ensuring all FileSystem streams are closed for task Source:
Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (10/16) (74d06758f9a2beaf8844a7d29e864927) [FINISHED]
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Ensuring all FileSystem streams are closed for task Source:
Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (8/16) (7891b576da082589594062ec34665004) [FINISHED]
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (10/16) 74d06758f9a2beaf8844a7d29e864927.
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (8/16) 7891b576da082589594062ec34665004.
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (10/16) (74d06758f9a2beaf8844a7d29e864927) switched from
RUNNING to FINISHED.
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (8/16) (7891b576da082589594062ec34665004) switched from RUNNING
to FINISHED.
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (6/16) (906e86b64c76796bfa5faadc07076da3) switched from RUNNING
to FINISHED.
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Freeing task resources for Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (6/16) (906e86b64c76796bfa5faadc07076da3).
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Ensuring all FileSystem streams are closed for task Source:
Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (6/16) (906e86b64c76796bfa5faadc07076da3) [FINISHED]
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (6/16) 906e86b64c76796bfa5faadc07076da3.
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (6/16) (906e86b64c76796bfa5faadc07076da3) switched from RUNNING
to FINISHED.
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (1/16) (a8042fe29050ac50f8a6aa3ed0e3efc9) switched from RUNNING
to FINISHED.
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Freeing task resources for Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (1/16) (a8042fe29050ac50f8a6aa3ed0e3efc9).
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Ensuring all FileSystem streams are closed for task Source:
Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (1/16) (a8042fe29050ac50f8a6aa3ed0e3efc9) [FINISHED]
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (1/16) a8042fe29050ac50f8a6aa3ed0e3efc9.
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (1/16) (a8042fe29050ac50f8a6aa3ed0e3efc9) switched from RUNNING
to FINISHED.
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (9/16) (f2e09d46e0b1a136e313663354ebf4fe) switched from RUNNING
to FINISHED.
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Freeing task resources for Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (9/16) (f2e09d46e0b1a136e313663354ebf4fe).
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Ensuring all FileSystem streams are closed for task Source:
Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (9/16) (f2e09d46e0b1a136e313663354ebf4fe) [FINISHED]
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (9/16) f2e09d46e0b1a136e313663354ebf4fe.
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (9/16) (f2e09d46e0b1a136e313663354ebf4fe) switched from RUNNING
to FINISHED.
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (14/16) (0e6b03d26c34d6dd6833099b77dbc616) switched from
RUNNING to FINISHED.
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Freeing task resources for Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (14/16) (0e6b03d26c34d6dd6833099b77dbc616).
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Ensuring all FileSystem streams are closed for task Source:
Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (14/16) (0e6b03d26c34d6dd6833099b77dbc616) [FINISHED]
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (14/16) 0e6b03d26c34d6dd6833099b77dbc616.
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (11/16) (8ee78146b5dc948aa2bb26759c556d51) switched from
RUNNING to FINISHED.
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Freeing task resources for Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (11/16) (8ee78146b5dc948aa2bb26759c556d51).
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Ensuring all FileSystem streams are closed for task Source:
Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (11/16) (8ee78146b5dc948aa2bb26759c556d51) [FINISHED]
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (3/16) (0b63f25525112d62a9041d379257fb98) switched from RUNNING
to FINISHED.
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (11/16) 8ee78146b5dc948aa2bb26759c556d51.
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Freeing task resources for Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (3/16) (0b63f25525112d62a9041d379257fb98).
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (14/16) (0e6b03d26c34d6dd6833099b77dbc616) switched from
RUNNING to FINISHED.
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Ensuring all FileSystem streams are closed for task Source:
Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (3/16) (0b63f25525112d62a9041d379257fb98) [FINISHED]
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (3/16) 0b63f25525112d62a9041d379257fb98.
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (11/16) (8ee78146b5dc948aa2bb26759c556d51) switched from
RUNNING to FINISHED.
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (3/16) (0b63f25525112d62a9041d379257fb98) switched from RUNNING
to FINISHED.
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (12/16) (4146355ff51cea00a8986e9e11445d95) switched from
RUNNING to FINISHED.
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Freeing task resources for Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (12/16) (4146355ff51cea00a8986e9e11445d95).
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Ensuring all FileSystem streams are closed for task Source:
Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (12/16) (4146355ff51cea00a8986e9e11445d95) [FINISHED]
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (12/16) 4146355ff51cea00a8986e9e11445d95.
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (12/16) (4146355ff51cea00a8986e9e11445d95) switched from
RUNNING to FINISHED.
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (4/16) (63f23d4f99eb8f77e7c417d6a87941bc) switched from RUNNING
to FINISHED.
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Freeing task resources for Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (4/16) (63f23d4f99eb8f77e7c417d6a87941bc).
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Ensuring all FileSystem streams are closed for task Source:
Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (4/16) (63f23d4f99eb8f77e7c417d6a87941bc) [FINISHED]
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (4/16) 63f23d4f99eb8f77e7c417d6a87941bc.
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (4/16) (63f23d4f99eb8f77e7c417d6a87941bc) switched from RUNNING
to FINISHED.
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (15/16) (684c88cb86acb46b73d165143c169757) switched from
RUNNING to FINISHED.
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Freeing task resources for Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (15/16) (684c88cb86acb46b73d165143c169757).
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Ensuring all FileSystem streams are closed for task Source:
Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (15/16) (684c88cb86acb46b73d165143c169757) [FINISHED]
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (15/16) 684c88cb86acb46b73d165143c169757.
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (15/16) (684c88cb86acb46b73d165143c169757) switched from
RUNNING to FINISHED.
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (16/16) (69bc523342874ee50c68f8571ddb7fb5) switched from
RUNNING to FINISHED.
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Freeing task resources for Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (16/16) (69bc523342874ee50c68f8571ddb7fb5).
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Ensuring all FileSystem streams are closed for task Source:
Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (16/16) (69bc523342874ee50c68f8571ddb7fb5) [FINISHED]
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (16/16) 69bc523342874ee50c68f8571ddb7fb5.
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (16/16) (69bc523342874ee50c68f8571ddb7fb5) switched from
RUNNING to FINISHED.
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (13/16) (30fa0d2752de27713d45011cdc6795cc) switched from
RUNNING to FINISHED.
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Freeing task resources for Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (13/16) (30fa0d2752de27713d45011cdc6795cc).
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Ensuring all FileSystem streams are closed for task Source:
Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (13/16) (30fa0d2752de27713d45011cdc6795cc) [FINISHED]
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (13/16) 30fa0d2752de27713d45011cdc6795cc.
Mar 15, 2020 6:36:13 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Source: Query12.ReadUnbounded -> Flat Map ->
Query12/Query12.Monitor/ParMultiDo(Monitor) ->
Query12/Query12.Snoop/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/IsBid/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/justBids/AsBid/ParMultiDo(Anonymous) ->
Query12/Query12/ParDo(Anonymous)/ParMultiDo(Anonymous) ->
Query12/Query12/Window.Into()/Window.Assign.out ->
Query12/Query12/Count.PerElement/Init/Map/ParMultiDo(Anonymous) ->
ToKeyedWorkItem (13/16) (30fa0d2752de27713d45011cdc6795cc) switched from
RUNNING to FINISHED.
FATAL: command execution failed
java.io.IOException: Backing channel 'JNLP4-connect connection from
81.144.66.34.bc.googleusercontent.com/34.66.144.81:38774' is disconnected.
at
hudson.remoting.RemoteInvocationHandler.channelOrFail(RemoteInvocationHandler.java:214)
at
hudson.remoting.RemoteInvocationHandler.invoke(RemoteInvocationHandler.java:283)
at com.sun.proxy.$Proxy126.isAlive(Unknown Source)
at hudson.Launcher$RemoteLauncher$ProcImpl.isAlive(Launcher.java:1150)
at hudson.Launcher$RemoteLauncher$ProcImpl.join(Launcher.java:1142)
at hudson.Launcher$ProcStarter.join(Launcher.java:470)
at hudson.plugins.gradle.Gradle.perform(Gradle.java:317)
at hudson.tasks.BuildStepMonitor$1.perform(BuildStepMonitor.java:20)
at
hudson.model.AbstractBuild$AbstractBuildExecution.perform(AbstractBuild.java:741)
at hudson.model.Build$BuildExecution.build(Build.java:206)
at hudson.model.Build$BuildExecution.doRun(Build.java:163)
at
hudson.model.AbstractBuild$AbstractBuildExecution.run(AbstractBuild.java:504)
at hudson.model.Run.execute(Run.java:1815)
at hudson.model.FreeStyleBuild.run(FreeStyleBuild.java:43)
at hudson.model.ResourceController.execute(ResourceController.java:97)
at hudson.model.Executor.run(Executor.java:429)
Caused by: java.nio.channels.ClosedChannelException
at
org.jenkinsci.remoting.protocol.impl.ChannelApplicationLayer.onReadClosed(ChannelApplicationLayer.java:209)
at
org.jenkinsci.remoting.protocol.ApplicationLayer.onRecvClosed(ApplicationLayer.java:222)
at
org.jenkinsci.remoting.protocol.ProtocolStack$Ptr.onRecvClosed(ProtocolStack.java:816)
at
org.jenkinsci.remoting.protocol.FilterLayer.onRecvClosed(FilterLayer.java:287)
at
org.jenkinsci.remoting.protocol.impl.SSLEngineFilterLayer.onRecvClosed(SSLEngineFilterLayer.java:181)
at
org.jenkinsci.remoting.protocol.impl.SSLEngineFilterLayer.switchToNoSecure(SSLEngineFilterLayer.java:283)
at
org.jenkinsci.remoting.protocol.impl.SSLEngineFilterLayer.processWrite(SSLEngineFilterLayer.java:503)
at
org.jenkinsci.remoting.protocol.impl.SSLEngineFilterLayer.processQueuedWrites(SSLEngineFilterLayer.java:248)
at
org.jenkinsci.remoting.protocol.impl.SSLEngineFilterLayer.doSend(SSLEngineFilterLayer.java:200)
at
org.jenkinsci.remoting.protocol.impl.SSLEngineFilterLayer.doCloseSend(SSLEngineFilterLayer.java:213)
at
org.jenkinsci.remoting.protocol.ProtocolStack$Ptr.doCloseSend(ProtocolStack.java:784)
at
org.jenkinsci.remoting.protocol.ApplicationLayer.doCloseWrite(ApplicationLayer.java:173)
at
org.jenkinsci.remoting.protocol.impl.ChannelApplicationLayer$ByteBufferCommandTransport.closeWrite(ChannelApplicationLayer.java:314)
at hudson.remoting.Channel.close(Channel.java:1452)
at hudson.remoting.Channel.close(Channel.java:1405)
at hudson.slaves.SlaveComputer.closeChannel(SlaveComputer.java:847)
at hudson.slaves.SlaveComputer.kill(SlaveComputer.java:814)
at hudson.model.AbstractCIBase.killComputer(AbstractCIBase.java:89)
at jenkins.model.Jenkins.access$2100(Jenkins.java:312)
at jenkins.model.Jenkins$19.run(Jenkins.java:3464)
at hudson.model.Queue._withLock(Queue.java:1379)
at hudson.model.Queue.withLock(Queue.java:1256)
at jenkins.model.Jenkins._cleanUpDisconnectComputers(Jenkins.java:3458)
at jenkins.model.Jenkins.cleanUp(Jenkins.java:3336)
at hudson.WebAppMain.contextDestroyed(WebAppMain.java:379)
at
org.apache.catalina.core.StandardContext.listenerStop(StandardContext.java:4732)
at
org.apache.catalina.core.StandardContext.stopInternal(StandardContext.java:5396)
at org.apache.catalina.util.LifecycleBase.stop(LifecycleBase.java:257)
at
org.apache.catalina.core.ContainerBase$StopChild.call(ContainerBase.java:1400)
at
org.apache.catalina.core.ContainerBase$StopChild.call(ContainerBase.java:1389)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at
org.apache.tomcat.util.threads.InlineExecutorService.execute(InlineExecutorService.java:75)
at
java.util.concurrent.AbstractExecutorService.submit(AbstractExecutorService.java:134)
at
org.apache.catalina.core.ContainerBase.stopInternal(ContainerBase.java:976)
at org.apache.catalina.util.LifecycleBase.stop(LifecycleBase.java:257)
at
org.apache.catalina.core.ContainerBase$StopChild.call(ContainerBase.java:1400)
at
org.apache.catalina.core.ContainerBase$StopChild.call(ContainerBase.java:1389)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at
org.apache.tomcat.util.threads.InlineExecutorService.execute(InlineExecutorService.java:75)
at
java.util.concurrent.AbstractExecutorService.submit(AbstractExecutorService.java:134)
at
org.apache.catalina.core.ContainerBase.stopInternal(ContainerBase.java:976)
at org.apache.catalina.util.LifecycleBase.stop(LifecycleBase.java:257)
at
org.apache.catalina.core.StandardService.stopInternal(StandardService.java:473)
at org.apache.catalina.util.LifecycleBase.stop(LifecycleBase.java:257)
at
org.apache.catalina.core.StandardServer.stopInternal(StandardServer.java:994)
at org.apache.catalina.util.LifecycleBase.stop(LifecycleBase.java:257)
at org.apache.catalina.startup.Catalina.stop(Catalina.java:706)
at org.apache.catalina.startup.Catalina.start(Catalina.java:668)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.apache.catalina.startup.Bootstrap.start(Bootstrap.java:344)
at org.apache.catalina.startup.Bootstrap.main(Bootstrap.java:475)
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
ERROR: apache-beam-jenkins-16 is offline; cannot locate JDK 1.8 (latest)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
