beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Apache Jenkins Server <jenk...@builds.apache.org>
Subject Build failed in Jenkins: beam_PostCommit_Java_ValidatesRunner_Dataflow #4265
Date Wed, 01 Nov 2017 18:19:14 GMT
See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Dataflow/4265/display/redirect?page=changes>

Changes:

[lcwik] Changed the mutation detector to be based on structural value only

------------------------------------------
[...truncated 6.40 MB...]
[INFO] Adding PAssert$57/GroupGlobally/Create.Values/Read(CreateSource) as step s24
[INFO] Adding PAssert$57/GroupGlobally/WindowIntoDummy/Window.Assign as step s25
[INFO] Adding PAssert$57/GroupGlobally/RemoveDummyTriggering/Flatten.PCollections as step
s26
[INFO] Adding PAssert$57/GroupGlobally/FlattenDummyAndContents as step s27
[INFO] Adding PAssert$57/GroupGlobally/NeverTrigger/Flatten.PCollections as step s28
[INFO] Adding PAssert$57/GroupGlobally/GroupDummyAndContents as step s29
[INFO] Adding PAssert$57/GroupGlobally/Values/Values/Map as step s30
[INFO] Adding PAssert$57/GroupGlobally/ParDo(Concat) as step s31
[INFO] Adding PAssert$57/GetPane/Map as step s32
[INFO] 2017-11-01T18:18:03.428Z: (8cc7ddad31ac63bc): Executing operation PAssert$46/GroupGlobally/GatherAllOutputs/GroupByKey/Close
[INFO] 2017-11-01T18:18:03.444Z: (8cc7ddad31ac6314): Executing operation PAssert$46/GroupGlobally/GroupDummyAndContents/Create
[INFO] 2017-11-01T18:18:03.494Z: (8cc7ddad31ac6170): Executing operation PAssert$46/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$46/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$46/GroupGlobally/GroupDummyAndContents/Reify+PAssert$46/GroupGlobally/GroupDummyAndContents/Write
[INFO] 2017-11-01T18:18:03.506Z: (f5e8a7f349a5dcc4): Executing operation PAssert$46/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$46/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$46/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$46/GroupGlobally/RewindowActuals/Window.Assign+PAssert$46/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$46/GroupGlobally/GroupDummyAndContents/Reify+PAssert$46/GroupGlobally/GroupDummyAndContents/Write
[INFO] Adding PAssert$57/RunChecks as step s33
[INFO] Adding PAssert$57/VerifyAssertions/ParDo(DefaultConclude) as step s34
[INFO] 2017-11-01T18:18:01.589Z: (e13aa6c0f3022533): Autoscaling: Raised the number of workers
to 1 based on the rate of progress in the currently running step(s).
[INFO] Adding CreateEmptyView/Read(CreateSource) as step s1
[INFO] Adding View.AsMultimap/View.CreatePCollectionView/GBKaSVForData/ParDo(GroupByKeyHashAndSortByKeyAndWindow)
as step s2
[INFO] Adding View.AsMultimap/View.CreatePCollectionView/GBKaSVForData/BatchViewOverrides.GroupByKeyAndSortValuesOnly
as step s3
[INFO] Adding View.AsMultimap/View.CreatePCollectionView/ParMultiDo(ToIsmRecordForMapLike)
as step s4
[INFO] Adding View.AsMultimap/View.CreatePCollectionView/GBKaSVForSize as step s5
[INFO] Adding View.AsMultimap/View.CreatePCollectionView/ParDo(ToIsmMetadataRecordForSize)
as step s6
[INFO] Adding View.AsMultimap/View.CreatePCollectionView/GBKaSVForKeys as step s7
[INFO] Adding View.AsMultimap/View.CreatePCollectionView/ParDo(ToIsmMetadataRecordForKey)
as step s8
[INFO] Adding View.AsMultimap/View.CreatePCollectionView/Flatten.PCollections as step s9
[INFO] Adding View.AsMultimap/View.CreatePCollectionView/CreateDataflowView as step s10
[INFO] Adding Create1/Read(CreateSource) as step s11
[INFO] Adding OutputSideInputs as step s12
[INFO] Adding PAssert$56/GroupGlobally/Window.Into()/Window.Assign as step s13
[INFO] Adding PAssert$56/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows) as
step s14
[INFO] Adding PAssert$56/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map as step s15
[INFO] Adding PAssert$56/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign as step
s16
[INFO] Adding PAssert$56/GroupGlobally/GatherAllOutputs/GroupByKey as step s17
[INFO] Adding PAssert$56/GroupGlobally/GatherAllOutputs/Values/Values/Map as step s18
[INFO] Adding PAssert$56/GroupGlobally/RewindowActuals/Window.Assign as step s19
[INFO] Adding PAssert$56/GroupGlobally/KeyForDummy/AddKeys/Map as step s20
[INFO] Adding PAssert$56/GroupGlobally/RemoveActualsTriggering/Flatten.PCollections as step
s21
[INFO] Adding PAssert$56/GroupGlobally/Create.Values/Read(CreateSource) as step s22
[INFO] Adding PAssert$56/GroupGlobally/WindowIntoDummy/Window.Assign as step s23
[INFO] Adding PAssert$56/GroupGlobally/RemoveDummyTriggering/Flatten.PCollections as step
s24
[INFO] Adding PAssert$56/GroupGlobally/FlattenDummyAndContents as step s25
[INFO] Adding PAssert$56/GroupGlobally/NeverTrigger/Flatten.PCollections as step s26
[INFO] Adding PAssert$56/GroupGlobally/GroupDummyAndContents as step s27
[INFO] Adding PAssert$56/GroupGlobally/Values/Values/Map as step s28
[INFO] Adding PAssert$56/GroupGlobally/ParDo(Concat) as step s29
[INFO] Adding PAssert$56/GetPane/Map as step s30
[INFO] Adding PAssert$56/RunChecks as step s31
[INFO] Adding PAssert$56/VerifyAssertions/ParDo(DefaultConclude) as step s32
[INFO] To access the Dataflow monitoring console, please navigate to https://console.cloud.google.com/dataflow/jobsDetail/locations/us-central1/jobs/2017-11-01_11_18_03-3045012204810959192?project=apache-beam-testing
[INFO] To cancel the job using the 'gcloud' tool, run:
> gcloud dataflow jobs --project=apache-beam-testing cancel 2017-11-01_11_18_03-3045012204810959192
[INFO] Running Dataflow job 2017-11-01_11_18_03-3045012204810959192 with 1 expected assertions.
[INFO] To access the Dataflow monitoring console, please navigate to https://console.cloud.google.com/dataflow/jobsDetail/locations/us-central1/jobs/2017-11-01_11_18_04-18338852650054697781?project=apache-beam-testing
[INFO] To cancel the job using the 'gcloud' tool, run:
> gcloud dataflow jobs --project=apache-beam-testing cancel 2017-11-01_11_18_04-18338852650054697781
[INFO] Running Dataflow job 2017-11-01_11_18_04-18338852650054697781 with 1 expected assertions.
[INFO] 2017-11-01T18:18:04.169Z: (f2f9c5c0087d7b64): Workers have started successfully.
[INFO] 2017-11-01T18:18:06.014Z: (75ce63181f5cf8da): Workers have started successfully.
[INFO] 2017-11-01T18:18:03.815Z: (2a420e77947c7cec): Autoscaling is enabled for job 2017-11-01_11_18_03-3045012204810959192.
The number of workers will be between 1 and 15.
[INFO] 2017-11-01T18:18:03.822Z: (2a420e77947c71d1): Autoscaling was automatically enabled
for job 2017-11-01_11_18_03-3045012204810959192.
[INFO] 2017-11-01T18:18:06.237Z: (626e98f7871127da): Checking required Cloud APIs are enabled.
[INFO] 2017-11-01T18:18:09.750Z: (626e98f78711292a): Expanding CoGroupByKey operations into
optimizable parts.
[INFO] 2017-11-01T18:18:09.765Z: (626e98f787112ff3): Expanding GroupByKey operations into
optimizable parts.
[INFO] 2017-11-01T18:18:09.767Z: (626e98f787112d4d): Lifting ValueCombiningMappingFns into
MergeBucketsMappingFns
[INFO] 2017-11-01T18:18:09.790Z: (626e98f787112d69): Fusing adjacent ParDo, Read, Write, and
Flatten operations
[INFO] 2017-11-01T18:18:09.792Z: (626e98f787112ac3): Elided trivial flatten 
[INFO] 2017-11-01T18:18:09.794Z: (626e98f78711281d): Elided trivial flatten 
[INFO] 2017-11-01T18:18:09.796Z: (626e98f787112577): Elided trivial flatten 
[INFO] 2017-11-01T18:18:09.800Z: (626e98f7871122d1): Unzipping flatten s27 for input s22.24
[INFO] 2017-11-01T18:18:09.803Z: (626e98f78711202b): Fusing unzipped copy of PAssert$57/GroupGlobally/GroupDummyAndContents/Reify,
through flatten , into producer PAssert$57/GroupGlobally/KeyForDummy/AddKeys/Map
[INFO] 2017-11-01T18:18:09.805Z: (626e98f787112d85): Fusing consumer PAssert$57/GroupGlobally/GroupDummyAndContents/GroupByWindow
into PAssert$57/GroupGlobally/GroupDummyAndContents/Read
[INFO] 2017-11-01T18:18:09.807Z: (626e98f787112adf): Unzipping flatten s27-u62 for input s29-reify-value33-c60
[INFO] 2017-11-01T18:18:09.809Z: (626e98f787112839): Fusing unzipped copy of PAssert$57/GroupGlobally/GroupDummyAndContents/Write,
through flatten , into producer PAssert$57/GroupGlobally/GroupDummyAndContents/Reify
[INFO] 2017-11-01T18:18:09.811Z: (626e98f787112593): Fusing consumer PAssert$57/GetPane/Map
into PAssert$57/GroupGlobally/ParDo(Concat)
[INFO] 2017-11-01T18:18:09.813Z: (626e98f7871122ed): Fusing consumer PAssert$57/VerifyAssertions/ParDo(DefaultConclude)
into PAssert$57/RunChecks
[INFO] 2017-11-01T18:18:09.815Z: (626e98f787112047): Fusing consumer PAssert$57/RunChecks
into PAssert$57/GetPane/Map
[INFO] 2017-11-01T18:18:09.817Z: (626e98f787112da1): Fusing consumer PAssert$57/GroupGlobally/Values/Values/Map
into PAssert$57/GroupGlobally/GroupDummyAndContents/GroupByWindow
[INFO] 2017-11-01T18:18:09.819Z: (626e98f787112afb): Fusing consumer PAssert$57/GroupGlobally/ParDo(Concat)
into PAssert$57/GroupGlobally/Values/Values/Map
[INFO] 2017-11-01T18:18:09.821Z: (626e98f787112855): Fusing consumer PAssert$57/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow
into PAssert$57/GroupGlobally/GatherAllOutputs/GroupByKey/Read
[INFO] 2017-11-01T18:18:09.823Z: (626e98f7871125af): Fusing consumer PAssert$57/GroupGlobally/GatherAllOutputs/Values/Values/Map
into PAssert$57/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow
[INFO] 2017-11-01T18:18:09.826Z: (626e98f787112309): Fusing consumer PAssert$57/GroupGlobally/RewindowActuals/Window.Assign
into PAssert$57/GroupGlobally/GatherAllOutputs/Values/Values/Map
[INFO] 2017-11-01T18:18:09.828Z: (626e98f787112063): Fusing consumer PAssert$57/GroupGlobally/KeyForDummy/AddKeys/Map
into PAssert$57/GroupGlobally/RewindowActuals/Window.Assign
[INFO] 2017-11-01T18:18:09.830Z: (626e98f787112dbd): Fusing consumer PAssert$57/GroupGlobally/GatherAllOutputs/GroupByKey/Reify
into PAssert$57/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign
[INFO] 2017-11-01T18:18:09.832Z: (626e98f787112b17): Fusing consumer PAssert$57/GroupGlobally/GatherAllOutputs/GroupByKey/Write
into PAssert$57/GroupGlobally/GatherAllOutputs/GroupByKey/Reify
[INFO] 2017-11-01T18:18:09.834Z: (626e98f787112871): Fusing consumer PAssert$57/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map
into PAssert$57/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)
[INFO] 2017-11-01T18:18:09.835Z: (626e98f7871125cb): Fusing consumer PAssert$57/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign
into PAssert$57/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map
[INFO] 2017-11-01T18:18:09.838Z: (626e98f787112325): Fusing consumer PAssert$57/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)
into PAssert$57/GroupGlobally/Window.Into()/Window.Assign
[INFO] 2017-11-01T18:18:09.840Z: (626e98f78711207f): Fusing consumer Output into CreateMainInput/Read(CreateSource)
[INFO] 2017-11-01T18:18:09.842Z: (626e98f787112dd9): Fusing consumer PAssert$57/GroupGlobally/Window.Into()/Window.Assign
into Output
[INFO] 2017-11-01T18:18:09.844Z: (626e98f787112b33): Fusing consumer View.AsMap/View.CreatePCollectionView/GBKaSVForData/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Write
into View.AsMap/View.CreatePCollectionView/GBKaSVForData/ParDo(GroupByKeyHashAndSortByKeyAndWindow)
[INFO] 2017-11-01T18:18:09.846Z: (626e98f78711288d): Fusing consumer View.AsMap/View.CreatePCollectionView/GBKaSVForSize/Write
into View.AsMap/View.CreatePCollectionView/ParMultiDo(ToIsmRecordForMapLike)
[INFO] 2017-11-01T18:18:09.848Z: (626e98f7871125e7): Fusing consumer SumIntegers/GroupByKey/Reify
into SumIntegers/GroupByKey+SumIntegers/Combine.GroupedValues/Partial
[INFO] 2017-11-01T18:18:09.850Z: (626e98f787112341): Fusing consumer SumIntegers/GroupByKey/Write
into SumIntegers/GroupByKey/Reify
[INFO] 2017-11-01T18:18:09.852Z: (626e98f78711209b): Fusing consumer View.AsMap/View.CreatePCollectionView/GBKaSVForData/ParDo(GroupByKeyHashAndSortByKeyAndWindow)
into SumIntegers/Combine.GroupedValues/Extract
[INFO] 2017-11-01T18:18:09.854Z: (626e98f787112df5): Fusing consumer View.AsMap/View.CreatePCollectionView/ParMultiDo(ToIsmRecordForMapLike)
into View.AsMap/View.CreatePCollectionView/GBKaSVForData/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read
[INFO] 2017-11-01T18:18:09.857Z: (626e98f787112b4f): Fusing consumer View.AsMap/View.CreatePCollectionView/ParDo(ToIsmMetadataRecordForKey)
into View.AsMap/View.CreatePCollectionView/GBKaSVForKeys/Read
[INFO] 2017-11-01T18:18:09.859Z: (626e98f7871128a9): Fusing consumer View.AsMap/View.CreatePCollectionView/ParDo(ToIsmMetadataRecordForSize)
into View.AsMap/View.CreatePCollectionView/GBKaSVForSize/Read
[INFO] 2017-11-01T18:18:09.861Z: (626e98f787112603): Fusing consumer SumIntegers/Combine.GroupedValues/Extract
into SumIntegers/Combine.GroupedValues
[INFO] 2017-11-01T18:18:09.863Z: (626e98f78711235d): Fusing consumer SumIntegers/GroupByKey+SumIntegers/Combine.GroupedValues/Partial
into CreateSideInput/Read(CreateSource)
[INFO] 2017-11-01T18:18:09.865Z: (626e98f7871120b7): Fusing consumer View.AsMap/View.CreatePCollectionView/GBKaSVForKeys/Write
into View.AsMap/View.CreatePCollectionView/ParMultiDo(ToIsmRecordForMapLike)
[INFO] 2017-11-01T18:18:09.867Z: (626e98f787112e11): Fusing consumer SumIntegers/Combine.GroupedValues
into SumIntegers/GroupByKey/Read
[INFO] 2017-11-01T18:18:09.869Z: (626e98f787112b6b): Fusing consumer PAssert$57/GroupGlobally/GroupDummyAndContents/Write
into PAssert$57/GroupGlobally/GroupDummyAndContents/Reify
[INFO] 2017-11-01T18:18:09.871Z: (626e98f7871128c5): Fusing consumer PAssert$57/GroupGlobally/GroupDummyAndContents/Reify
into PAssert$57/GroupGlobally/WindowIntoDummy/Window.Assign
[INFO] 2017-11-01T18:18:10.126Z: (8cc7ddad31ac685f): Executing operation PAssert$46/GroupGlobally/GroupDummyAndContents/Close
[INFO] 2017-11-01T18:18:10.147Z: (8cc7ddad31ac6fcc): Executing operation PAssert$46/GroupGlobally/GroupDummyAndContents/Read+PAssert$46/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$46/GroupGlobally/Values/Values/Map+PAssert$46/GroupGlobally/ParDo(Concat)+PAssert$46/GetPane/Map+PAssert$46/RunChecks+PAssert$46/VerifyAssertions/ParDo(DefaultConclude)
[INFO] 2017-11-01T18:18:04.107Z: (fe80b15262bdc431): Autoscaling is enabled for job 2017-11-01_11_18_04-18338852650054697781.
The number of workers will be between 1 and 15.
[INFO] 2017-11-01T18:18:04.113Z: (fe80b15262bdc070): Autoscaling was automatically enabled
for job 2017-11-01_11_18_04-18338852650054697781.
[INFO] 2017-11-01T18:18:06.466Z: (270298a67994dd37): Checking required Cloud APIs are enabled.
[INFO] 2017-11-01T18:18:10.340Z: (270298a67994d4e7): Expanding CoGroupByKey operations into
optimizable parts.
[INFO] 2017-11-01T18:18:10.361Z: (270298a67994d6ee): Expanding GroupByKey operations into
optimizable parts.
[INFO] 2017-11-01T18:18:10.365Z: (270298a67994d9b4): Lifting ValueCombiningMappingFns into
MergeBucketsMappingFns
[INFO] 2017-11-01T18:18:10.396Z: (270298a67994d792): Fusing adjacent ParDo, Read, Write, and
Flatten operations
[INFO] 2017-11-01T18:18:10.402Z: (270298a67994da58): Elided trivial flatten 
[INFO] 2017-11-01T18:18:10.407Z: (270298a67994dd1e): Elided trivial flatten 
[INFO] 2017-11-01T18:18:10.410Z: (270298a67994dfe4): Elided trivial flatten 
[INFO] 2017-11-01T18:18:10.415Z: (270298a67994d2aa): Unzipping flatten s25 for input s20.22
[INFO] 2017-11-01T18:18:10.421Z: (270298a67994d570): Fusing unzipped copy of PAssert$56/GroupGlobally/GroupDummyAndContents/Reify,
through flatten , into producer PAssert$56/GroupGlobally/KeyForDummy/AddKeys/Map
[INFO] 2017-11-01T18:18:10.425Z: (270298a67994d836): Fusing consumer PAssert$56/GroupGlobally/GroupDummyAndContents/Reify
into PAssert$56/GroupGlobally/WindowIntoDummy/Window.Assign
[INFO] 2017-11-01T18:18:10.428Z: (270298a67994dafc): Fusing consumer PAssert$56/GroupGlobally/GroupDummyAndContents/GroupByWindow
into PAssert$56/GroupGlobally/GroupDummyAndContents/Read
[INFO] 2017-11-01T18:18:10.432Z: (270298a67994ddc2): Fusing consumer PAssert$56/GroupGlobally/ParDo(Concat)
into PAssert$56/GroupGlobally/Values/Values/Map
[INFO] 2017-11-01T18:18:10.435Z: (270298a67994d088): Fusing consumer PAssert$56/GetPane/Map
into PAssert$56/GroupGlobally/ParDo(Concat)
[INFO] 2017-11-01T18:18:10.439Z: (270298a67994d34e): Fusing consumer PAssert$56/GroupGlobally/Values/Values/Map
into PAssert$56/GroupGlobally/GroupDummyAndContents/GroupByWindow
[INFO] 2017-11-01T18:18:10.442Z: (270298a67994d614): Fusing consumer PAssert$56/RunChecks
into PAssert$56/GetPane/Map
[INFO] 2017-11-01T18:18:10.445Z: (270298a67994d8da): Fusing consumer PAssert$56/VerifyAssertions/ParDo(DefaultConclude)
into PAssert$56/RunChecks
[INFO] 2017-11-01T18:18:10.449Z: (270298a67994dba0): Unzipping flatten s25-u37 for input s27-reify-value9-c35
[INFO] 2017-11-01T18:18:10.452Z: (270298a67994de66): Fusing unzipped copy of PAssert$56/GroupGlobally/GroupDummyAndContents/Write,
through flatten , into producer PAssert$56/GroupGlobally/GroupDummyAndContents/Reify
[INFO] 2017-11-01T18:18:10.455Z: (270298a67994d12c): Fusing consumer PAssert$56/GroupGlobally/GroupDummyAndContents/Write
into PAssert$56/GroupGlobally/GroupDummyAndContents/Reify
[INFO] 2017-11-01T18:18:10.458Z: (270298a67994d3f2): Fusing consumer PAssert$56/GroupGlobally/WindowIntoDummy/Window.Assign
into PAssert$56/GroupGlobally/Create.Values/Read(CreateSource)
[INFO] 2017-11-01T18:18:10.462Z: (270298a67994d6b8): Fusing consumer PAssert$56/GroupGlobally/GatherAllOutputs/GroupByKey/Write
into PAssert$56/GroupGlobally/GatherAllOutputs/GroupByKey/Reify
[INFO] 2017-11-01T18:18:10.465Z: (270298a67994d97e): Fusing consumer PAssert$56/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)
into PAssert$56/GroupGlobally/Window.Into()/Window.Assign
[INFO] 2017-11-01T18:18:10.468Z: (270298a67994dc44): Fusing consumer PAssert$56/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map
into PAssert$56/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)
[INFO] 2017-11-01T18:18:10.470Z: (270298a67994df0a): Fusing consumer OutputSideInputs into
Create1/Read(CreateSource)
[INFO] 2017-11-01T18:18:10.474Z: (270298a67994d1d0): Fusing consumer PAssert$56/GroupGlobally/Window.Into()/Window.Assign
into OutputSideInputs
[INFO] 2017-11-01T18:18:10.476Z: (270298a67994d496): Fusing consumer PAssert$56/GroupGlobally/GatherAllOutputs/Values/Values/Map
into PAssert$56/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow
[INFO] 2017-11-01T18:18:10.479Z: (270298a67994d75c): Fusing consumer PAssert$56/GroupGlobally/KeyForDummy/AddKeys/Map
into PAssert$56/GroupGlobally/RewindowActuals/Window.Assign
[INFO] 2017-11-01T18:18:10.482Z: (270298a67994da22): Fusing consumer PAssert$56/GroupGlobally/RewindowActuals/Window.Assign
into PAssert$56/GroupGlobally/GatherAllOutputs/Values/Values/Map
[INFO] 2017-11-01T18:18:10.489Z: (270298a67994dce8): Fusing consumer PAssert$56/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow
into PAssert$56/GroupGlobally/GatherAllOutputs/GroupByKey/Read
[INFO] 2017-11-01T18:18:10.492Z: (270298a67994dfae): Fusing consumer PAssert$56/GroupGlobally/GatherAllOutputs/GroupByKey/Reify
into PAssert$56/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign
[INFO] 2017-11-01T18:18:10.495Z: (270298a67994d274): Fusing consumer PAssert$56/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign
into PAssert$56/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map
[INFO] 2017-11-01T18:18:10.499Z: (270298a67994d53a): Fusing consumer View.AsMultimap/View.CreatePCollectionView/ParDo(ToIsmMetadataRecordForSize)
into View.AsMultimap/View.CreatePCollectionView/GBKaSVForSize/Read
[INFO] 2017-11-01T18:18:10.502Z: (270298a67994d800): Fusing consumer View.AsMultimap/View.CreatePCollectionView/GBKaSVForSize/Write
into View.AsMultimap/View.CreatePCollectionView/ParMultiDo(ToIsmRecordForMapLike)
[INFO] 2017-11-01T18:18:10.505Z: (270298a67994dac6): Fusing consumer View.AsMultimap/View.CreatePCollectionView/GBKaSVForData/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Write
into View.AsMultimap/View.CreatePCollectionView/GBKaSVForData/ParDo(GroupByKeyHashAndSortByKeyAndWindow)
[INFO] 2017-11-01T18:18:10.509Z: (270298a67994dd8c): Fusing consumer View.AsMultimap/View.CreatePCollectionView/GBKaSVForData/ParDo(GroupByKeyHashAndSortByKeyAndWindow)
into CreateEmptyView/Read(CreateSource)
[INFO] 2017-11-01T18:18:10.513Z: (270298a67994d052): Fusing consumer View.AsMultimap/View.CreatePCollectionView/ParMultiDo(ToIsmRecordForMapLike)
into View.AsMultimap/View.CreatePCollectionView/GBKaSVForData/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read
[INFO] 2017-11-01T18:18:10.516Z: (270298a67994d318): Fusing consumer View.AsMultimap/View.CreatePCollectionView/ParDo(ToIsmMetadataRecordForKey)
into View.AsMultimap/View.CreatePCollectionView/GBKaSVForKeys/Read
[INFO] 2017-11-01T18:18:10.518Z: (270298a67994d5de): Fusing consumer View.AsMultimap/View.CreatePCollectionView/GBKaSVForKeys/Write
into View.AsMultimap/View.CreatePCollectionView/ParMultiDo(ToIsmRecordForMapLike)
[INFO] 2017-11-01T18:18:10.641Z: (15fd997287a29d58): Executing operation View.AsMultimap/View.CreatePCollectionView/GBKaSVForData/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Create
[INFO] 2017-11-01T18:18:10.659Z: (7b99242a8d754a5d): Starting 1 workers in us-central1-f...
[INFO] 2017-11-01T18:18:10.708Z: (15fd997287a29814): Executing operation CreateEmptyView/Read(CreateSource)+View.AsMultimap/View.CreatePCollectionView/GBKaSVForData/ParDo(GroupByKeyHashAndSortByKeyAndWindow)+View.AsMultimap/View.CreatePCollectionView/GBKaSVForData/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Write
[INFO] 2017-11-01T18:18:11.841Z: (4e79c04076e4c537): Workers have started successfully.
[INFO] 2017-11-01T18:18:09.873Z: (626e98f78711261f): Fusing consumer PAssert$57/GroupGlobally/WindowIntoDummy/Window.Assign
into PAssert$57/GroupGlobally/Create.Values/Read(CreateSource)
[INFO] 2017-11-01T18:18:09.964Z: (5b5d48532241bf3b): Executing operation SumIntegers/GroupByKey/Create
[INFO] 2017-11-01T18:18:09.982Z: (947460efa4848e3c): Starting 1 workers in us-central1-f...
[INFO] 2017-11-01T18:18:10.020Z: (5b5d48532241b3fa): Executing operation CreateSideInput/Read(CreateSource)+SumIntegers/GroupByKey+SumIntegers/Combine.GroupedValues/Partial+SumIntegers/GroupByKey/Reify+SumIntegers/GroupByKey/Write
[INFO] 2017-11-01T18:18:16.283Z: (51f58f8fa33d7344): Autoscaling: Raised the number of workers
to 0 based on the rate of progress in the currently running step(s).
[INFO] 2017-11-01T18:18:16.986Z: (7c20f697942c8ea7): Cleaning up.
[INFO] 2017-11-01T18:18:17.011Z: (7c20f697942c88b5): Stopping worker pool...
[INFO] 2017-11-01T18:18:18.186Z: (33859483fe6310f1): Autoscaling: Raised the number of workers
to 0 based on the rate of progress in the currently running step(s).
[INFO] 2017-11-01T18:18:21.251Z: (7324085fa9f15354): Workers have started successfully.
[INFO] 2017-11-01T18:18:21.737Z: (ef134921eb835bfe): Workers have started successfully.
[INFO] 2017-11-01T18:18:21.453Z: (f7558dbb82b0153a): Workers have started successfully.
[INFO] 2017-11-01T18:18:23.039Z: (659d37a92e73502e): Executing operation View.AsMap/View.CreatePCollectionView/GBKaSVForData/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Close
[INFO] 2017-11-01T18:18:23.056Z: (659d37a92e7352b9): Executing operation View.AsMap/View.CreatePCollectionView/GBKaSVForSize/Create
[INFO] 2017-11-01T18:18:23.068Z: (31ca5d223c0cbb57): Executing operation View.AsMap/View.CreatePCollectionView/GBKaSVForKeys/Create
[INFO] 2017-11-01T18:18:23.116Z: (31ca5d223c0cb750): Executing operation View.AsMap/View.CreatePCollectionView/GBKaSVForData/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read+View.AsMap/View.CreatePCollectionView/ParMultiDo(ToIsmRecordForMapLike)+View.AsMap/View.CreatePCollectionView/GBKaSVForSize/Write+View.AsMap/View.CreatePCollectionView/GBKaSVForKeys/Write
[INFO] 2017-11-01T18:18:23.437Z: (2bf73bb3ce5cc3e0): Workers have started successfully.
[INFO] 2017-11-01T18:18:26.898Z: (51f58f8fa33d7af7): Autoscaling: Raised the number of workers
to 1 based on the rate of progress in the currently running step(s).
[INFO] 2017-11-01T18:18:28.709Z: (33859483fe631518): Autoscaling: Raised the number of workers
to 1 based on the rate of progress in the currently running step(s).
[INFO] 2017-11-01T18:18:29.936Z: (e0f9036bb5c9c1af): Workers have started successfully.
[INFO] 2017-11-01T18:18:27.527Z: (28e72ff336b0ae25): Workers have started successfully.
[INFO] 2017-11-01T18:18:27.970Z: (d1a60c14e5079557): Executing operation View.AsMultimap/View.CreatePCollectionView/GBKaSVForData/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Close
[INFO] 2017-11-01T18:18:27.985Z: (d1a60c14e5079c3e): Executing operation View.AsMultimap/View.CreatePCollectionView/GBKaSVForSize/Create
[INFO] 2017-11-01T18:18:27.997Z: (339a408dd21d7839): Executing operation View.AsMultimap/View.CreatePCollectionView/GBKaSVForKeys/Create
[INFO] 2017-11-01T18:18:28.044Z: (d1a60c14e507957b): Executing operation View.AsMultimap/View.CreatePCollectionView/GBKaSVForData/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read+View.AsMultimap/View.CreatePCollectionView/ParMultiDo(ToIsmRecordForMapLike)+View.AsMultimap/View.CreatePCollectionView/GBKaSVForSize/Write+View.AsMultimap/View.CreatePCollectionView/GBKaSVForKeys/Write
[INFO] 2017-11-01T18:18:29.091Z: (a1baa46d5e3b4c5b): Executing operation View.AsList/View.CreatePCollectionView/CreateDataflowView
[INFO] 2017-11-01T18:18:29.153Z: (a1baa46d5e3b44d7): Executing operation PAssert$45/GroupGlobally/GatherAllOutputs/GroupByKey/Create
[INFO] 2017-11-01T18:18:29.200Z: (a1baa46d5e3b4246): Executing operation CreateMainInput/Read(CreateSource)+OutputSideInputs+PAssert$45/GroupGlobally/Window.Into()/Window.Assign+PAssert$45/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$45/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$45/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$45/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$45/GroupGlobally/GatherAllOutputs/GroupByKey/Write
[INFO] 2017-11-01T18:18:33.749Z: (659d37a92e735474): Executing operation View.AsMap/View.CreatePCollectionView/GBKaSVForSize/Close
[INFO] 2017-11-01T18:18:33.758Z: (31ca5d223c0cb734): Executing operation View.AsMap/View.CreatePCollectionView/GBKaSVForKeys/Close
[INFO] 2017-11-01T18:18:33.770Z: (659d37a92e735119): Executing operation View.AsMap/View.CreatePCollectionView/GBKaSVForSize/Read+View.AsMap/View.CreatePCollectionView/ParDo(ToIsmMetadataRecordForSize)
[INFO] 2017-11-01T18:18:33.784Z: (31ca5d223c0cb409): Executing operation View.AsMap/View.CreatePCollectionView/GBKaSVForKeys/Read+View.AsMap/View.CreatePCollectionView/ParDo(ToIsmMetadataRecordForKey)
[INFO] 2017-11-01T18:18:35.098Z: (339a408dd21d70a1): Executing operation View.AsMultimap/View.CreatePCollectionView/GBKaSVForSize/Close
[INFO] 2017-11-01T18:18:35.113Z: (d1a60c14e5079a6f): Executing operation View.AsMultimap/View.CreatePCollectionView/GBKaSVForKeys/Close
[INFO] 2017-11-01T18:18:35.124Z: (339a408dd21d7c6a): Executing operation View.AsMultimap/View.CreatePCollectionView/GBKaSVForSize/Read+View.AsMultimap/View.CreatePCollectionView/ParDo(ToIsmMetadataRecordForSize)
[INFO] 2017-11-01T18:18:35.133Z: (d1a60c14e5079a78): Executing operation View.AsMultimap/View.CreatePCollectionView/GBKaSVForKeys/Read+View.AsMultimap/View.CreatePCollectionView/ParDo(ToIsmMetadataRecordForKey)
[INFO] 2017-11-01T18:18:35.768Z: (a1baa46d5e3b406a): Executing operation PAssert$45/GroupGlobally/GatherAllOutputs/GroupByKey/Close
[INFO] 2017-11-01T18:18:35.783Z: (a1baa46d5e3b4612): Executing operation PAssert$45/GroupGlobally/GroupDummyAndContents/Create
[INFO] 2017-11-01T18:18:35.828Z: (a1baa46d5e3b4436): Executing operation PAssert$45/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$45/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$45/GroupGlobally/GroupDummyAndContents/Reify+PAssert$45/GroupGlobally/GroupDummyAndContents/Write
[INFO] 2017-11-01T18:18:35.840Z: (c2c136ee6908b090): Executing operation PAssert$45/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$45/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$45/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$45/GroupGlobally/RewindowActuals/Window.Assign+PAssert$45/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$45/GroupGlobally/GroupDummyAndContents/Reify+PAssert$45/GroupGlobally/GroupDummyAndContents/Write
[INFO] 2017-11-01T18:18:38.599Z: (a7334ccd9e8f28e8): Executing operation View.AsMap/View.CreatePCollectionView/GBKaSVForData/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Close
[INFO] 2017-11-01T18:18:38.617Z: (a7334ccd9e8f251d): Executing operation View.AsMap/View.CreatePCollectionView/GBKaSVForSize/Create
[INFO] 2017-11-01T18:18:38.627Z: (2bdd76fd2b0e9cf9): Executing operation View.AsMap/View.CreatePCollectionView/GBKaSVForKeys/Create
[INFO] 2017-11-01T18:18:38.680Z: (a7334ccd9e8f2b54): Executing operation View.AsMap/View.CreatePCollectionView/GBKaSVForData/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read+View.AsMap/View.CreatePCollectionView/ParMultiDo(ToIsmRecordForMapLike)+View.AsMap/View.CreatePCollectionView/GBKaSVForSize/Write+View.AsMap/View.CreatePCollectionView/GBKaSVForKeys/Write
[INFO] 2017-11-01T18:18:43.079Z: (38f016a48612dde8): Executing operation View.AsIterable/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Close
[INFO] 2017-11-01T18:18:43.095Z: (38f016a48612d8ff): Executing operation View.AsIterable/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read+View.AsIterable/View.CreatePCollectionView/ParDo(ToIsmRecordForNonGlobalWindow)
[INFO] 2017-11-01T18:18:43.675Z: (a1baa46d5e3b4d67): Executing operation PAssert$45/GroupGlobally/GroupDummyAndContents/Close
[INFO] 2017-11-01T18:18:43.696Z: (a1baa46d5e3b425a): Executing operation PAssert$45/GroupGlobally/GroupDummyAndContents/Read+PAssert$45/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$45/GroupGlobally/Values/Values/Map+PAssert$45/GroupGlobally/ParDo(Concat)+PAssert$45/GetPane/Map+PAssert$45/RunChecks+PAssert$45/VerifyAssertions/ParDo(DefaultConclude)
[INFO] 2017-11-01T18:18:45.550Z: (bbc5e9399a1c0b37): Executing operation Combine.globally(SumInteger)/Combine.perKey(SumInteger)/GroupByKey/Close
[INFO] 2017-11-01T18:18:45.567Z: (bbc5e9399a1c0a2f): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Create
[INFO] 2017-11-01T18:18:45.616Z: (bbc5e9399a1c0b7a): Executing operation Combine.globally(SumInteger)/Combine.perKey(SumInteger)/GroupByKey/Read+Combine.globally(SumInteger)/Combine.perKey(SumInteger)/Combine.GroupedValues+Combine.globally(SumInteger)/Combine.perKey(SumInteger)/Combine.GroupedValues/Extract+Combine.globally(SumInteger)/Values/Values/Map+Combine.globally(SumInteger)/View.AsIterable/View.CreatePCollectionView/ParDo(ToIsmRecordForGlobalWindow)+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/WithKeys/AddKeys/Map+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Partial+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Reify+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Write
[INFO] 2017-11-01T18:18:46.706Z: (659d37a92e735cf7): Executing operation View.AsMap/View.CreatePCollectionView/Flatten.PCollections
[INFO] 2017-11-01T18:18:46.808Z: (659d37a92e73521f): Executing operation View.AsMap/View.CreatePCollectionView/CreateDataflowView
[INFO] 2017-11-01T18:18:46.909Z: (659d37a92e735161): Executing operation PAssert$50/GroupGlobally/GatherAllOutputs/GroupByKey/Create
[INFO] 2017-11-01T18:18:46.953Z: (659d37a92e73516a): Executing operation CreateMainInput/Read(CreateSource)+OutputSideInputs+PAssert$50/GroupGlobally/Window.Into()/Window.Assign+PAssert$50/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$50/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$50/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$50/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$50/GroupGlobally/GatherAllOutputs/GroupByKey/Write
[INFO] 2017-11-01T18:18:47.626Z: (9d716c8abdfaee4c): Cleaning up.
[INFO] 2017-11-01T18:18:47.652Z: (9d716c8abdfaec86): Stopping worker pool...
[INFO] 2017-11-01T18:18:48.635Z: (54cc2ccdf44f15c3): Executing operation View.AsMultimap/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Close
[INFO] 2017-11-01T18:18:48.663Z: (54cc2ccdf44f1ca6): Executing operation View.AsMultimap/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read+View.AsMultimap/View.CreatePCollectionView/ParDo(ToMultimap)
[INFO] 2017-11-01T18:18:50.094Z: (d1a60c14e5079aae): Executing operation View.AsMultimap/View.CreatePCollectionView/Flatten.PCollections
[INFO] 2017-11-01T18:18:50.188Z: (d1a60c14e50791d4): Executing operation View.AsMultimap/View.CreatePCollectionView/CreateDataflowView
[INFO] 2017-11-01T18:18:50.263Z: (d1a60c14e5079b3e): Executing operation PAssert$47/GroupGlobally/GatherAllOutputs/GroupByKey/Create
[INFO] 2017-11-01T18:18:50.345Z: (2bdd76fd2b0e980a): Executing operation View.AsMap/View.CreatePCollectionView/GBKaSVForSize/Close
[INFO] 2017-11-01T18:18:50.355Z: (a7334ccd9e8f2430): Executing operation View.AsMap/View.CreatePCollectionView/GBKaSVForKeys/Close
[INFO] 2017-11-01T18:18:50.366Z: (2bdd76fd2b0e9419): Executing operation View.AsMap/View.CreatePCollectionView/GBKaSVForSize/Read+View.AsMap/View.CreatePCollectionView/ParDo(ToIsmMetadataRecordForSize)
[INFO] 2017-11-01T18:18:50.375Z: (a7334ccd9e8f24cb): Executing operation View.AsMap/View.CreatePCollectionView/GBKaSVForKeys/Read+View.AsMap/View.CreatePCollectionView/ParDo(ToIsmMetadataRecordForKey)
[INFO] 2017-11-01T18:18:51.061Z: (659d37a92e735914): Executing operation PAssert$50/GroupGlobally/GatherAllOutputs/GroupByKey/Close
[INFO] 2017-11-01T18:18:51.077Z: (659d37a92e7350ac): Executing operation PAssert$50/GroupGlobally/GroupDummyAndContents/Create
[INFO] 2017-11-01T18:18:51.121Z: (659d37a92e735ba8): Executing operation PAssert$50/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$50/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$50/GroupGlobally/GroupDummyAndContents/Reify+PAssert$50/GroupGlobally/GroupDummyAndContents/Write
[INFO] 2017-11-01T18:18:51.132Z: (17f2a1c85320c764): Executing operation PAssert$50/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$50/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$50/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$50/GroupGlobally/RewindowActuals/Window.Assign+PAssert$50/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$50/GroupGlobally/GroupDummyAndContents/Reify+PAssert$50/GroupGlobally/GroupDummyAndContents/Write
[INFO] 2017-11-01T18:18:50.310Z: (d1a60c14e507947b): Executing operation CreateMainInput/Read(CreateSource)+OutputSideInputs+PAssert$47/GroupGlobally/Window.Into()/Window.Assign+PAssert$47/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$47/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$47/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$47/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$47/GroupGlobally/GatherAllOutputs/GroupByKey/Write
[INFO] 2017-11-01T18:18:52.368Z: (e47feb618e4aee9b): Executing operation View.AsIterable/View.CreatePCollectionView/CreateDataflowView
[INFO] 2017-11-01T18:18:52.440Z: (38f016a48612d138): Executing operation PAssert$53/GroupGlobally/GatherAllOutputs/GroupByKey/Create
[INFO] 2017-11-01T18:18:52.504Z: (38f016a48612d5a2): Executing operation CreateMainInput/Create.Values/Read(CreateSource)+CreateMainInput/ParDo(ConvertTimestamps)+MainWindowInto/Window.Assign+OutputSideInputs+PAssert$53/GroupGlobally/Window.Into()/Window.Assign+PAssert$53/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$53/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$53/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$53/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$53/GroupGlobally/GatherAllOutputs/GroupByKey/Write
[INFO] 2017-11-01T18:18:54.595Z: (bbc5e9399a1c09f0): Executing operation Combine.globally(SumInteger)/View.AsIterable/View.CreatePCollectionView/CreateDataflowView
[INFO] 2017-11-01T18:18:54.660Z: (bbc5e9399a1c075c): Executing operation Combine.globally(SumInteger)/CreateVoid/Read(CreateSource)+Combine.globally(SumInteger)/ProduceDefault+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/WithKeys/AddKeys/Map+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Partial+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Reify+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Write
[INFO] 2017-11-01T18:18:57.384Z: (d1a60c14e507926d): Executing operation PAssert$47/GroupGlobally/GatherAllOutputs/GroupByKey/Close
[INFO] 2017-11-01T18:18:57.402Z: (d1a60c14e5079de5): Executing operation PAssert$47/GroupGlobally/GroupDummyAndContents/Create
[INFO] 2017-11-01T18:18:57.449Z: (d1a60c14e5079291): Executing operation PAssert$47/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$47/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$47/GroupGlobally/GroupDummyAndContents/Reify+PAssert$47/GroupGlobally/GroupDummyAndContents/Write
[INFO] 2017-11-01T18:18:57.461Z: (388934e0ac87096f): Executing operation PAssert$47/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$47/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$47/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$47/GroupGlobally/RewindowActuals/Window.Assign+PAssert$47/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$47/GroupGlobally/GroupDummyAndContents/Reify+PAssert$47/GroupGlobally/GroupDummyAndContents/Write
[INFO] 2017-11-01T18:18:57.480Z: (bbc5e9399a1c08a7): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Close
[INFO] 2017-11-01T18:18:57.497Z: (bbc5e9399a1c079f): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Create
[INFO] 2017-11-01T18:18:57.550Z: (bbc5e9399a1c012c): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Read+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Extract+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map+View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey)+View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Write
[INFO] 2017-11-01T18:18:57.589Z: (54cc2ccdf44f180e): Executing operation View.AsMultimap/View.CreatePCollectionView/CreateDataflowView
[INFO] 2017-11-01T18:18:57.659Z: (54cc2ccdf44f1cb7): Executing operation PAssert$54/GroupGlobally/GatherAllOutputs/GroupByKey/Create
[INFO] 2017-11-01T18:18:57.707Z: (54cc2ccdf44f1ad6): Executing operation CreateMainInput/Read(CreateSource)+OutputSideInputs+PAssert$54/GroupGlobally/Window.Into()/Window.Assign+PAssert$54/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$54/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$54/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$54/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$54/GroupGlobally/GatherAllOutputs/GroupByKey/Write
[INFO] 2017-11-01T18:18:58.769Z: (38f016a48612de76): Executing operation PAssert$53/GroupGlobally/GatherAllOutputs/GroupByKey/Close
[INFO] 2017-11-01T18:18:58.787Z: (38f016a48612d1fe): Executing operation PAssert$53/GroupGlobally/GroupDummyAndContents/Create
[INFO] 2017-11-01T18:18:58.831Z: (38f016a48612dad2): Executing operation PAssert$53/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$53/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$53/GroupGlobally/GroupDummyAndContents/Reify+PAssert$53/GroupGlobally/GroupDummyAndContents/Write
[INFO] 2017-11-01T18:18:58.842Z: (e47feb618e4ae7e5): Executing operation PAssert$53/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$53/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$53/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$53/GroupGlobally/RewindowActuals/Window.Assign+PAssert$53/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$53/GroupGlobally/GroupDummyAndContents/Reify+PAssert$53/GroupGlobally/GroupDummyAndContents/Write
[INFO] 2017-11-01T18:19:00.545Z: (17f2a1c85320c57e): Executing operation PAssert$50/GroupGlobally/GroupDummyAndContents/Close
[INFO] 2017-11-01T18:19:00.564Z: (17f2a1c85320c4c1): Executing operation PAssert$50/GroupGlobally/GroupDummyAndContents/Read+PAssert$50/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$50/GroupGlobally/Values/Values/Map+PAssert$50/GroupGlobally/ParDo(Concat)+PAssert$50/GetPane/Map+PAssert$50/RunChecks+PAssert$50/VerifyAssertions/ParDo(DefaultConclude)
[INFO] 2017-11-01T18:19:01.147Z: (6447b13a28f9316f): Workers have started successfully.
[INFO] 2017-11-01T18:19:02.121Z: (388934e0ac870d79): Executing operation PAssert$47/GroupGlobally/GroupDummyAndContents/Close
[INFO] 2017-11-01T18:19:02.143Z: (388934e0ac870d44): Executing operation PAssert$47/GroupGlobally/GroupDummyAndContents/Read+PAssert$47/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$47/GroupGlobally/Values/Values/Map+PAssert$47/GroupGlobally/ParDo(Concat)+PAssert$47/GetPane/Map+PAssert$47/RunChecks+PAssert$47/VerifyAssertions/ParDo(DefaultConclude)
[INFO] 2017-11-01T18:19:02.314Z: (a7334ccd9e8f286d): Executing operation View.AsMap/View.CreatePCollectionView/Flatten.PCollections
[INFO] 2017-11-01T18:19:02.440Z: (a7334ccd9e8f26ac): Executing operation View.AsMap/View.CreatePCollectionView/CreateDataflowView
[INFO] 2017-11-01T18:19:02.539Z: (a7334ccd9e8f2fea): Executing operation PAssert$48/GroupGlobally/GatherAllOutputs/GroupByKey/Create
[INFO] 2017-11-01T18:19:02.628Z: (a7334ccd9e8f2621): Executing operation CreateMainInput/Read(CreateSource)+OutputSideInputs+PAssert$48/GroupGlobally/Window.Into()/Window.Assign+PAssert$48/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$48/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$48/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$48/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$48/GroupGlobally/GatherAllOutputs/GroupByKey/Write
ERROR: Maven JVM terminated unexpectedly with exit code 137


Mime
View raw message