Build failed in Jenkins: beam_PreCommit_Java_Cron #141

Apache Jenkins Server Tue, 24 Jul 2018 06:29:45 -0700

See 
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/141/display/redirect>


------------------------------------------
[...truncated 6.37 MB...]
    [flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Create.Values/Read(CreateSource)
 (1/1) (b68fbed4541341b7908928190f3f64fe) switched from CREATED to SCHEDULED.
    [flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnwritten/ParMultiDo(WriteShardsIntoTempFiles)
 -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/DropShardNum/ParMultiDo(Anonymous)
 (1/1) (505e37b2a8fe119d912563baa81e223f) switched from CREATED to SCHEDULED.
    [flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1) (b3cfc35fad0a94f34dcbcb5481c9b02e) switched from 
CREATED to SCHEDULED.
    [flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map/ParMultiDo(Anonymous)
 -> Map (1/1) (2093eb711bdef48a7ee795e6c41cfd07) switched from CREATED to 
SCHEDULED.
    [flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Reify.ReifyView/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Values/Values/Map/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Finalize/ParMultiDo(Finalize) 
-> TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Pair 
with random key/ParMultiDo(AssignShard) -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign.out
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ReifyOriginalTimestamps/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1) (b5070bdd71ecc5c7277e2d77642047b8) switched from 
CREATED to SCHEDULED.
    [flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Values/Values/Map/ParMultiDo(Anonymous)
 (1/1) (314cfafdcaae1b61d0bf9522430a2df7) switched from CREATED to SCHEDULED.
    [flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: 
GenerateSequence/Read(BoundedCountingSource) -> 
ParDo(Anonymous)/ParMultiDo(Anonymous) -> 
TextIO.Write/WriteFiles/RewindowIntoGlobal/Window.Assign.out -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnshardedBundles 
-> ToKeyedWorkItem (1/1) (7799c912b2d53a8238b947f1a771c866) switched from 
SCHEDULED to DEPLOYING.
    [flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Source: 
GenerateSequence/Read(BoundedCountingSource) -> 
ParDo(Anonymous)/ParMultiDo(Anonymous) -> 
TextIO.Write/WriteFiles/RewindowIntoGlobal/Window.Assign.out -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnshardedBundles 
-> ToKeyedWorkItem (1/1) (attempt #0) to localhost
    [flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Create.Values/Read(CreateSource)
 (1/1) (b68fbed4541341b7908928190f3f64fe) switched from SCHEDULED to DEPLOYING.
    [flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Source: 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Create.Values/Read(CreateSource)
 (1/1) (attempt #0) to localhost
    [flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnwritten/ParMultiDo(WriteShardsIntoTempFiles)
 -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/DropShardNum/ParMultiDo(Anonymous)
 (1/1) (505e37b2a8fe119d912563baa81e223f) switched from SCHEDULED to DEPLOYING.
    [flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnwritten/ParMultiDo(WriteShardsIntoTempFiles)
 -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/DropShardNum/ParMultiDo(Anonymous)
 (1/1) (attempt #0) to localhost
    [flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1) (b3cfc35fad0a94f34dcbcb5481c9b02e) switched from 
SCHEDULED to DEPLOYING.
    [flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1) (attempt #0) to localhost
    [flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map/ParMultiDo(Anonymous)
 -> Map (1/1) (2093eb711bdef48a7ee795e6c41cfd07) switched from SCHEDULED to 
DEPLOYING.
    [flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map/ParMultiDo(Anonymous)
 -> Map (1/1) (attempt #0) to localhost
    [flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Reify.ReifyView/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Values/Values/Map/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Finalize/ParMultiDo(Finalize) 
-> TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Pair 
with random key/ParMultiDo(AssignShard) -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign.out
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ReifyOriginalTimestamps/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1) (b5070bdd71ecc5c7277e2d77642047b8) switched from 
SCHEDULED to DEPLOYING.
    [flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Reify.ReifyView/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Values/Values/Map/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Finalize/ParMultiDo(Finalize) 
-> TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Pair 
with random key/ParMultiDo(AssignShard) -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign.out
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ReifyOriginalTimestamps/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1) (attempt #0) to localhost
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.client.JobSubmissionClientActor - Job 
36a824611e77501ac3de2dc24d775bad was successfully submitted to the JobManager 
akka://flink/deadLetters.
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.client.JobSubmissionClientActor - 07/24/2018 12:11:07 
Job execution switched to status RUNNING.
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.client.JobSubmissionClientActor - 07/24/2018 12:11:07 
Source: GenerateSequence/Read(BoundedCountingSource) -> 
ParDo(Anonymous)/ParMultiDo(Anonymous) -> 
TextIO.Write/WriteFiles/RewindowIntoGlobal/Window.Assign.out -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnshardedBundles 
-> ToKeyedWorkItem(1/1) switched to SCHEDULED 
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.client.JobSubmissionClientActor - 07/24/2018 12:11:07 
Source: 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Create.Values/Read(CreateSource)(1/1)
 switched to SCHEDULED 
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.client.JobSubmissionClientActor - 07/24/2018 12:11:07 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnwritten/ParMultiDo(WriteShardsIntoTempFiles)
 -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/DropShardNum/ParMultiDo(Anonymous)(1/1)
 switched to SCHEDULED 
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.client.JobSubmissionClientActor - 07/24/2018 12:11:07 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem(1/1) switched to SCHEDULED 
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.client.JobSubmissionClientActor - 07/24/2018 12:11:07 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map/ParMultiDo(Anonymous)
 -> Map(1/1) switched to SCHEDULED 
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.client.JobSubmissionClientActor - 07/24/2018 12:11:07 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Reify.ReifyView/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Values/Values/Map/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Finalize/ParMultiDo(Finalize) 
-> TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Pair 
with random key/ParMultiDo(AssignShard) -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign.out
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ReifyOriginalTimestamps/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem(1/1) switched to SCHEDULED 
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.client.JobSubmissionClientActor - 07/24/2018 12:11:07 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Values/Values/Map/ParMultiDo(Anonymous)(1/1)
 switched to SCHEDULED 
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.client.JobSubmissionClientActor - 07/24/2018 12:11:07 
Source: GenerateSequence/Read(BoundedCountingSource) -> 
ParDo(Anonymous)/ParMultiDo(Anonymous) -> 
TextIO.Write/WriteFiles/RewindowIntoGlobal/Window.Assign.out -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnshardedBundles 
-> ToKeyedWorkItem(1/1) switched to DEPLOYING 
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.client.JobSubmissionClientActor - 07/24/2018 12:11:07 
Source: 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Create.Values/Read(CreateSource)(1/1)
 switched to DEPLOYING 
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.client.JobSubmissionClientActor - 07/24/2018 12:11:07 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnwritten/ParMultiDo(WriteShardsIntoTempFiles)
 -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/DropShardNum/ParMultiDo(Anonymous)(1/1)
 switched to DEPLOYING 
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.client.JobSubmissionClientActor - 07/24/2018 12:11:07 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem(1/1) switched to DEPLOYING 
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.client.JobSubmissionClientActor - 07/24/2018 12:11:07 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map/ParMultiDo(Anonymous)
 -> Map(1/1) switched to DEPLOYING 
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.client.JobSubmissionClientActor - 07/24/2018 12:11:07 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Reify.ReifyView/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Values/Values/Map/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Finalize/ParMultiDo(Finalize) 
-> TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Pair 
with random key/ParMultiDo(AssignShard) -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign.out
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ReifyOriginalTimestamps/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem(1/1) switched to DEPLOYING 
    [flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Values/Values/Map/ParMultiDo(Anonymous)
 (1/1) (314cfafdcaae1b61d0bf9522430a2df7) switched from SCHEDULED to DEPLOYING.
    [flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Values/Values/Map/ParMultiDo(Anonymous)
 (1/1) (attempt #0) to localhost
    [flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.taskmanager.TaskManager - Received task Source: 
GenerateSequence/Read(BoundedCountingSource) -> 
ParDo(Anonymous)/ParMultiDo(Anonymous) -> 
TextIO.Write/WriteFiles/RewindowIntoGlobal/Window.Assign.out -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnshardedBundles 
-> ToKeyedWorkItem (1/1)
    [Source: GenerateSequence/Read(BoundedCountingSource) -> 
ParDo(Anonymous)/ParMultiDo(Anonymous) -> 
TextIO.Write/WriteFiles/RewindowIntoGlobal/Window.Assign.out -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnshardedBundles 
-> ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - 
Source: GenerateSequence/Read(BoundedCountingSource) -> 
ParDo(Anonymous)/ParMultiDo(Anonymous) -> 
TextIO.Write/WriteFiles/RewindowIntoGlobal/Window.Assign.out -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnshardedBundles 
-> ToKeyedWorkItem (1/1) (7799c912b2d53a8238b947f1a771c866) switched from 
CREATED to DEPLOYING.
    [Source: GenerateSequence/Read(BoundedCountingSource) -> 
ParDo(Anonymous)/ParMultiDo(Anonymous) -> 
TextIO.Write/WriteFiles/RewindowIntoGlobal/Window.Assign.out -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnshardedBundles 
-> ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - 
Creating FileSystem stream leak safety net for task Source: 
GenerateSequence/Read(BoundedCountingSource) -> 
ParDo(Anonymous)/ParMultiDo(Anonymous) -> 
TextIO.Write/WriteFiles/RewindowIntoGlobal/Window.Assign.out -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnshardedBundles 
-> ToKeyedWorkItem (1/1) (7799c912b2d53a8238b947f1a771c866) [DEPLOYING]
    [flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.client.JobSubmissionClientActor - 07/24/2018 12:11:07 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Values/Values/Map/ParMultiDo(Anonymous)(1/1)
 switched to DEPLOYING 
    [flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.taskmanager.TaskManager - Received task Source: 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Create.Values/Read(CreateSource)
 (1/1)
    [Source: 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Create.Values/Read(CreateSource)
 (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Source: 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Create.Values/Read(CreateSource)
 (1/1) (b68fbed4541341b7908928190f3f64fe) switched from CREATED to DEPLOYING.
    [Source: 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Create.Values/Read(CreateSource)
 (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem 
stream leak safety net for task Source: 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Create.Values/Read(CreateSource)
 (1/1) (b68fbed4541341b7908928190f3f64fe) [DEPLOYING]
    [flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.taskmanager.TaskManager - Received task 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnwritten/ParMultiDo(WriteShardsIntoTempFiles)
 -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/DropShardNum/ParMultiDo(Anonymous)
 (1/1)
    [TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnwritten/ParMultiDo(WriteShardsIntoTempFiles)
 -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/DropShardNum/ParMultiDo(Anonymous)
 (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnwritten/ParMultiDo(WriteShardsIntoTempFiles)
 -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/DropShardNum/ParMultiDo(Anonymous)
 (1/1) (505e37b2a8fe119d912563baa81e223f) switched from CREATED to DEPLOYING.
    [TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnwritten/ParMultiDo(WriteShardsIntoTempFiles)
 -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/DropShardNum/ParMultiDo(Anonymous)
 (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem 
stream leak safety net for task 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnwritten/ParMultiDo(WriteShardsIntoTempFiles)
 -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/DropShardNum/ParMultiDo(Anonymous)
 (1/1) (505e37b2a8fe119d912563baa81e223f) [DEPLOYING]
    [flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.taskmanager.TaskManager - Received task 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1)
    
[TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1) (b3cfc35fad0a94f34dcbcb5481c9b02e) switched from 
CREATED to DEPLOYING.
    
[TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - 
Creating FileSystem stream leak safety net for task 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1) (b3cfc35fad0a94f34dcbcb5481c9b02e) [DEPLOYING]
    [flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.taskmanager.TaskManager - Received task 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map/ParMultiDo(Anonymous)
 -> Map (1/1)
    
[TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map/ParMultiDo(Anonymous)
 -> Map (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map/ParMultiDo(Anonymous)
 -> Map (1/1) (2093eb711bdef48a7ee795e6c41cfd07) switched from CREATED to 
DEPLOYING.
    
[TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map/ParMultiDo(Anonymous)
 -> Map (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Creating 
FileSystem stream leak safety net for task 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map/ParMultiDo(Anonymous)
 -> Map (1/1) (2093eb711bdef48a7ee795e6c41cfd07) [DEPLOYING]
    [flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.taskmanager.TaskManager - Received task 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Reify.ReifyView/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Values/Values/Map/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Finalize/ParMultiDo(Finalize) 
-> TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Pair 
with random key/ParMultiDo(AssignShard) -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign.out
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ReifyOriginalTimestamps/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1)
    
[TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Reify.ReifyView/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Values/Values/Map/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Finalize/ParMultiDo(Finalize) 
-> TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Pair 
with random key/ParMultiDo(AssignShard) -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign.out
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ReifyOriginalTimestamps/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Reify.ReifyView/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Values/Values/Map/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Finalize/ParMultiDo(Finalize) 
-> TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Pair 
with random key/ParMultiDo(AssignShard) -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign.out
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ReifyOriginalTimestamps/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1) (b5070bdd71ecc5c7277e2d77642047b8) switched from 
CREATED to DEPLOYING.
    
[TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Reify.ReifyView/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Values/Values/Map/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Finalize/ParMultiDo(Finalize) 
-> TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Pair 
with random key/ParMultiDo(AssignShard) -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign.out
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ReifyOriginalTimestamps/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - 
Creating FileSystem stream leak safety net for task 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Reify.ReifyView/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Values/Values/Map/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Finalize/ParMultiDo(Finalize) 
-> TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Pair 
with random key/ParMultiDo(AssignShard) -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign.out
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ReifyOriginalTimestamps/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1) (b5070bdd71ecc5c7277e2d77642047b8) [DEPLOYING]
    [flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.taskmanager.TaskManager - Received task 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Values/Values/Map/ParMultiDo(Anonymous)
 (1/1)
    
[TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Values/Values/Map/ParMultiDo(Anonymous)
 (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Values/Values/Map/ParMultiDo(Anonymous)
 (1/1) (314cfafdcaae1b61d0bf9522430a2df7) switched from CREATED to DEPLOYING.
    
[TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Values/Values/Map/ParMultiDo(Anonymous)
 (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem 
stream leak safety net for task 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Values/Values/Map/ParMultiDo(Anonymous)
 (1/1) (314cfafdcaae1b61d0bf9522430a2df7) [DEPLOYING]
    [Source: GenerateSequence/Read(BoundedCountingSource) -> 
ParDo(Anonymous)/ParMultiDo(Anonymous) -> 
TextIO.Write/WriteFiles/RewindowIntoGlobal/Window.Assign.out -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnshardedBundles 
-> ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - 
Loading JAR files for task Source: GenerateSequence/Read(BoundedCountingSource) 
-> ParDo(Anonymous)/ParMultiDo(Anonymous) -> 
TextIO.Write/WriteFiles/RewindowIntoGlobal/Window.Assign.out -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnshardedBundles 
-> ToKeyedWorkItem (1/1) (7799c912b2d53a8238b947f1a771c866) [DEPLOYING].
    [Source: GenerateSequence/Read(BoundedCountingSource) -> 
ParDo(Anonymous)/ParMultiDo(Anonymous) -> 
TextIO.Write/WriteFiles/RewindowIntoGlobal/Window.Assign.out -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnshardedBundles 
-> ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - 
Registering task at network: Source: 
GenerateSequence/Read(BoundedCountingSource) -> 
ParDo(Anonymous)/ParMultiDo(Anonymous) -> 
TextIO.Write/WriteFiles/RewindowIntoGlobal/Window.Assign.out -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnshardedBundles 
-> ToKeyedWorkItem (1/1) (7799c912b2d53a8238b947f1a771c866) [DEPLOYING].
    [Source: 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Create.Values/Read(CreateSource)
 (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for 
task Source: 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Create.Values/Read(CreateSource)
 (1/1) (b68fbed4541341b7908928190f3f64fe) [DEPLOYING].
    [Source: 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Create.Values/Read(CreateSource)
 (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at 
network: Source: 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Create.Values/Read(CreateSource)
 (1/1) (b68fbed4541341b7908928190f3f64fe) [DEPLOYING].
    [Source: 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Create.Values/Read(CreateSource)
 (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Source: 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Create.Values/Read(CreateSource)
 (1/1) (b68fbed4541341b7908928190f3f64fe) switched from DEPLOYING to RUNNING.
    [Source: 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Create.Values/Read(CreateSource)
 (1/1)] INFO org.apache.flink.streaming.runtime.tasks.StreamTask - No state 
backend has been configured, using default (Memory / JobManager) 
MemoryStateBackend (data in heap memory / checkpoints to JobManager) 
(checkpoints: 'null', savepoints: 'null', asynchronous: TRUE, maxStateSize: 
5242880)
    [flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Create.Values/Read(CreateSource)
 (1/1) (b68fbed4541341b7908928190f3f64fe) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.client.JobSubmissionClientActor - 07/24/2018 12:11:07 
Source: 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Create.Values/Read(CreateSource)(1/1)
 switched to RUNNING 
    [Source: 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Create.Values/Read(CreateSource)
 (1/1)] WARN org.apache.flink.metrics.MetricGroup - The operator name Source: 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Create.Values/Read(CreateSource)
 exceeded the 80 characters length limit and was truncated.
    [Source: GenerateSequence/Read(BoundedCountingSource) -> 
ParDo(Anonymous)/ParMultiDo(Anonymous) -> 
TextIO.Write/WriteFiles/RewindowIntoGlobal/Window.Assign.out -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnshardedBundles 
-> ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - 
Source: GenerateSequence/Read(BoundedCountingSource) -> 
ParDo(Anonymous)/ParMultiDo(Anonymous) -> 
TextIO.Write/WriteFiles/RewindowIntoGlobal/Window.Assign.out -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnshardedBundles 
-> ToKeyedWorkItem (1/1) (7799c912b2d53a8238b947f1a771c866) switched from 
DEPLOYING to RUNNING.
    
[TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Values/Values/Map/ParMultiDo(Anonymous)
 (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for 
task 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Values/Values/Map/ParMultiDo(Anonymous)
 (1/1) (314cfafdcaae1b61d0bf9522430a2df7) [DEPLOYING].
    [Source: GenerateSequence/Read(BoundedCountingSource) -> 
ParDo(Anonymous)/ParMultiDo(Anonymous) -> 
TextIO.Write/WriteFiles/RewindowIntoGlobal/Window.Assign.out -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnshardedBundles 
-> ToKeyedWorkItem (1/1)] INFO 
org.apache.flink.streaming.runtime.tasks.StreamTask - No state backend has been 
configured, using default (Memory / JobManager) MemoryStateBackend (data in 
heap memory / checkpoints to JobManager) (checkpoints: 'null', savepoints: 
'null', asynchronous: TRUE, maxStateSize: 5242880)
    
[TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Values/Values/Map/ParMultiDo(Anonymous)
 (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at 
network: 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Values/Values/Map/ParMultiDo(Anonymous)
 (1/1) (314cfafdcaae1b61d0bf9522430a2df7) [DEPLOYING].
    
[TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Values/Values/Map/ParMultiDo(Anonymous)
 (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Values/Values/Map/ParMultiDo(Anonymous)
 (1/1) (314cfafdcaae1b61d0bf9522430a2df7) switched from DEPLOYING to RUNNING.
    
[TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Values/Values/Map/ParMultiDo(Anonymous)
 (1/1)] INFO org.apache.flink.streaming.runtime.tasks.StreamTask - No state 
backend has been configured, using default (Memory / JobManager) 
MemoryStateBackend (data in heap memory / checkpoints to JobManager) 
(checkpoints: 'null', savepoints: 'null', asynchronous: TRUE, maxStateSize: 
5242880)
    [Source: 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Create.Values/Read(CreateSource)
 (1/1)] INFO 
org.apache.beam.runners.flink.translation.wrappers.streaming.io.UnboundedSourceWrapper
 - No restore state for UnbounedSourceWrapper.
    [Source: 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Create.Values/Read(CreateSource)
 (1/1)] INFO 
org.apache.beam.runners.flink.translation.wrappers.streaming.io.UnboundedSourceWrapper
 - Unbounded Flink Source 0/1 is reading from sources: 
[org.apache.beam.runners.core.construction.UnboundedReadFromBoundedSource$BoundedToUnboundedSourceAdapter@2d115a4d]
    
[TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Reify.ReifyView/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Values/Values/Map/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Finalize/ParMultiDo(Finalize) 
-> TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Pair 
with random key/ParMultiDo(AssignShard) -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign.out
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ReifyOriginalTimestamps/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - 
Loading JAR files for task 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Reify.ReifyView/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Values/Values/Map/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Finalize/ParMultiDo(Finalize) 
-> TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Pair 
with random key/ParMultiDo(AssignShard) -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign.out
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ReifyOriginalTimestamps/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1) (b5070bdd71ecc5c7277e2d77642047b8) [DEPLOYING].
    
[TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Reify.ReifyView/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Values/Values/Map/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Finalize/ParMultiDo(Finalize) 
-> TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Pair 
with random key/ParMultiDo(AssignShard) -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign.out
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ReifyOriginalTimestamps/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - 
Registering task at network: 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Reify.ReifyView/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Values/Values/Map/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Finalize/ParMultiDo(Finalize) 
-> TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Pair 
with random key/ParMultiDo(AssignShard) -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign.out
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ReifyOriginalTimestamps/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1) (b5070bdd71ecc5c7277e2d77642047b8) [DEPLOYING].
    
[TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Values/Values/Map/ParMultiDo(Anonymous)
 (1/1)] WARN org.apache.flink.metrics.MetricGroup - The operator name 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Values/Values/Map/ParMultiDo(Anonymous)
 exceeded the 80 characters length limit and was truncated.
    
[TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Values/Values/Map/ParMultiDo(Anonymous)
 (1/1)] WARN org.apache.flink.metrics.MetricGroup - The operator name 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
 exceeded the 80 characters length limit and was truncated.
    
[TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map/ParMultiDo(Anonymous)
 -> Map (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR 
files for task 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map/ParMultiDo(Anonymous)
 -> Map (1/1) (2093eb711bdef48a7ee795e6c41cfd07) [DEPLOYING].
    
[TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Reify.ReifyView/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Values/Values/Map/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Finalize/ParMultiDo(Finalize) 
-> TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Pair 
with random key/ParMultiDo(AssignShard) -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign.out
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ReifyOriginalTimestamps/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Reify.ReifyView/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Values/Values/Map/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Finalize/ParMultiDo(Finalize) 
-> TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Pair 
with random key/ParMultiDo(AssignShard) -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign.out
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ReifyOriginalTimestamps/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1) (b5070bdd71ecc5c7277e2d77642047b8) switched from 
DEPLOYING to RUNNING.
    
[TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Reify.ReifyView/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Values/Values/Map/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Finalize/ParMultiDo(Finalize) 
-> TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Pair 
with random key/ParMultiDo(AssignShard) -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign.out
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ReifyOriginalTimestamps/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1)] INFO 
org.apache.flink.streaming.runtime.tasks.StreamTask - No state backend has been 
configured, using default (Memory / JobManager) MemoryStateBackend (data in 
heap memory / checkpoints to JobManager) (checkpoints: 'null', savepoints: 
'null', asynchronous: TRUE, maxStateSize: 5242880)
    
[TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map/ParMultiDo(Anonymous)
 -> Map (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Registering 
task at network: 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map/ParMultiDo(Anonymous)
 -> Map (1/1) (2093eb711bdef48a7ee795e6c41cfd07) [DEPLOYING].
    
[TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - 
Loading JAR files for task 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1) (b3cfc35fad0a94f34dcbcb5481c9b02e) [DEPLOYING].
    
[TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - 
Registering task at network: 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1) (b3cfc35fad0a94f34dcbcb5481c9b02e) [DEPLOYING].
    
[TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Values/Values/Map/ParMultiDo(Anonymous)
 (1/1)] WARN org.apache.flink.metrics.MetricGroup - The operator name 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
 exceeded the 80 characters length limit and was truncated.
    [TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnwritten/ParMultiDo(WriteShardsIntoTempFiles)
 -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/DropShardNum/ParMultiDo(Anonymous)
 (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for 
task TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnwritten/ParMultiDo(WriteShardsIntoTempFiles)
 -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/DropShardNum/ParMultiDo(Anonymous)
 (1/1) (505e37b2a8fe119d912563baa81e223f) [DEPLOYING].
    [TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnwritten/ParMultiDo(WriteShardsIntoTempFiles)
 -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/DropShardNum/ParMultiDo(Anonymous)
 (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at 
network: 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnwritten/ParMultiDo(WriteShardsIntoTempFiles)
 -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/DropShardNum/ParMultiDo(Anonymous)
 (1/1) (505e37b2a8fe119d912563baa81e223f) [DEPLOYING].
    
[TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Values/Values/Map/ParMultiDo(Anonymous)
 (1/1)] WARN org.apache.flink.metrics.MetricGroup - The operator name 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
 exceeded the 80 characters length limit and was truncated.
    
[TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Values/Values/Map/ParMultiDo(Anonymous)
 (1/1)] WARN org.apache.flink.metrics.MetricGroup - The operator name 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
 exceeded the 80 characters length limit and was truncated.
    
[TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map/ParMultiDo(Anonymous)
 -> Map (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map/ParMultiDo(Anonymous)
 -> Map (1/1) (2093eb711bdef48a7ee795e6c41cfd07) switched from DEPLOYING to 
RUNNING.
    
[TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map/ParMultiDo(Anonymous)
 -> Map (1/1)] INFO org.apache.flink.streaming.runtime.tasks.StreamTask - No 
state backend has been configured, using default (Memory / JobManager) 
MemoryStateBackend (data in heap memory / checkpoints to JobManager) 
(checkpoints: 'null', savepoints: 'null', asynchronous: TRUE, maxStateSize: 
5242880)
    
[TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Reify.ReifyView/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Values/Values/Map/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Finalize/ParMultiDo(Finalize) 
-> TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Pair 
with random key/ParMultiDo(AssignShard) -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign.out
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ReifyOriginalTimestamps/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1)] WARN org.apache.flink.metrics.MetricGroup - The 
operator name 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ReifyOriginalTimestamps/ParDo(Anonymous)/ParMultiDo(Anonymous)
 exceeded the 80 characters length limit and was truncated.
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: 
GenerateSequence/Read(BoundedCountingSource) -> 
ParDo(Anonymous)/ParMultiDo(Anonymous) -> 
TextIO.Write/WriteFiles/RewindowIntoGlobal/Window.Assign.out -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnshardedBundles 
-> ToKeyedWorkItem (1/1) (7799c912b2d53a8238b947f1a771c866) switched from 
DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Values/Values/Map/ParMultiDo(Anonymous)
 (1/1) (314cfafdcaae1b61d0bf9522430a2df7) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Reify.ReifyView/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Values/Values/Map/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Finalize/ParMultiDo(Finalize) 
-> TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Pair 
with random key/ParMultiDo(AssignShard) -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign.out
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ReifyOriginalTimestamps/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1) (b5070bdd71ecc5c7277e2d77642047b8) switched from 
DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map/ParMultiDo(Anonymous)
 -> Map (1/1) (2093eb711bdef48a7ee795e6c41cfd07) switched from DEPLOYING to 
RUNNING.
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.client.JobSubmissionClientActor - 07/24/2018 12:11:07 
Source: GenerateSequence/Read(BoundedCountingSource) -> 
ParDo(Anonymous)/ParMultiDo(Anonymous) -> 
TextIO.Write/WriteFiles/RewindowIntoGlobal/Window.Assign.out -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnshardedBundles 
-> ToKeyedWorkItem(1/1) switched to RUNNING 
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.client.JobSubmissionClientActor - 07/24/2018 12:11:07 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Values/Values/Map/ParMultiDo(Anonymous)(1/1)
 switched to RUNNING 
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.client.JobSubmissionClientActor - 07/24/2018 12:11:07 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Reify.ReifyView/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Values/Values/Map/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Finalize/ParMultiDo(Finalize) 
-> TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Pair 
with random key/ParMultiDo(AssignShard) -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign.out
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ReifyOriginalTimestamps/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem(1/1) switched to RUNNING 
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.client.JobSubmissionClientActor - 07/24/2018 12:11:07 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map/ParMultiDo(Anonymous)
 -> Map(1/1) switched to RUNNING 
    
[TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map/ParMultiDo(Anonymous)
 -> Map (1/1)] WARN org.apache.flink.metrics.MetricGroup - The operator name 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map/ParMultiDo(Anonymous)
 exceeded the 80 characters length limit and was truncated.
    
[TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map/ParMultiDo(Anonymous)
 -> Map (1/1)] WARN org.apache.flink.metrics.MetricGroup - The operator name 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)
 exceeded the 80 characters length limit and was truncated.
    
[TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Reify.ReifyView/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Values/Values/Map/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Finalize/ParMultiDo(Finalize) 
-> TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Pair 
with random key/ParMultiDo(AssignShard) -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign.out
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ReifyOriginalTimestamps/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1)] WARN org.apache.flink.metrics.MetricGroup - The 
operator name 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign.out
 exceeded the 80 characters length limit and was truncated.
    
[TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map/ParMultiDo(Anonymous)
 -> Map (1/1)] INFO org.apache.flink.runtime.state.heap.HeapKeyedStateBackend - 
Initializing heap keyed state backend with stream factory.
    [TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnwritten/ParMultiDo(WriteShardsIntoTempFiles)
 -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/DropShardNum/ParMultiDo(Anonymous)
 (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnwritten/ParMultiDo(WriteShardsIntoTempFiles)
 -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/DropShardNum/ParMultiDo(Anonymous)
 (1/1) (505e37b2a8fe119d912563baa81e223f) switched from DEPLOYING to RUNNING.
    [TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnwritten/ParMultiDo(WriteShardsIntoTempFiles)
 -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/DropShardNum/ParMultiDo(Anonymous)
 (1/1)] INFO org.apache.flink.streaming.runtime.tasks.StreamTask - No state 
backend has been configured, using default (Memory / JobManager) 
MemoryStateBackend (data in heap memory / checkpoints to JobManager) 
(checkpoints: 'null', savepoints: 'null', asynchronous: TRUE, maxStateSize: 
5242880)
    
[TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Reify.ReifyView/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Values/Values/Map/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Finalize/ParMultiDo(Finalize) 
-> TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Pair 
with random key/ParMultiDo(AssignShard) -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign.out
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ReifyOriginalTimestamps/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1)] WARN org.apache.flink.metrics.MetricGroup - The 
operator name 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Pair 
with random key/ParMultiDo(AssignShard) exceeded the 80 characters length limit 
and was truncated.
    [flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnwritten/ParMultiDo(WriteShardsIntoTempFiles)
 -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/DropShardNum/ParMultiDo(Anonymous)
 (1/1) (505e37b2a8fe119d912563baa81e223f) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.client.JobSubmissionClientActor - 07/24/2018 12:11:07 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnwritten/ParMultiDo(WriteShardsIntoTempFiles)
 -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/DropShardNum/ParMultiDo(Anonymous)(1/1)
 switched to RUNNING 
    
[TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Reify.ReifyView/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Values/Values/Map/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Finalize/ParMultiDo(Finalize) 
-> TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Pair 
with random key/ParMultiDo(AssignShard) -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign.out
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ReifyOriginalTimestamps/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1)] WARN org.apache.flink.metrics.MetricGroup - The 
operator name 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Values/Values/Map/ParMultiDo(Anonymous)
 exceeded the 80 characters length limit and was truncated.
    
[TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Reify.ReifyView/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Values/Values/Map/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Finalize/ParMultiDo(Finalize) 
-> TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Pair 
with random key/ParMultiDo(AssignShard) -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign.out
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ReifyOriginalTimestamps/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1)] WARN org.apache.flink.metrics.MetricGroup - The 
operator name 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Reify.ReifyView/ParDo(Anonymous)/ParMultiDo(Anonymous)
 exceeded the 80 characters length limit and was truncated.
    [TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnwritten/ParMultiDo(WriteShardsIntoTempFiles)
 -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/DropShardNum/ParMultiDo(Anonymous)
 (1/1)] WARN org.apache.flink.metrics.MetricGroup - The operator name 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/DropShardNum/ParMultiDo(Anonymous)
 exceeded the 80 characters length limit and was truncated.
    
[TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1) (b3cfc35fad0a94f34dcbcb5481c9b02e) switched from 
DEPLOYING to RUNNING.
    
[TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1)] INFO 
org.apache.flink.streaming.runtime.tasks.StreamTask - No state backend has been 
configured, using default (Memory / JobManager) MemoryStateBackend (data in 
heap memory / checkpoints to JobManager) (checkpoints: 'null', savepoints: 
'null', asynchronous: TRUE, maxStateSize: 5242880)
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1) (b3cfc35fad0a94f34dcbcb5481c9b02e) switched from 
DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.client.JobSubmissionClientActor - 07/24/2018 12:11:07 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem(1/1) switched to RUNNING 
    [TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnwritten/ParMultiDo(WriteShardsIntoTempFiles)
 -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/DropShardNum/ParMultiDo(Anonymous)
 (1/1)] WARN org.apache.flink.metrics.MetricGroup - The operator name 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnwritten/ParMultiDo(WriteShardsIntoTempFiles)
 exceeded the 80 characters length limit and was truncated.
    
[TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Values/Values/Map/ParMultiDo(Anonymous)
 (1/1)] INFO org.apache.flink.runtime.state.heap.HeapKeyedStateBackend - 
Initializing heap keyed state backend with stream factory.
    
[TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1)] WARN org.apache.flink.metrics.MetricGroup - The 
operator name 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
 exceeded the 80 characters length limit and was truncated.
    
[TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1)] WARN org.apache.flink.metrics.MetricGroup - The 
operator name 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization)
 exceeded the 80 characters length limit and was truncated.
    [Source: GenerateSequence/Read(BoundedCountingSource) -> 
ParDo(Anonymous)/ParMultiDo(Anonymous) -> 
TextIO.Write/WriteFiles/RewindowIntoGlobal/Window.Assign.out -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnshardedBundles 
-> ToKeyedWorkItem (1/1)] INFO 
org.apache.beam.runners.flink.translation.wrappers.streaming.io.UnboundedSourceWrapper
 - No restore state for UnbounedSourceWrapper.
    [Source: GenerateSequence/Read(BoundedCountingSource) -> 
ParDo(Anonymous)/ParMultiDo(Anonymous) -> 
TextIO.Write/WriteFiles/RewindowIntoGlobal/Window.Assign.out -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnshardedBundles 
-> ToKeyedWorkItem (1/1)] INFO 
org.apache.beam.runners.flink.translation.wrappers.streaming.io.UnboundedSourceWrapper
 - Unbounded Flink Source 0/1 is reading from sources: 
[org.apache.beam.runners.core.construction.UnboundedReadFromBoundedSource$BoundedToUnboundedSourceAdapter@d5a388c]
    [Source: GenerateSequence/Read(BoundedCountingSource) -> 
ParDo(Anonymous)/ParMultiDo(Anonymous) -> 
TextIO.Write/WriteFiles/RewindowIntoGlobal/Window.Assign.out -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnshardedBundles 
-> ToKeyedWorkItem (1/1)] INFO org.apache.beam.sdk.io.WriteFiles - Opening 
writer ccceca3c-1f87-489f-a362-9872b8f80ea5 for window 
org.apache.beam.sdk.transforms.windowing.GlobalWindow@4d4ba8d0 pane 
PaneInfo.NO_FIRING destination null
    [TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnwritten/ParMultiDo(WriteShardsIntoTempFiles)
 -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/DropShardNum/ParMultiDo(Anonymous)
 (1/1)] INFO org.apache.flink.runtime.state.heap.HeapKeyedStateBackend - 
Initializing heap keyed state backend with stream factory.
    [Source: 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Create.Values/Read(CreateSource)
 (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Source: 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Create.Values/Read(CreateSource)
 (1/1) (b68fbed4541341b7908928190f3f64fe) switched from RUNNING to FINISHED.
    [Source: 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Create.Values/Read(CreateSource)
 (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources 
for Source: 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Create.Values/Read(CreateSource)
 (1/1) (b68fbed4541341b7908928190f3f64fe).
    [Source: 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Create.Values/Read(CreateSource)
 (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all 
FileSystem streams are closed for task Source: 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Create.Values/Read(CreateSource)
 (1/1) (b68fbed4541341b7908928190f3f64fe) [FINISHED]
    [flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.taskmanager.TaskManager - Un-registering task and 
sending final execution state FINISHED to JobManager for task Source: 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Create.Values/Read(CreateSource)
 (b68fbed4541341b7908928190f3f64fe)
    [flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Create.Values/Read(CreateSource)
 (1/1) (b68fbed4541341b7908928190f3f64fe) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.client.JobSubmissionClientActor - 07/24/2018 12:11:08 
Source: 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Create.Values/Read(CreateSource)(1/1)
 switched to FINISHED 
    [Time Trigger for Source: GenerateSequence/Read(BoundedCountingSource) -> 
ParDo(Anonymous)/ParMultiDo(Anonymous) -> 
TextIO.Write/WriteFiles/RewindowIntoGlobal/Window.Assign.out -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnshardedBundles 
-> ToKeyedWorkItem (1/1)] INFO org.apache.beam.sdk.io.FileBasedSink$Writer - 
Successfully wrote temporary file 
/tmp/junit8461028423339166968/junit7775443102897849981/result/.temp-beam-2018-07-24_12-11-07-6/ccceca3c-1f87-489f-a362-9872b8f80ea5
    [Source: GenerateSequence/Read(BoundedCountingSource) -> 
ParDo(Anonymous)/ParMultiDo(Anonymous) -> 
TextIO.Write/WriteFiles/RewindowIntoGlobal/Window.Assign.out -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnshardedBundles 
-> ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - 
Source: GenerateSequence/Read(BoundedCountingSource) -> 
ParDo(Anonymous)/ParMultiDo(Anonymous) -> 
TextIO.Write/WriteFiles/RewindowIntoGlobal/Window.Assign.out -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnshardedBundles 
-> ToKeyedWorkItem (1/1) (7799c912b2d53a8238b947f1a771c866) switched from 
RUNNING to FINISHED.
    [Source: GenerateSequence/Read(BoundedCountingSource) -> 
ParDo(Anonymous)/ParMultiDo(Anonymous) -> 
TextIO.Write/WriteFiles/RewindowIntoGlobal/Window.Assign.out -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnshardedBundles 
-> ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - 
Freeing task resources for Source: GenerateSequence/Read(BoundedCountingSource) 
-> ParDo(Anonymous)/ParMultiDo(Anonymous) -> 
TextIO.Write/WriteFiles/RewindowIntoGlobal/Window.Assign.out -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnshardedBundles 
-> ToKeyedWorkItem (1/1) (7799c912b2d53a8238b947f1a771c866).
    [Source: GenerateSequence/Read(BoundedCountingSource) -> 
ParDo(Anonymous)/ParMultiDo(Anonymous) -> 
TextIO.Write/WriteFiles/RewindowIntoGlobal/Window.Assign.out -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnshardedBundles 
-> ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - 
Ensuring all FileSystem streams are closed for task Source: 
GenerateSequence/Read(BoundedCountingSource) -> 
ParDo(Anonymous)/ParMultiDo(Anonymous) -> 
TextIO.Write/WriteFiles/RewindowIntoGlobal/Window.Assign.out -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnshardedBundles 
-> ToKeyedWorkItem (1/1) (7799c912b2d53a8238b947f1a771c866) [FINISHED]
    [flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.taskmanager.TaskManager - Un-registering task and 
sending final execution state FINISHED to JobManager for task Source: 
GenerateSequence/Read(BoundedCountingSource) -> 
ParDo(Anonymous)/ParMultiDo(Anonymous) -> 
TextIO.Write/WriteFiles/RewindowIntoGlobal/Window.Assign.out -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnshardedBundles 
-> ToKeyedWorkItem (7799c912b2d53a8238b947f1a771c866)
    [TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnwritten/ParMultiDo(WriteShardsIntoTempFiles)
 -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/DropShardNum/ParMultiDo(Anonymous)
 (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnwritten/ParMultiDo(WriteShardsIntoTempFiles)
 -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/DropShardNum/ParMultiDo(Anonymous)
 (1/1) (505e37b2a8fe119d912563baa81e223f) switched from RUNNING to FINISHED.
    [TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnwritten/ParMultiDo(WriteShardsIntoTempFiles)
 -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/DropShardNum/ParMultiDo(Anonymous)
 (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources 
for TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnwritten/ParMultiDo(WriteShardsIntoTempFiles)
 -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/DropShardNum/ParMultiDo(Anonymous)
 (1/1) (505e37b2a8fe119d912563baa81e223f).
    [TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnwritten/ParMultiDo(WriteShardsIntoTempFiles)
 -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/DropShardNum/ParMultiDo(Anonymous)
 (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all 
FileSystem streams are closed for task 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnwritten/ParMultiDo(WriteShardsIntoTempFiles)
 -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/DropShardNum/ParMultiDo(Anonymous)
 (1/1) (505e37b2a8fe119d912563baa81e223f) [FINISHED]
    [flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.taskmanager.TaskManager - Un-registering task and 
sending final execution state FINISHED to JobManager for task 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnwritten/ParMultiDo(WriteShardsIntoTempFiles)
 -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/DropShardNum/ParMultiDo(Anonymous)
 (505e37b2a8fe119d912563baa81e223f)
    
[TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1) (b3cfc35fad0a94f34dcbcb5481c9b02e) switched from 
RUNNING to FINISHED.
    
[TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - 
Freeing task resources for 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1) (b3cfc35fad0a94f34dcbcb5481c9b02e).
    
[TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - 
Ensuring all FileSystem streams are closed for task 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1) (b3cfc35fad0a94f34dcbcb5481c9b02e) [FINISHED]
    [flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.taskmanager.TaskManager - Un-registering task and 
sending final execution state FINISHED to JobManager for task 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (b3cfc35fad0a94f34dcbcb5481c9b02e)
    [flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnwritten/ParMultiDo(WriteShardsIntoTempFiles)
 -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/DropShardNum/ParMultiDo(Anonymous)
 (1/1) (505e37b2a8fe119d912563baa81e223f) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1) (b3cfc35fad0a94f34dcbcb5481c9b02e) switched from 
RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.client.JobSubmissionClientActor - 07/24/2018 12:11:08 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem(1/1) switched to FINISHED 
    [flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: 
GenerateSequence/Read(BoundedCountingSource) -> 
ParDo(Anonymous)/ParMultiDo(Anonymous) -> 
TextIO.Write/WriteFiles/RewindowIntoGlobal/Window.Assign.out -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnshardedBundles 
-> ToKeyedWorkItem (1/1) (7799c912b2d53a8238b947f1a771c866) switched from 
RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.client.JobSubmissionClientActor - 07/24/2018 12:11:08 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/GroupUnwritten -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnwritten/ParMultiDo(WriteShardsIntoTempFiles)
 -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/DropShardNum/ParMultiDo(Anonymous)(1/1)
 switched to FINISHED 
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.client.JobSubmissionClientActor - 07/24/2018 12:11:08 
Source: GenerateSequence/Read(BoundedCountingSource) -> 
ParDo(Anonymous)/ParMultiDo(Anonymous) -> 
TextIO.Write/WriteFiles/RewindowIntoGlobal/Window.Assign.out -> 
TextIO.Write/WriteFiles/WriteUnshardedBundlesToTempFiles/WriteUnshardedBundles 
-> ToKeyedWorkItem(1/1) switched to FINISHED 
    
[TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map/ParMultiDo(Anonymous)
 -> Map (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map/ParMultiDo(Anonymous)
 -> Map (1/1) (2093eb711bdef48a7ee795e6c41cfd07) switched from RUNNING to 
FINISHED.
    
[TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map/ParMultiDo(Anonymous)
 -> Map (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task 
resources for 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map/ParMultiDo(Anonymous)
 -> Map (1/1) (2093eb711bdef48a7ee795e6c41cfd07).
    
[TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map/ParMultiDo(Anonymous)
 -> Map (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all 
FileSystem streams are closed for task 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map/ParMultiDo(Anonymous)
 -> Map (1/1) (2093eb711bdef48a7ee795e6c41cfd07) [FINISHED]
    [flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.taskmanager.TaskManager - Un-registering task and 
sending final execution state FINISHED to JobManager for task 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map/ParMultiDo(Anonymous)
 -> Map (2093eb711bdef48a7ee795e6c41cfd07)
    
[TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Reify.ReifyView/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Values/Values/Map/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Finalize/ParMultiDo(Finalize) 
-> TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Pair 
with random key/ParMultiDo(AssignShard) -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign.out
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ReifyOriginalTimestamps/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1)] INFO org.apache.beam.sdk.io.WriteFiles - Finalizing 
1 file results
    
[TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Reify.ReifyView/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Values/Values/Map/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Finalize/ParMultiDo(Finalize) 
-> TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Pair 
with random key/ParMultiDo(AssignShard) -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign.out
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ReifyOriginalTimestamps/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1)] INFO org.apache.beam.sdk.io.FileBasedSink - 
Finalizing for destination null num shards 1.
    [flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map/ParMultiDo(Anonymous)
 -> Map (1/1) (2093eb711bdef48a7ee795e6c41cfd07) switched from RUNNING to 
FINISHED.
    
[TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Reify.ReifyView/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Values/Values/Map/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Finalize/ParMultiDo(Finalize) 
-> TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Pair 
with random key/ParMultiDo(AssignShard) -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign.out
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ReifyOriginalTimestamps/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1)] INFO org.apache.beam.sdk.io.FileBasedSink - Will 
copy temporary file 
FileResult{tempFilename=/tmp/junit8461028423339166968/junit7775443102897849981/result/.temp-beam-2018-07-24_12-11-07-6/ccceca3c-1f87-489f-a362-9872b8f80ea5,
 shard=0, 
window=org.apache.beam.sdk.transforms.windowing.GlobalWindow@4d4ba8d0, 
paneInfo=PaneInfo.NO_FIRING} to final location 
/tmp/junit8461028423339166968/junit7775443102897849981/result/file.txt-00000-of-00001
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.client.JobSubmissionClientActor - 07/24/2018 12:11:08 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Combine.perKey(Concatenate)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/View.AsList/View.CreatePCollectionView/Combine.globally(Concatenate)/Values/Values/Map/ParMultiDo(Anonymous)
 -> Map(1/1) switched to FINISHED 
    
[TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Reify.ReifyView/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Values/Values/Map/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Finalize/ParMultiDo(Finalize) 
-> TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Pair 
with random key/ParMultiDo(AssignShard) -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign.out
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ReifyOriginalTimestamps/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1)] INFO org.apache.beam.sdk.io.FileBasedSink - Will 
remove known temporary file 
/tmp/junit8461028423339166968/junit7775443102897849981/result/.temp-beam-2018-07-24_12-11-07-6/ccceca3c-1f87-489f-a362-9872b8f80ea5
    
[TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Reify.ReifyView/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Values/Values/Map/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Finalize/ParMultiDo(Finalize) 
-> TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Pair 
with random key/ParMultiDo(AssignShard) -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign.out
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ReifyOriginalTimestamps/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Reify.ReifyView/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Values/Values/Map/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Finalize/ParMultiDo(Finalize) 
-> TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Pair 
with random key/ParMultiDo(AssignShard) -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign.out
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ReifyOriginalTimestamps/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1) (b5070bdd71ecc5c7277e2d77642047b8) switched from 
RUNNING to FINISHED.
    
[TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Reify.ReifyView/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Values/Values/Map/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Finalize/ParMultiDo(Finalize) 
-> TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Pair 
with random key/ParMultiDo(AssignShard) -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign.out
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ReifyOriginalTimestamps/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - 
Freeing task resources for 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Reify.ReifyView/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Values/Values/Map/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Finalize/ParMultiDo(Finalize) 
-> TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Pair 
with random key/ParMultiDo(AssignShard) -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign.out
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ReifyOriginalTimestamps/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1) (b5070bdd71ecc5c7277e2d77642047b8).
    
[TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Reify.ReifyView/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Values/Values/Map/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Finalize/ParMultiDo(Finalize) 
-> TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Pair 
with random key/ParMultiDo(AssignShard) -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign.out
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ReifyOriginalTimestamps/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - 
Ensuring all FileSystem streams are closed for task 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Reify.ReifyView/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Values/Values/Map/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Finalize/ParMultiDo(Finalize) 
-> TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Pair 
with random key/ParMultiDo(AssignShard) -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign.out
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ReifyOriginalTimestamps/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1) (b5070bdd71ecc5c7277e2d77642047b8) [FINISHED]
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.taskmanager.TaskManager - Un-registering task and 
sending final execution state FINISHED to JobManager for task 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Reify.ReifyView/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Values/Values/Map/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Finalize/ParMultiDo(Finalize) 
-> TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Pair 
with random key/ParMultiDo(AssignShard) -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign.out
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ReifyOriginalTimestamps/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (b5070bdd71ecc5c7277e2d77642047b8)
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Reify.ReifyView/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Values/Values/Map/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Finalize/ParMultiDo(Finalize) 
-> TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Pair 
with random key/ParMultiDo(AssignShard) -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign.out
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ReifyOriginalTimestamps/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem (1/1) (b5070bdd71ecc5c7277e2d77642047b8) switched from 
RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.client.JobSubmissionClientActor - 07/24/2018 12:11:08 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Reify.ReifyView/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/GatherTempFileResults/Reify.ReifyViewInGlobalWindow/Values/Values/Map/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Finalize/ParMultiDo(Finalize) 
-> TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Pair 
with random key/ParMultiDo(AssignShard) -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign.out
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ReifyOriginalTimestamps/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> ToKeyedWorkItem(1/1) switched to FINISHED 
    
[TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Values/Values/Map/ParMultiDo(Anonymous)
 (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Values/Values/Map/ParMultiDo(Anonymous)
 (1/1) (314cfafdcaae1b61d0bf9522430a2df7) switched from RUNNING to FINISHED.
    
[TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Values/Values/Map/ParMultiDo(Anonymous)
 (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources 
for 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Values/Values/Map/ParMultiDo(Anonymous)
 (1/1) (314cfafdcaae1b61d0bf9522430a2df7).
    
[TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Values/Values/Map/ParMultiDo(Anonymous)
 (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all 
FileSystem streams are closed for task 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Values/Values/Map/ParMultiDo(Anonymous)
 (1/1) (314cfafdcaae1b61d0bf9522430a2df7) [FINISHED]
    [flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.taskmanager.TaskManager - Un-registering task and 
sending final execution state FINISHED to JobManager for task 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Values/Values/Map/ParMultiDo(Anonymous)
 (314cfafdcaae1b61d0bf9522430a2df7)
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Values/Values/Map/ParMultiDo(Anonymous)
 (1/1) (314cfafdcaae1b61d0bf9522430a2df7) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.client.JobSubmissionClientActor - 07/24/2018 12:11:08 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/ReifyTimestamps.RemoveWildcard/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Reshuffle/RestoreOriginalTimestamps/Reify.ExtractTimestampsFromValues/ParDo(Anonymous)/ParMultiDo(Anonymous)
 -> 
TextIO.Write/WriteFiles/FinalizeTempFileBundles/Reshuffle.ViaRandomKey/Values/Values/Map/ParMultiDo(Anonymous)(1/1)
 switched to FINISHED 
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - Job 
testflinkrunner-jenkins-0724121107-9a64b7c7 (36a824611e77501ac3de2dc24d775bad) 
switched from state RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Stopping checkpoint 
coordinator for job 36a824611e77501ac3de2dc24d775bad.
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore - 
Shutting down
    [flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.client.JobSubmissionClientActor - 07/24/2018 12:11:08 
Job execution switched to status FINISHED.
    [flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.client.JobSubmissionClientActor - Terminate 
JobClientActor.
    [Test worker] INFO org.apache.flink.runtime.client.JobClient - Job 
execution complete
    [flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.client.JobSubmissionClientActor - Disconnect from 
JobManager Actor[akka://flink/user/jobmanager_1#1511242515].
    [Test worker] INFO org.apache.beam.runners.flink.FlinkRunner - Execution 
finished in 322 msecs
    [Test worker] INFO org.apache.beam.runners.flink.FlinkRunner - Final 
accumulator values:
    [Test worker] INFO org.apache.beam.runners.flink.FlinkRunner - 
__metricscontainers : 
org.apache.beam.runners.core.metrics.MetricsContainerStepMap@9f980b54
    [Test worker] INFO org.apache.beam.runners.flink.ReadSourceStreamingTest - 
    
--------------------------------------------------------------------------------
    Test testJob(org.apache.beam.runners.flink.ReadSourceStreamingTest) 
successfully run.
    
================================================================================

org.apache.beam.runners.flink.ReadSourceStreamingTest STANDARD_ERROR
    [Test worker] INFO org.apache.flink.runtime.minicluster.FlinkMiniCluster - 
Stopping FlinkMiniCluster.
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.taskmanager.TaskManager - Stopping TaskManager 
akka://flink/user/taskmanager_1#-1413768013.
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.taskmanager.TaskManager - Disassociating from 
JobManager
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
    [flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.jobmanager.JobManager - Stopping JobManager 
akka://flink/user/jobmanager_1.
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the 
network environment and its components.
    [flink-akka.actor.default-dispatcher-5] INFO 
org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:38287
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting 
down TaskExecutorLocalStateStoresManager.
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.taskmanager.TaskManager - Task manager 
akka://flink/user/taskmanager_1 is completely shut down.

org.apache.beam.runners.flink.PipelineOptionsTest > 
parDoBaseClassPipelineOptionsSerializationTest STANDARD_ERROR
    [Test worker] INFO org.apache.flink.api.java.typeutils.TypeExtractor - No 
fields were detected for class org.apache.beam.sdk.util.WindowedValue so it 
cannot be used as a POJO type and must be processed as GenericType. Please read 
the Flink documentation on "Data Types & Serialization" for details of the 
effect on performance.
    [Test worker] INFO org.apache.flink.runtime.io.disk.iomanager.IOManager - 
I/O manager uses directory /tmp/flink-io-95e6631e-a738-4ab0-a4c0-3726108757cd 
for spill files.
    [Test worker] INFO org.apache.flink.runtime.io.disk.iomanager.IOManager - 
I/O manager removed spill file directory 
/tmp/flink-io-95e6631e-a738-4ab0-a4c0-3726108757cd
Finished generating test XML results (5.67 secs) into: 
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/runners/flink/build/test-results/test>
Generating HTML test report...
Finished generating test html results (58.276 secs) into: 
<https://builds.apache.org/job/beam_PreCommit_Java_Cron/ws/src/runners/flink/build/reports/tests/test>
Packing task ':beam-runners-flink_2.11:test'
:beam-runners-flink_2.11:test (Thread[Task worker for ':' Thread 3,5,main]) 
completed. Took 3 mins 50.575 secs.
:beam-runners-flink_2.11:check (Thread[Task worker for ':' Thread 3,5,main]) 
started.

> Task :beam-runners-flink_2.11:check
Skipping task ':beam-runners-flink_2.11:check' as it has no actions.
:beam-runners-flink_2.11:check (Thread[Task worker for ':' Thread 3,5,main]) 
completed. Took 0.0 secs.
:beam-runners-flink_2.11:build (Thread[Task worker for ':' Thread 3,5,main]) 
started.

> Task :beam-runners-flink_2.11:build
Skipping task ':beam-runners-flink_2.11:build' as it has no actions.
:beam-runners-flink_2.11:build (Thread[Task worker for ':' Thread 3,5,main]) 
completed. Took 0.0 secs.
Expiring Daemon because JVM Tenured space is exhausted

> Task :beam-sdks-java-extensions-sql:compileJava FAILED
:beam-sdks-java-extensions-sql:compileJava (Thread[Task worker for ':' Thread 
39,5,main]) completed. Took 16 mins 11.556 secs.
Expiring Daemon because JVM Tenured space is exhausted
Expiring Daemon because JVM Tenured space is exhausted
Expiring Daemon because JVM Tenured space is exhausted
Expiring Daemon because JVM Tenured space is exhausted
Expiring Daemon because JVM Tenured space is exhausted
Expiring Daemon because JVM Tenured space is exhausted
Expiring Daemon because JVM Tenured space is exhausted
Expiring Daemon because JVM Tenured space is exhausted
Expiring Daemon because JVM Tenured space is exhausted
Expiring Daemon because JVM Tenured space is exhausted
Expiring Daemon because JVM Tenured space is exhausted
Expiring Daemon because JVM Tenured space is exhausted
JVM garbage collector is thrashing. Daemon will be stopped immediately
Daemon is stopping immediately JVM garbage collector thrashing
Stop requested. Daemon is removing its presence from the registry...
Expiring Daemon because JVM Tenured space is exhausted

FAILURE: Build failed with an exception.

* What went wrong:
Gradle build daemon has been stopped: JVM garbage collector thrashing

* 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
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure

Build failed in Jenkins: beam_PreCommit_Java_Cron #141

Reply via email to