You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by Apache Jenkins Server <je...@builds.apache.org> on 2017/11/01 19:04:46 UTC
Build failed in Jenkins:
beam_PostCommit_Java_ValidatesRunner_Dataflow #4266
See <https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Dataflow/4266/display/redirect?page=changes>
Changes:
[lcwik] [BEAM-2482] - CodedValueMutationDetector should use the coders
[lcwik] Remove obsolete extra parameter
------------------------------------------
[...truncated 7.31 MB...]
[INFO] Adding PAssert$62/GroupGlobally/Values/Values/Map as step s27
[INFO] Adding PAssert$62/GroupGlobally/ParDo(Concat) as step s28
[INFO] Adding PAssert$62/GetPane/Map as step s29
[INFO] Adding PAssert$62/RunChecks as step s30
[INFO] Adding PAssert$62/VerifyAssertions/ParDo(DefaultConclude) as step s31
[INFO] 2017-11-01T19:04:00.559Z: (adc850d5e33f1418): Executing operation View.AsMap/View.CreatePCollectionView/CreateDataflowView
[INFO] 2017-11-01T19:04:00.695Z: (adc850d5e33f1d76): Executing operation PAssert$58/GroupGlobally/GatherAllOutputs/GroupByKey/Create
[INFO] 2017-11-01T19:04:00.782Z: (d013b8fc88340f11): Executing operation CreateMainInput/Read(CreateSource)+OutputSideInputs+PAssert$58/GroupGlobally/Window.Into()/Window.Assign+PAssert$58/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$58/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$58/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$58/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$58/GroupGlobally/GatherAllOutputs/GroupByKey/Write
[INFO] To access the Dataflow monitoring console, please navigate to https://console.cloud.google.com/dataflow/jobsDetail/locations/us-central1/jobs/2017-11-01_12_04_01-917909264737197999?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_12_04_01-917909264737197999
[INFO] Running Dataflow job 2017-11-01_12_04_01-917909264737197999 with 1 expected assertions.
[INFO] Staging files complete: 0 files cached, 132 files newly uploaded
[INFO] Staging pipeline description to gs://temp-storage-for-validates-runner-tests//viewtest0testemptymapsideinputwithnondeterministickeycoder-jenkins-1101190312-6be32882/output/results/staging/
[INFO] Uploading <43248 bytes, hash RRfNk0vWf1vUYvk5gb318A> to gs://temp-storage-for-validates-runner-tests//viewtest0testemptymapsideinputwithnondeterministickeycoder-jenkins-1101190312-6be32882/output/results/staging/pipeline-RRfNk0vWf1vUYvk5gb318A.pb
[INFO] 2017-11-01T19:04:00.219Z: (ebde821b411e46f6): Autoscaling: Raised the number of workers to 2 based on the rate of progress in the currently running step(s).
[INFO] 2017-11-01T19:04:01.649Z: (997213e479082b62): Executing operation PAssert$57/GroupGlobally/GroupDummyAndContents/Close
[INFO] 2017-11-01T19:04:01.681Z: (91ac886bd2d58aa): Executing operation PAssert$57/GroupGlobally/GroupDummyAndContents/Read+PAssert$57/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$57/GroupGlobally/Values/Values/Map+PAssert$57/GroupGlobally/ParDo(Concat)+PAssert$57/GetPane/Map+PAssert$57/RunChecks+PAssert$57/VerifyAssertions/ParDo(DefaultConclude)
[INFO] Adding CreateEmptyView/Read(CreateSource) as step s1
[INFO] Adding View.AsMap/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey) as step s2
[INFO] Adding View.AsMap/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly as step s3
[INFO] Adding View.AsMap/View.CreatePCollectionView/ParDo(ToMap) as step s4
[INFO] Adding View.AsMap/View.CreatePCollectionView/CreateDataflowView as step s5
[INFO] Adding Create1/Read(CreateSource) as step s6
[INFO] Adding OutputSideInputs as step s7
[INFO] Adding PAssert$60/GroupGlobally/Window.Into()/Window.Assign as step s8
[INFO] Adding PAssert$60/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows) as step s9
[INFO] Adding PAssert$60/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map as step s10
[INFO] Adding PAssert$60/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign as step s11
[INFO] Adding PAssert$60/GroupGlobally/GatherAllOutputs/GroupByKey as step s12
[INFO] Adding PAssert$60/GroupGlobally/GatherAllOutputs/Values/Values/Map as step s13
[INFO] Adding PAssert$60/GroupGlobally/RewindowActuals/Window.Assign as step s14
[INFO] Adding PAssert$60/GroupGlobally/KeyForDummy/AddKeys/Map as step s15
[INFO] Adding PAssert$60/GroupGlobally/RemoveActualsTriggering/Flatten.PCollections as step s16
[INFO] Adding PAssert$60/GroupGlobally/Create.Values/Read(CreateSource) as step s17
[INFO] Adding PAssert$60/GroupGlobally/WindowIntoDummy/Window.Assign as step s18
[INFO] Adding PAssert$60/GroupGlobally/RemoveDummyTriggering/Flatten.PCollections as step s19
[INFO] Adding PAssert$60/GroupGlobally/FlattenDummyAndContents as step s20
[INFO] Adding PAssert$60/GroupGlobally/NeverTrigger/Flatten.PCollections as step s21
[INFO] Adding PAssert$60/GroupGlobally/GroupDummyAndContents as step s22
[INFO] Adding PAssert$60/GroupGlobally/Values/Values/Map as step s23
[INFO] Adding PAssert$60/GroupGlobally/ParDo(Concat) as step s24
[INFO] Adding PAssert$60/GetPane/Map as step s25
[INFO] Adding PAssert$60/RunChecks as step s26
[INFO] Adding PAssert$60/VerifyAssertions/ParDo(DefaultConclude) as step s27
[INFO] To access the Dataflow monitoring console, please navigate to https://console.cloud.google.com/dataflow/jobsDetail/locations/us-central1/jobs/2017-11-01_12_04_03-18187808509397968977?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_12_04_03-18187808509397968977
[INFO] Running Dataflow job 2017-11-01_12_04_03-18187808509397968977 with 1 expected assertions.
[INFO] 2017-11-01T19:04:02.745Z: (8574788f261861cc): Executing operation PAssert$58/GroupGlobally/GatherAllOutputs/GroupByKey/Close
[INFO] 2017-11-01T19:04:02.781Z: (bac50ff67fc6ee23): Executing operation PAssert$58/GroupGlobally/GroupDummyAndContents/Create
[INFO] 2017-11-01T19:04:02.866Z: (bac50ff67fc6e80c): Executing operation PAssert$58/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$58/GroupGlobally/WindowIntoDummy/Window.Assign+PAssert$58/GroupGlobally/GroupDummyAndContents/Reify+PAssert$58/GroupGlobally/GroupDummyAndContents/Write
[INFO] 2017-11-01T19:04:02.897Z: (d013b8fc88340409): Executing operation PAssert$58/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$58/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$58/GroupGlobally/GatherAllOutputs/Values/Values/Map+PAssert$58/GroupGlobally/RewindowActuals/Window.Assign+PAssert$58/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$58/GroupGlobally/GroupDummyAndContents/Reify+PAssert$58/GroupGlobally/GroupDummyAndContents/Write
[INFO] 2017-11-01T19:03:55.494Z: (808d3dc9e07b05cb): Autoscaling is enabled for job 2017-11-01_12_03_55-9263127945834859239. The number of workers will be between 1 and 15.
[INFO] 2017-11-01T19:03:55.522Z: (808d3dc9e07b0484): Autoscaling was automatically enabled for job 2017-11-01_12_03_55-9263127945834859239.
[INFO] 2017-11-01T19:03:57.617Z: (298e46d019a653d5): Checking required Cloud APIs are enabled.
[INFO] 2017-11-01T19:04:01.377Z: (298e46d019a65965): Expanding CoGroupByKey operations into optimizable parts.
[INFO] 2017-11-01T19:04:01.410Z: (298e46d019a65402): Expanding GroupByKey operations into optimizable parts.
[INFO] 2017-11-01T19:04:01.415Z: (298e46d019a655a4): Lifting ValueCombiningMappingFns into MergeBucketsMappingFns
[INFO] 2017-11-01T19:04:01.440Z: (298e46d019a65dce): Fusing adjacent ParDo, Read, Write, and Flatten operations
[INFO] 2017-11-01T19:04:01.444Z: (298e46d019a65f70): Elided trivial flatten
[INFO] 2017-11-01T19:04:01.447Z: (298e46d019a65112): Elided trivial flatten
[INFO] 2017-11-01T19:04:01.449Z: (298e46d019a652b4): Elided trivial flatten
[INFO] 2017-11-01T19:04:01.453Z: (298e46d019a65456): Fusing consumer CreateSideInput/ParDo(ConvertTimestamps) into CreateSideInput/Create.Values/Read(CreateSource)
[INFO] 2017-11-01T19:04:01.456Z: (298e46d019a655f8): Fusing consumer View.AsMap/View.CreatePCollectionView/ParDo(ToIsmMetadataRecordForKey) into View.AsMap/View.CreatePCollectionView/GBKaSVForKeys/Read
[INFO] 2017-11-01T19:04:01.458Z: (298e46d019a6579a): Fusing consumer View.AsMap/View.CreatePCollectionView/GBKaSVForData/ParDo(GroupByKeyHashAndSortByKeyAndWindow) into SideWindowInto/Window.Assign
[INFO] 2017-11-01T19:04:01.460Z: (298e46d019a6593c): Fusing consumer View.AsMap/View.CreatePCollectionView/GBKaSVForKeys/Write into View.AsMap/View.CreatePCollectionView/ParMultiDo(ToIsmRecordForMapLike)
[INFO] 2017-11-01T19:04:01.464Z: (298e46d019a65ade): Fusing consumer SideWindowInto/Window.Assign into CreateSideInput/ParDo(ConvertTimestamps)
[INFO] 2017-11-01T19:04:01.467Z: (298e46d019a65c80): Fusing consumer View.AsMap/View.CreatePCollectionView/ParMultiDo(ToIsmRecordForMapLike) into View.AsMap/View.CreatePCollectionView/GBKaSVForData/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read
[INFO] 2017-11-01T19:04:01.469Z: (298e46d019a65e22): Fusing consumer View.AsMap/View.CreatePCollectionView/ParDo(ToIsmMetadataRecordForSize) into View.AsMap/View.CreatePCollectionView/GBKaSVForSize/Read
[INFO] 2017-11-01T19:04:01.478Z: (298e46d019a65fc4): Fusing consumer View.AsMap/View.CreatePCollectionView/GBKaSVForSize/Write into View.AsMap/View.CreatePCollectionView/ParMultiDo(ToIsmRecordForMapLike)
[INFO] 2017-11-01T19:04:01.481Z: (298e46d019a65166): Fusing consumer View.AsMap/View.CreatePCollectionView/GBKaSVForData/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Write into View.AsMap/View.CreatePCollectionView/GBKaSVForData/ParDo(GroupByKeyHashAndSortByKeyAndWindow)
[INFO] 2017-11-01T19:04:01.483Z: (298e46d019a65308): Unzipping flatten s29 for input s24.26
[INFO] 2017-11-01T19:04:01.488Z: (298e46d019a654aa): Fusing unzipped copy of PAssert$59/GroupGlobally/GroupDummyAndContents/Reify, through flatten , into producer PAssert$59/GroupGlobally/KeyForDummy/AddKeys/Map
[INFO] 2017-11-01T19:04:01.493Z: (298e46d019a6564c): Fusing consumer PAssert$59/VerifyAssertions/ParDo(DefaultConclude) into PAssert$59/RunChecks
[INFO] 2017-11-01T19:04:01.500Z: (298e46d019a657ee): Fusing consumer PAssert$59/GetPane/Map into PAssert$59/GroupGlobally/ParDo(Concat)
[INFO] 2017-11-01T19:04:01.508Z: (298e46d019a65990): Unzipping flatten s29-u38 for input s31-reify-value9-c36
[INFO] 2017-11-01T19:04:01.511Z: (298e46d019a65b32): Fusing unzipped copy of PAssert$59/GroupGlobally/GroupDummyAndContents/Write, through flatten , into producer PAssert$59/GroupGlobally/GroupDummyAndContents/Reify
[INFO] 2017-11-01T19:04:01.516Z: (298e46d019a65cd4): Fusing consumer PAssert$59/GroupGlobally/Values/Values/Map into PAssert$59/GroupGlobally/GroupDummyAndContents/GroupByWindow
[INFO] 2017-11-01T19:04:01.521Z: (298e46d019a65e76): Fusing consumer PAssert$59/RunChecks into PAssert$59/GetPane/Map
[INFO] 2017-11-01T19:04:01.524Z: (298e46d019a65018): Fusing consumer PAssert$59/GroupGlobally/ParDo(Concat) into PAssert$59/GroupGlobally/Values/Values/Map
[INFO] 2017-11-01T19:04:01.527Z: (298e46d019a651ba): Fusing consumer PAssert$59/GroupGlobally/GroupDummyAndContents/GroupByWindow into PAssert$59/GroupGlobally/GroupDummyAndContents/Read
[INFO] 2017-11-01T19:04:01.532Z: (298e46d019a6535c): Fusing consumer MainWindowInto/Window.Assign into CreateMainInput/ParDo(ConvertTimestamps)
[INFO] 2017-11-01T19:04:01.539Z: (298e46d019a654fe): Fusing consumer PAssert$59/GroupGlobally/KeyForDummy/AddKeys/Map into PAssert$59/GroupGlobally/RewindowActuals/Window.Assign
[INFO] 2017-11-01T19:04:01.542Z: (298e46d019a656a0): Fusing consumer CreateMainInput/ParDo(ConvertTimestamps) into CreateMainInput/Create.Values/Read(CreateSource)
[INFO] 2017-11-01T19:04:01.545Z: (298e46d019a65842): Fusing consumer OutputSideInputs into MainWindowInto/Window.Assign
[INFO] 2017-11-01T19:04:01.550Z: (298e46d019a659e4): Fusing consumer PAssert$59/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign into PAssert$59/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map
[INFO] 2017-11-01T19:04:01.553Z: (298e46d019a65b86): Fusing consumer PAssert$59/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows) into PAssert$59/GroupGlobally/Window.Into()/Window.Assign
[INFO] 2017-11-01T19:04:01.556Z: (298e46d019a65d28): Fusing consumer PAssert$59/GroupGlobally/RewindowActuals/Window.Assign into PAssert$59/GroupGlobally/GatherAllOutputs/Values/Values/Map
[INFO] 2017-11-01T19:04:01.559Z: (298e46d019a65eca): Fusing consumer PAssert$59/GroupGlobally/GatherAllOutputs/Values/Values/Map into PAssert$59/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow
[INFO] 2017-11-01T19:04:01.563Z: (298e46d019a6506c): Fusing consumer PAssert$59/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow into PAssert$59/GroupGlobally/GatherAllOutputs/GroupByKey/Read
[INFO] 2017-11-01T19:04:01.570Z: (298e46d019a6520e): Fusing consumer PAssert$59/GroupGlobally/GatherAllOutputs/GroupByKey/Write into PAssert$59/GroupGlobally/GatherAllOutputs/GroupByKey/Reify
[INFO] 2017-11-01T19:04:01.574Z: (298e46d019a653b0): Fusing consumer PAssert$59/GroupGlobally/GatherAllOutputs/GroupByKey/Reify into PAssert$59/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign
[INFO] 2017-11-01T19:04:01.579Z: (298e46d019a65552): Fusing consumer PAssert$59/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map into PAssert$59/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)
[INFO] 2017-11-01T19:04:01.586Z: (298e46d019a656f4): Fusing consumer PAssert$59/GroupGlobally/Window.Into()/Window.Assign into OutputSideInputs
[INFO] 2017-11-01T19:04:01.591Z: (298e46d019a65896): Fusing consumer PAssert$59/GroupGlobally/GroupDummyAndContents/Reify into PAssert$59/GroupGlobally/WindowIntoDummy/Window.Assign
[INFO] 2017-11-01T19:04:01.596Z: (298e46d019a65a38): Fusing consumer PAssert$59/GroupGlobally/GroupDummyAndContents/Write into PAssert$59/GroupGlobally/GroupDummyAndContents/Reify
[INFO] 2017-11-01T19:04:01.602Z: (298e46d019a65bda): Fusing consumer PAssert$59/GroupGlobally/WindowIntoDummy/Window.Assign into PAssert$59/GroupGlobally/Create.Values/Read(CreateSource)
[INFO] 2017-11-01T19:04:01.804Z: (ae0626c15e388587): Executing operation View.AsMap/View.CreatePCollectionView/GBKaSVForData/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Create
[INFO] 2017-11-01T19:04:01.821Z: (a5b637c28f6e0de1): Starting 1 workers in us-central1-f...
[INFO] 2017-11-01T19:04:01.883Z: (ae0626c15e388df1): Executing operation CreateSideInput/Create.Values/Read(CreateSource)+CreateSideInput/ParDo(ConvertTimestamps)+SideWindowInto/Window.Assign+View.AsMap/View.CreatePCollectionView/GBKaSVForData/ParDo(GroupByKeyHashAndSortByKeyAndWindow)+View.AsMap/View.CreatePCollectionView/GBKaSVForData/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Write
[INFO] 2017-11-01T19:04:06.612Z: (15995b19b7e06d4d): Cleaning up.
[INFO] 2017-11-01T19:04:06.634Z: (15995b19b7e06c17): Stopping worker pool...
[INFO] 2017-11-01T19:04:00.331Z: (6352df7721f83af5): Autoscaling is enabled for job 2017-11-01_12_04_00-7157028460609155273. The number of workers will be between 1 and 15.
[INFO] 2017-11-01T19:04:00.358Z: (6352df7721f83980): Autoscaling was automatically enabled for job 2017-11-01_12_04_00-7157028460609155273.
[INFO] 2017-11-01T19:04:03.095Z: (c5d87ea33c427919): Checking required Cloud APIs are enabled.
[INFO] 2017-11-01T19:04:07.019Z: (c5d87ea33c4278a9): Expanding CoGroupByKey operations into optimizable parts.
[INFO] 2017-11-01T19:04:07.043Z: (c5d87ea33c427166): Expanding GroupByKey operations into optimizable parts.
[INFO] 2017-11-01T19:04:07.050Z: (c5d87ea33c427048): Lifting ValueCombiningMappingFns into MergeBucketsMappingFns
[INFO] 2017-11-01T19:04:07.075Z: (c5d87ea33c427ab2): Fusing adjacent ParDo, Read, Write, and Flatten operations
[INFO] 2017-11-01T19:04:07.078Z: (c5d87ea33c427994): Elided trivial flatten
[INFO] 2017-11-01T19:04:07.082Z: (c5d87ea33c427876): Elided trivial flatten
[INFO] 2017-11-01T19:04:07.085Z: (c5d87ea33c427758): Elided trivial flatten
[INFO] 2017-11-01T19:04:07.089Z: (c5d87ea33c42763a): Fusing consumer View.AsMultimap/View.CreatePCollectionView/ParMultiDo(ToIsmRecordForMapLike) into View.AsMultimap/View.CreatePCollectionView/GBKaSVForData/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read
[INFO] 2017-11-01T19:04:07.092Z: (c5d87ea33c42751c): Fusing consumer View.AsMultimap/View.CreatePCollectionView/ParDo(ToIsmMetadataRecordForSize) into View.AsMultimap/View.CreatePCollectionView/GBKaSVForSize/Read
[INFO] 2017-11-01T19:04:07.095Z: (c5d87ea33c4273fe): Fusing consumer View.AsMultimap/View.CreatePCollectionView/GBKaSVForData/ParDo(GroupByKeyHashAndSortByKeyAndWindow) into CreateSideInput/Read(CreateSource)
[INFO] 2017-11-01T19:04:07.097Z: (c5d87ea33c4272e0): Fusing consumer View.AsMultimap/View.CreatePCollectionView/GBKaSVForData/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Write into View.AsMultimap/View.CreatePCollectionView/GBKaSVForData/ParDo(GroupByKeyHashAndSortByKeyAndWindow)
[INFO] 2017-11-01T19:04:07.101Z: (c5d87ea33c4271c2): Fusing consumer View.AsMultimap/View.CreatePCollectionView/GBKaSVForSize/Write into View.AsMultimap/View.CreatePCollectionView/ParMultiDo(ToIsmRecordForMapLike)
[INFO] 2017-11-01T19:04:07.104Z: (c5d87ea33c4270a4): Fusing consumer View.AsMultimap/View.CreatePCollectionView/ParDo(ToIsmMetadataRecordForKey) into View.AsMultimap/View.CreatePCollectionView/GBKaSVForKeys/Read
[INFO] 2017-11-01T19:04:07.107Z: (c5d87ea33c427f86): Fusing consumer View.AsMultimap/View.CreatePCollectionView/GBKaSVForKeys/Write into View.AsMultimap/View.CreatePCollectionView/ParMultiDo(ToIsmRecordForMapLike)
[INFO] 2017-11-01T19:04:07.109Z: (c5d87ea33c427e68): Fusing consumer PAssert$61/GroupGlobally/ParDo(Concat) into PAssert$61/GroupGlobally/Values/Values/Map
[INFO] 2017-11-01T19:04:07.112Z: (c5d87ea33c427d4a): Fusing consumer PAssert$61/GetPane/Map into PAssert$61/GroupGlobally/ParDo(Concat)
[INFO] 2017-11-01T19:04:07.115Z: (c5d87ea33c427c2c): Fusing consumer PAssert$61/GroupGlobally/GroupDummyAndContents/GroupByWindow into PAssert$61/GroupGlobally/GroupDummyAndContents/Read
[INFO] 2017-11-01T19:04:07.118Z: (c5d87ea33c427b0e): Unzipping flatten s25 for input s20.22
[INFO] 2017-11-01T19:04:07.121Z: (c5d87ea33c4279f0): Fusing unzipped copy of PAssert$61/GroupGlobally/GroupDummyAndContents/Reify, through flatten , into producer PAssert$61/GroupGlobally/KeyForDummy/AddKeys/Map
[INFO] 2017-11-01T19:04:07.125Z: (c5d87ea33c4278d2): Fusing consumer PAssert$61/GroupGlobally/GroupDummyAndContents/Reify into PAssert$61/GroupGlobally/WindowIntoDummy/Window.Assign
[INFO] 2017-11-01T19:04:07.128Z: (c5d87ea33c4277b4): Fusing consumer PAssert$61/GroupGlobally/Values/Values/Map into PAssert$61/GroupGlobally/GroupDummyAndContents/GroupByWindow
[INFO] 2017-11-01T19:04:07.132Z: (c5d87ea33c427696): Unzipping flatten s25-u38 for input s27-reify-value9-c36
[INFO] 2017-11-01T19:04:07.136Z: (c5d87ea33c427578): Fusing unzipped copy of PAssert$61/GroupGlobally/GroupDummyAndContents/Write, through flatten , into producer PAssert$61/GroupGlobally/GroupDummyAndContents/Reify
[INFO] 2017-11-01T19:04:07.139Z: (c5d87ea33c42745a): Fusing consumer PAssert$61/GroupGlobally/GroupDummyAndContents/Write into PAssert$61/GroupGlobally/GroupDummyAndContents/Reify
[INFO] 2017-11-01T19:04:07.142Z: (c5d87ea33c42733c): Fusing consumer PAssert$61/RunChecks into PAssert$61/GetPane/Map
[INFO] 2017-11-01T19:04:07.144Z: (c5d87ea33c42721e): Fusing consumer PAssert$61/VerifyAssertions/ParDo(DefaultConclude) into PAssert$61/RunChecks
[INFO] 2017-11-01T19:04:07.146Z: (c5d87ea33c427100): Fusing consumer PAssert$61/GroupGlobally/WindowIntoDummy/Window.Assign into PAssert$61/GroupGlobally/Create.Values/Read(CreateSource)
[INFO] 2017-11-01T19:04:07.150Z: (c5d87ea33c427fe2): Fusing consumer PAssert$61/GroupGlobally/GatherAllOutputs/GroupByKey/Reify into PAssert$61/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign
[INFO] 2017-11-01T19:04:07.153Z: (c5d87ea33c427ec4): Fusing consumer PAssert$61/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign into PAssert$61/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map
[INFO] 2017-11-01T19:04:07.156Z: (c5d87ea33c427da6): Fusing consumer OutputSideInputs into CreateMainInput/Read(CreateSource)
[INFO] 2017-11-01T19:04:07.159Z: (c5d87ea33c427c88): Fusing consumer PAssert$61/GroupGlobally/GatherAllOutputs/Values/Values/Map into PAssert$61/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow
[INFO] 2017-11-01T19:04:07.162Z: (c5d87ea33c427b6a): Fusing consumer PAssert$61/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map into PAssert$61/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)
[INFO] 2017-11-01T19:04:07.166Z: (c5d87ea33c427a4c): Fusing consumer PAssert$61/GroupGlobally/GatherAllOutputs/GroupByKey/Write into PAssert$61/GroupGlobally/GatherAllOutputs/GroupByKey/Reify
[INFO] 2017-11-01T19:04:07.169Z: (c5d87ea33c42792e): Fusing consumer PAssert$61/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows) into PAssert$61/GroupGlobally/Window.Into()/Window.Assign
[INFO] 2017-11-01T19:04:07.172Z: (c5d87ea33c427810): Fusing consumer PAssert$61/GroupGlobally/Window.Into()/Window.Assign into OutputSideInputs
[INFO] 2017-11-01T19:04:07.177Z: (c5d87ea33c4276f2): Fusing consumer PAssert$61/GroupGlobally/KeyForDummy/AddKeys/Map into PAssert$61/GroupGlobally/RewindowActuals/Window.Assign
[INFO] 2017-11-01T19:04:07.180Z: (c5d87ea33c4275d4): Fusing consumer PAssert$61/GroupGlobally/RewindowActuals/Window.Assign into PAssert$61/GroupGlobally/GatherAllOutputs/Values/Values/Map
[INFO] 2017-11-01T19:04:07.183Z: (c5d87ea33c4274b6): Fusing consumer PAssert$61/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow into PAssert$61/GroupGlobally/GatherAllOutputs/GroupByKey/Read
[INFO] 2017-11-01T19:04:07.368Z: (ef5d33fbdb36e75e): Executing operation View.AsMultimap/View.CreatePCollectionView/GBKaSVForData/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Create
[INFO] 2017-11-01T19:04:07.386Z: (2e2f5710b5a4586): Starting 1 workers in us-central1-f...
[INFO] 2017-11-01T19:04:07.476Z: (ef5d33fbdb36e66a): Executing operation CreateSideInput/Read(CreateSource)+View.AsMultimap/View.CreatePCollectionView/GBKaSVForData/ParDo(GroupByKeyHashAndSortByKeyAndWindow)+View.AsMultimap/View.CreatePCollectionView/GBKaSVForData/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Write
[INFO] 2017-11-01T19:04:03.154Z: (fc681379e57e2ead): Autoscaling is enabled for job 2017-11-01_12_04_03-18187808509397968977. The number of workers will be between 1 and 15.
[INFO] 2017-11-01T19:04:03.178Z: (fc681379e57e2844): Autoscaling was automatically enabled for job 2017-11-01_12_04_03-18187808509397968977.
[INFO] 2017-11-01T19:04:10.210Z: (d013b8fc88340feb): Executing operation PAssert$58/GroupGlobally/GroupDummyAndContents/Close
[INFO] 2017-11-01T19:04:05.243Z: (a69d07d713bc1287): Checking required Cloud APIs are enabled.
[INFO] 2017-11-01T19:04:10.248Z: (d013b8fc8834048a): Executing operation PAssert$58/GroupGlobally/GroupDummyAndContents/Read+PAssert$58/GroupGlobally/GroupDummyAndContents/GroupByWindow+PAssert$58/GroupGlobally/Values/Values/Map+PAssert$58/GroupGlobally/ParDo(Concat)+PAssert$58/GetPane/Map+PAssert$58/RunChecks+PAssert$58/VerifyAssertions/ParDo(DefaultConclude)
[INFO] 2017-11-01T19:04:08.928Z: (a69d07d713bc1397): Expanding CoGroupByKey operations into optimizable parts.
[INFO] 2017-11-01T19:04:08.942Z: (a69d07d713bc1ba8): Expanding GroupByKey operations into optimizable parts.
[INFO] 2017-11-01T19:04:08.945Z: (a69d07d713bc1f3a): Lifting ValueCombiningMappingFns into MergeBucketsMappingFns
[INFO] 2017-11-01T19:04:08.965Z: (a69d07d713bc1114): Fusing adjacent ParDo, Read, Write, and Flatten operations
[INFO] 2017-11-01T19:04:08.967Z: (a69d07d713bc14a6): Elided trivial flatten
[INFO] 2017-11-01T19:04:08.972Z: (a69d07d713bc1838): Elided trivial flatten
[INFO] 2017-11-01T19:04:08.976Z: (a69d07d713bc1bca): Elided trivial flatten
[INFO] 2017-11-01T19:04:08.980Z: (a69d07d713bc1f5c): Unzipping flatten s20 for input s15.15
[INFO] 2017-11-01T19:04:08.983Z: (a69d07d713bc12ee): Fusing unzipped copy of PAssert$60/GroupGlobally/GroupDummyAndContents/Reify, through flatten , into producer PAssert$60/GroupGlobally/KeyForDummy/AddKeys/Map
[INFO] 2017-11-01T19:04:08.985Z: (a69d07d713bc1680): Fusing consumer PAssert$60/GroupGlobally/GroupDummyAndContents/Reify into PAssert$60/GroupGlobally/WindowIntoDummy/Window.Assign
[INFO] 2017-11-01T19:04:08.988Z: (a69d07d713bc1a12): Fusing consumer PAssert$60/GetPane/Map into PAssert$60/GroupGlobally/ParDo(Concat)
[INFO] 2017-11-01T19:04:08.991Z: (a69d07d713bc1da4): Fusing consumer PAssert$60/RunChecks into PAssert$60/GetPane/Map
[INFO] 2017-11-01T19:04:08.994Z: (a69d07d713bc1136): Unzipping flatten s20-u27 for input s22-reify-value9-c25
[INFO] 2017-11-01T19:04:08.998Z: (a69d07d713bc14c8): Fusing unzipped copy of PAssert$60/GroupGlobally/GroupDummyAndContents/Write, through flatten , into producer PAssert$60/GroupGlobally/GroupDummyAndContents/Reify
[INFO] 2017-11-01T19:04:09.004Z: (a69d07d713bc185a): Fusing consumer PAssert$60/GroupGlobally/GroupDummyAndContents/Write into PAssert$60/GroupGlobally/GroupDummyAndContents/Reify
[INFO] 2017-11-01T19:04:09.007Z: (a69d07d713bc1bec): Fusing consumer PAssert$60/VerifyAssertions/ParDo(DefaultConclude) into PAssert$60/RunChecks
[INFO] 2017-11-01T19:04:09.010Z: (a69d07d713bc1f7e): Fusing consumer PAssert$60/GroupGlobally/GroupDummyAndContents/GroupByWindow into PAssert$60/GroupGlobally/GroupDummyAndContents/Read
[INFO] 2017-11-01T19:04:09.013Z: (a69d07d713bc1310): Fusing consumer PAssert$60/GroupGlobally/Values/Values/Map into PAssert$60/GroupGlobally/GroupDummyAndContents/GroupByWindow
[INFO] 2017-11-01T19:04:09.015Z: (a69d07d713bc16a2): Fusing consumer PAssert$60/GroupGlobally/ParDo(Concat) into PAssert$60/GroupGlobally/Values/Values/Map
[INFO] 2017-11-01T19:04:09.018Z: (a69d07d713bc1a34): Fusing consumer PAssert$60/GroupGlobally/WindowIntoDummy/Window.Assign into PAssert$60/GroupGlobally/Create.Values/Read(CreateSource)
[INFO] 2017-11-01T19:04:09.020Z: (a69d07d713bc1dc6): Fusing consumer PAssert$60/GroupGlobally/KeyForDummy/AddKeys/Map into PAssert$60/GroupGlobally/RewindowActuals/Window.Assign
[INFO] 2017-11-01T19:04:09.023Z: (a69d07d713bc1158): Fusing consumer PAssert$60/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows) into PAssert$60/GroupGlobally/Window.Into()/Window.Assign
[INFO] 2017-11-01T19:04:09.025Z: (a69d07d713bc14ea): Fusing consumer PAssert$60/GroupGlobally/RewindowActuals/Window.Assign into PAssert$60/GroupGlobally/GatherAllOutputs/Values/Values/Map
[INFO] 2017-11-01T19:04:09.027Z: (a69d07d713bc187c): Fusing consumer PAssert$60/GroupGlobally/GatherAllOutputs/Values/Values/Map into PAssert$60/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow
[INFO] 2017-11-01T19:04:09.029Z: (a69d07d713bc1c0e): Fusing consumer PAssert$60/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow into PAssert$60/GroupGlobally/GatherAllOutputs/GroupByKey/Read
[INFO] 2017-11-01T19:04:09.032Z: (a69d07d713bc1fa0): Fusing consumer PAssert$60/GroupGlobally/Window.Into()/Window.Assign into OutputSideInputs
[INFO] 2017-11-01T19:04:09.034Z: (a69d07d713bc1332): Fusing consumer PAssert$60/GroupGlobally/GatherAllOutputs/GroupByKey/Write into PAssert$60/GroupGlobally/GatherAllOutputs/GroupByKey/Reify
[INFO] 2017-11-01T19:04:09.036Z: (a69d07d713bc16c4): Fusing consumer PAssert$60/GroupGlobally/GatherAllOutputs/GroupByKey/Reify into PAssert$60/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign
[INFO] 2017-11-01T19:04:09.038Z: (a69d07d713bc1a56): Fusing consumer OutputSideInputs into Create1/Read(CreateSource)
[INFO] 2017-11-01T19:04:09.041Z: (a69d07d713bc1de8): Fusing consumer PAssert$60/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign into PAssert$60/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map
[INFO] 2017-11-01T19:04:09.043Z: (a69d07d713bc117a): Fusing consumer PAssert$60/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map into PAssert$60/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)
[INFO] 2017-11-01T19:04:09.046Z: (a69d07d713bc150c): Fusing consumer View.AsMap/View.CreatePCollectionView/ParDo(ToMap) into View.AsMap/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read
[INFO] 2017-11-01T19:04:09.048Z: (a69d07d713bc189e): Fusing consumer View.AsMap/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey) into CreateEmptyView/Read(CreateSource)
[INFO] 2017-11-01T19:04:09.050Z: (a69d07d713bc1c30): Fusing consumer View.AsMap/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Write into View.AsMap/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey)
[INFO] 2017-11-01T19:04:09.224Z: (f63257e233819b17): Executing operation View.AsMap/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Create
[INFO] 2017-11-01T19:04:09.243Z: (f2a38cd0445b613b): Starting 1 workers in us-central1-f...
[INFO] 2017-11-01T19:04:09.321Z: (f63257e233819921): Executing operation CreateEmptyView/Read(CreateSource)+View.AsMap/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey)+View.AsMap/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Write
[INFO] 2017-11-01T19:04:08.657Z: (f61854a74f9eb190): Cleaning up.
[INFO] 2017-11-01T19:04:08.678Z: (f61854a74f9eb012): Stopping worker pool...
[INFO] 2017-11-01T19:04:10.617Z: (b40220299b7fc942): Autoscaling: Raised the number of workers to 0 based on the rate of progress in the currently running step(s).
[INFO] 2017-11-01T19:04:01.397Z: (cbd119cecb3571b): Autoscaling is enabled for job 2017-11-01_12_04_01-917909264737197999. The number of workers will be between 1 and 15.
[INFO] 2017-11-01T19:04:01.417Z: (cbd119cecb358f6): Autoscaling was automatically enabled for job 2017-11-01_12_04_01-917909264737197999.
[INFO] 2017-11-01T19:04:04.178Z: (3638bc83a55f923c): Checking required Cloud APIs are enabled.
[INFO] 2017-11-01T19:04:08.781Z: (3638bc83a55f966c): Expanding CoGroupByKey operations into optimizable parts.
[INFO] 2017-11-01T19:04:08.806Z: (3638bc83a55f9daf): Expanding GroupByKey operations into optimizable parts.
[INFO] 2017-11-01T19:04:08.810Z: (3638bc83a55f9d85): Lifting ValueCombiningMappingFns into MergeBucketsMappingFns
[INFO] 2017-11-01T19:04:08.859Z: (3638bc83a55f9c89): Fusing adjacent ParDo, Read, Write, and Flatten operations
[INFO] 2017-11-01T19:04:08.862Z: (3638bc83a55f9c5f): Elided trivial flatten
[INFO] 2017-11-01T19:04:08.869Z: (3638bc83a55f9c35): Elided trivial flatten
[INFO] 2017-11-01T19:04:08.873Z: (3638bc83a55f9c0b): Elided trivial flatten
[INFO] 2017-11-01T19:04:08.878Z: (3638bc83a55f9be1): Unzipping flatten s24 for input s19.19
[INFO] 2017-11-01T19:04:08.886Z: (3638bc83a55f9bb7): Fusing unzipped copy of PAssert$62/GroupGlobally/GroupDummyAndContents/Reify, through flatten , into producer PAssert$62/GroupGlobally/KeyForDummy/AddKeys/Map
[INFO] 2017-11-01T19:04:08.891Z: (3638bc83a55f9b8d): Fusing consumer PAssert$62/GroupGlobally/GroupDummyAndContents/GroupByWindow into PAssert$62/GroupGlobally/GroupDummyAndContents/Read
[INFO] 2017-11-01T19:04:08.897Z: (3638bc83a55f9b63): Fusing consumer PAssert$62/GroupGlobally/ParDo(Concat) into PAssert$62/GroupGlobally/Values/Values/Map
[INFO] 2017-11-01T19:04:08.901Z: (3638bc83a55f9b39): Fusing consumer PAssert$62/GetPane/Map into PAssert$62/GroupGlobally/ParDo(Concat)
[INFO] 2017-11-01T19:04:08.908Z: (3638bc83a55f9b0f): Fusing consumer PAssert$62/GroupGlobally/Values/Values/Map into PAssert$62/GroupGlobally/GroupDummyAndContents/GroupByWindow
[INFO] 2017-11-01T19:04:08.912Z: (3638bc83a55f9ae5): Fusing consumer PAssert$62/RunChecks into PAssert$62/GetPane/Map
[INFO] 2017-11-01T19:04:08.920Z: (3638bc83a55f9abb): Fusing consumer PAssert$62/VerifyAssertions/ParDo(DefaultConclude) into PAssert$62/RunChecks
[INFO] 2017-11-01T19:04:08.926Z: (3638bc83a55f9a91): Unzipping flatten s24-u45 for input s26-reify-value18-c43
[INFO] 2017-11-01T19:04:08.933Z: (3638bc83a55f9a67): Fusing unzipped copy of PAssert$62/GroupGlobally/GroupDummyAndContents/Write, through flatten , into producer PAssert$62/GroupGlobally/GroupDummyAndContents/Reify
[INFO] 2017-11-01T19:04:08.939Z: (3638bc83a55f9a3d): Fusing consumer PAssert$62/GroupGlobally/GroupDummyAndContents/Reify into PAssert$62/GroupGlobally/WindowIntoDummy/Window.Assign
[INFO] 2017-11-01T19:04:08.944Z: (3638bc83a55f9a13): Fusing consumer PAssert$62/GroupGlobally/GroupDummyAndContents/Write into PAssert$62/GroupGlobally/GroupDummyAndContents/Reify
[INFO] 2017-11-01T19:04:08.950Z: (3638bc83a55f99e9): Fusing consumer PAssert$62/GroupGlobally/WindowIntoDummy/Window.Assign into PAssert$62/GroupGlobally/Create.Values/Read(CreateSource)
[INFO] 2017-11-01T19:04:08.962Z: (3638bc83a55f99bf): Fusing consumer PAssert$62/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map into PAssert$62/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)
[INFO] 2017-11-01T19:04:08.970Z: (3638bc83a55f9995): Fusing consumer PAssert$62/GroupGlobally/GatherAllOutputs/GroupByKey/Write into PAssert$62/GroupGlobally/GatherAllOutputs/GroupByKey/Reify
[INFO] 2017-11-01T19:04:08.975Z: (3638bc83a55f996b): Fusing consumer PAssert$62/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows) into PAssert$62/GroupGlobally/Window.Into()/Window.Assign
[INFO] 2017-11-01T19:04:08.985Z: (3638bc83a55f9941): Fusing consumer OutputSideInputs into Create123/Read(CreateSource)
[INFO] 2017-11-01T19:04:08.990Z: (3638bc83a55f9917): Fusing consumer PAssert$62/GroupGlobally/Window.Into()/Window.Assign into OutputSideInputs
[INFO] 2017-11-01T19:04:08.995Z: (3638bc83a55f98ed): Fusing consumer PAssert$62/GroupGlobally/GatherAllOutputs/Values/Values/Map into PAssert$62/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow
[INFO] 2017-11-01T19:04:09.002Z: (3638bc83a55f98c3): Fusing consumer PAssert$62/GroupGlobally/KeyForDummy/AddKeys/Map into PAssert$62/GroupGlobally/RewindowActuals/Window.Assign
[INFO] 2017-11-01T19:04:09.008Z: (3638bc83a55f9899): Fusing consumer PAssert$62/GroupGlobally/RewindowActuals/Window.Assign into PAssert$62/GroupGlobally/GatherAllOutputs/Values/Values/Map
[INFO] 2017-11-01T19:04:09.015Z: (3638bc83a55f986f): Fusing consumer PAssert$62/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow into PAssert$62/GroupGlobally/GatherAllOutputs/GroupByKey/Read
[INFO] 2017-11-01T19:04:09.021Z: (3638bc83a55f9845): Fusing consumer PAssert$62/GroupGlobally/GatherAllOutputs/GroupByKey/Reify into PAssert$62/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign
[INFO] 2017-11-01T19:04:09.028Z: (3638bc83a55f981b): Fusing consumer PAssert$62/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign into PAssert$62/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map
[INFO] 2017-11-01T19:04:09.033Z: (3638bc83a55f97f1): Fusing consumer View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Extract into View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues
[INFO] 2017-11-01T19:04:09.038Z: (3638bc83a55f97c7): Fusing consumer View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/ParDo(IsmRecordForSingularValuePerWindow) into View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Read
[INFO] 2017-11-01T19:04:09.045Z: (3638bc83a55f979d): Fusing consumer View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Write into View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Reify
[INFO] 2017-11-01T19:04:09.053Z: (3638bc83a55f9773): Fusing consumer View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/WithKeys/AddKeys/Map into Create47/Read(CreateSource)
[INFO] 2017-11-01T19:04:09.061Z: (3638bc83a55f9749): Fusing consumer View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Reify into View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Partial
[INFO] 2017-11-01T19:04:09.067Z: (3638bc83a55f971f): Fusing consumer View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues into View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Read
[INFO] 2017-11-01T19:04:09.073Z: (3638bc83a55f96f5): Fusing consumer View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/Write into View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey)
[INFO] 2017-11-01T19:04:09.078Z: (3638bc83a55f96cb): Fusing consumer View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Partial into View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/WithKeys/AddKeys/Map
[INFO] 2017-11-01T19:04:09.081Z: (3638bc83a55f96a1): Fusing consumer View.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey) into View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map
[INFO] 2017-11-01T19:04:09.084Z: (3638bc83a55f9677): Fusing consumer View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map into View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Extract
[INFO] 2017-11-01T19:04:09.287Z: (edeb3daade25ac94): Executing operation View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Create
[INFO] 2017-11-01T19:04:09.308Z: (e2a890873d138412): Starting 1 workers in us-central1-f...
[INFO] 2017-11-01T19:04:09.382Z: (edeb3daade25ab7a): Executing operation Create47/Read(CreateSource)+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-01T19:04:13.569Z: (e032c374b20aa681): Autoscaling: Raised the number of workers to 0 based on the rate of progress in the currently running step(s).
[INFO] 2017-11-01T19:04:15.067Z: (7d8fbd97507f84b0): Cleaning up.
[INFO] 2017-11-01T19:04:15.103Z: (7d8fbd97507f867e): Stopping worker pool...
[INFO] 2017-11-01T19:04:17.598Z: (42e3f73064ccaa4e): Autoscaling: Raised the number of workers to 0 based on the rate of progress in the currently running step(s).
[INFO] 2017-11-01T19:04:17.505Z: (ef489b963a8627b1): Autoscaling: Raised the number of workers to 0 based on the rate of progress in the currently running step(s).
[INFO] 2017-11-01T19:04:33.255Z: (ef489b963a8621c8): Autoscaling: Raised the number of workers to 1 based on the rate of progress in the currently running step(s).
[INFO] 2017-11-01T19:04:33.285Z: (42e3f73064cca6d7): Autoscaling: Raised the number of workers to 1 based on the rate of progress in the currently running step(s).
[INFO] 2017-11-01T19:04:37.924Z: (5b6fd1d333011c): Autoscaling: Resized worker pool from 1 to 0.
[INFO] 2017-11-01T19:04:37.926Z: (5b6fd1d3330e92): Autoscaling: Would further reduce the number of workers but reached the minimum number allowed for the job.
ERROR: Maven JVM terminated unexpectedly with exit code 137