Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 924B9200D1A for ; Mon, 9 Oct 2017 23:49:08 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 90A7B1609CE; Mon, 9 Oct 2017 21:49:08 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 837951609B8 for ; Mon, 9 Oct 2017 23:49:06 +0200 (CEST) Received: (qmail 77308 invoked by uid 500); 9 Oct 2017 21:49:05 -0000 Mailing-List: contact commits-help@beam.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@beam.apache.org Delivered-To: mailing list commits@beam.apache.org Received: (qmail 77299 invoked by uid 99); 9 Oct 2017 21:49:05 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd1-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 09 Oct 2017 21:49:05 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd1-us-west.apache.org (ASF Mail Server at spamd1-us-west.apache.org) with ESMTP id 84A28D6D2E for ; Mon, 9 Oct 2017 21:49:04 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd1-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 1.749 X-Spam-Level: * X-Spam-Status: No, score=1.749 tagged_above=-999 required=6.31 tests=[KAM_LAZY_DOMAIN_SECURITY=1, KAM_LOTSOFHASH=0.25, KAM_NUMSUBJECT=0.5, RP_MATCHES_RCVD=-0.001] autolearn=disabled Received: from mx1-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd1-us-west.apache.org [10.40.0.7]) (amavisd-new, port 10024) with ESMTP id Ae7HUYYyHykK for ; Mon, 9 Oct 2017 21:49:00 +0000 (UTC) Received: from mailrelay1-us-west.apache.org (mailrelay1-us-west.apache.org [209.188.14.139]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with ESMTP id 810E85F4DC for ; Mon, 9 Oct 2017 21:48:59 +0000 (UTC) Received: from jenkins-master.apache.org (unknown [62.210.60.235]) by mailrelay1-us-west.apache.org (ASF Mail Server at mailrelay1-us-west.apache.org) with ESMTP id 679CAE0051 for ; Mon, 9 Oct 2017 21:48:58 +0000 (UTC) Received: from jenkins-master.apache.org (localhost [127.0.0.1]) by jenkins-master.apache.org (ASF Mail Server at jenkins-master.apache.org) with ESMTP id 041B2A0016 for ; Mon, 9 Oct 2017 21:48:54 +0000 (UTC) Date: Mon, 9 Oct 2017 21:48:51 +0000 (UTC) From: Apache Jenkins Server To: commits@beam.apache.org Message-ID: <1147282990.1416.1507585731932.JavaMail.jenkins@jenkins-master.apache.org> Subject: Build failed in Jenkins: beam_PostCommit_Java_ValidatesRunner_Dataflow #4130 MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: quoted-printable X-Instance-Identity: MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEAkqVKZPv7YyHBB3FvWfV7XQehwe/Ga3aadzSNknt8g382X3uN8A3SOQ+Ixq9HxS+ZlN6XR4TECySmSRy2JN5Rx8svxAD0TjtSF9LuU98dD+LniNDP7Lq6gvRFuJhbMHoS0nuTizDZLsK4X8TW5MyV9w+jFbdoZfRE5O/Mse0fkOeL5uoIS/3Vvu/W+x9QSjDkB7CaU56bPFlQjqqJBl3Cn9r34CkXQZYnLb/NjW4vcpw0+TgMUAPTIVEr5BTPZRshz19g7huwg3zANT5HBIZnzV4hsVY9w4JHkceFdKi/ibNnjPjsFs9pm0HSGJ/RDxjIvSTYT02eH4+m1RAYaj2E9QIDAQAB X-Jenkins-Job: beam_PostCommit_Java_ValidatesRunner_Dataflow X-Jenkins-Result: FAILURE archived-at: Mon, 09 Oct 2017 21:49:08 -0000 See Changes: [klk] Fix typo in nightly release script [kirpichov] Fixes TextIO and AvroIO tests of watchForNewFiles [kirpichov] Add @FunctionalInterface annotation to several interfaces ------------------------------------------ [...truncated 21.06 MB...] [INFO] 2017-10-09T21:46:36.557Z: (81796e4cf2df7253): Fusing unzipped copy o= f PAssert$327/GroupGlobally/GroupDummyAndContents/Reify, through flatten , = into producer PAssert$327/GroupGlobally/KeyForDummy/AddKeys/Map [INFO] 2017-10-09T21:46:36.560Z: (81796e4cf2df7589): Fusing consumer PAsser= t$327/GroupGlobally/GroupDummyAndContents/GroupByWindow into PAssert$327/Gr= oupGlobally/GroupDummyAndContents/Read [INFO] 2017-10-09T21:46:36.562Z: (81796e4cf2df78bf): Unzipping flatten s37-= u117 for input s39-reify-value59-c115 [INFO] 2017-10-09T21:46:36.564Z: (81796e4cf2df7bf5): Fusing unzipped copy o= f PAssert$325/GroupGlobally/GroupDummyAndContents/Write, through flatten , = into producer PAssert$325/GroupGlobally/GroupDummyAndContents/Reify [INFO] 2017-10-09T21:46:36.566Z: (81796e4cf2df7f2b): Unzipping flatten s77-= u122 for input s79-reify-value104-c120 [INFO] 2017-10-09T21:46:36.569Z: (81796e4cf2df7261): Fusing unzipped copy o= f PAssert$327/GroupGlobally/GroupDummyAndContents/Write, through flatten , = into producer PAssert$327/GroupGlobally/GroupDummyAndContents/Reify [INFO] 2017-10-09T21:46:36.571Z: (81796e4cf2df7597): Unzipping flatten s57 = for input s52.52 [INFO] 2017-10-09T21:46:36.574Z: (81796e4cf2df78cd): Fusing unzipped copy o= f PAssert$326/GroupGlobally/GroupDummyAndContents/Reify, through flatten , = into producer PAssert$326/GroupGlobally/KeyForDummy/AddKeys/Map [INFO] 2017-10-09T21:46:36.576Z: (81796e4cf2df7c03): Fusing consumer PAsser= t$326/GetPane/Map into PAssert$326/GroupGlobally/ParDo(Concat) [INFO] 2017-10-09T21:46:36.579Z: (81796e4cf2df7f39): Fusing consumer PAsser= t$326/RunChecks into PAssert$326/GetPane/Map [INFO] 2017-10-09T21:46:36.582Z: (81796e4cf2df726f): Unzipping flatten s57-= u131 for input s59-reify-value77-c129 [INFO] 2017-10-09T21:46:36.585Z: (81796e4cf2df75a5): Fusing unzipped copy o= f PAssert$326/GroupGlobally/GroupDummyAndContents/Write, through flatten , = into producer PAssert$326/GroupGlobally/GroupDummyAndContents/Reify [INFO] 2017-10-09T21:46:36.587Z: (81796e4cf2df78db): Fusing consumer PAsser= t$326/VerifyAssertions/ParDo(DefaultConclude) into PAssert$326/RunChecks [INFO] 2017-10-09T21:46:36.590Z: (81796e4cf2df7c11): Fusing consumer PAsser= t$326/GroupGlobally/GroupDummyAndContents/GroupByWindow into PAssert$326/Gr= oupGlobally/GroupDummyAndContents/Read [INFO] 2017-10-09T21:46:36.593Z: (81796e4cf2df7f47): Fusing consumer PAsser= t$326/GroupGlobally/Values/Values/Map into PAssert$326/GroupGlobally/GroupD= ummyAndContents/GroupByWindow [INFO] 2017-10-09T21:46:36.596Z: (81796e4cf2df727d): Fusing consumer PAsser= t$326/GroupGlobally/ParDo(Concat) into PAssert$326/GroupGlobally/Values/Val= ues/Map [INFO] 2017-10-09T21:46:36.598Z: (81796e4cf2df75b3): Fusing consumer Sum/Co= mbine.perKey(SumInts)/GroupByKey/Write into Sum/Combine.perKey(SumInts)/Gro= upByKey/Reify [INFO] 2017-10-09T21:46:36.600Z: (81796e4cf2df78e9): Fusing consumer View.A= sSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Comb= ine.perKey(Singleton)/Combine.GroupedValues into View.AsSingleton/Combine.G= loballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton= )/GroupByKey/Read [INFO] 2017-10-09T21:46:36.604Z: (81796e4cf2df7c1f): Fusing consumer Combin= e.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContex= t)/Combine.GroupedValues into Combine.globally(TestCombineFnWithContext)/Co= mbine.perKey(TestCombineFnWithContext)/GroupByKey/GroupByWindow [INFO] 2017-10-09T21:46:36.606Z: (81796e4cf2df7f55): Fusing consumer PAsser= t$326/GroupGlobally/KeyForDummy/AddKeys/Map into PAssert$326/GroupGlobally/= RewindowActuals/Window.Assign [INFO] 2017-10-09T21:46:36.609Z: (81796e4cf2df728b): Fusing consumer PAsser= t$326/GroupGlobally/RewindowActuals/Window.Assign into PAssert$326/GroupGlo= bally/GatherAllOutputs/Values/Values/Map [INFO] 2017-10-09T21:46:36.611Z: (81796e4cf2df75c1): Fusing consumer PAsser= t$327/GroupGlobally/GatherAllOutputs/Values/Values/Map into PAssert$327/Gro= upGlobally/GatherAllOutputs/GroupByKey/GroupByWindow [INFO] 2017-10-09T21:46:36.614Z: (81796e4cf2df78f7): Fusing consumer PAsser= t$327/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow into PAssert$= 327/GroupGlobally/GatherAllOutputs/GroupByKey/Read [INFO] 2017-10-09T21:46:36.616Z: (81796e4cf2df7c2d): Fusing consumer PAsser= t$327/GroupGlobally/GatherAllOutputs/GroupByKey/Write into PAssert$327/Grou= pGlobally/GatherAllOutputs/GroupByKey/Reify [INFO] 2017-10-09T21:46:36.618Z: (81796e4cf2df7f63): Fusing consumer PAsser= t$327/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map into PAssert$327/= GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows) [INFO] 2017-10-09T21:46:36.621Z: (81796e4cf2df7299): Fusing consumer PAsser= t$327/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows) into = PAssert$327/GroupGlobally/Window.Into()/Window.Assign [INFO] 2017-10-09T21:46:36.623Z: (81796e4cf2df75cf): Fusing consumer Combin= e.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContex= t)/GroupByKey/GroupByWindow into Combine.globally(TestCombineFnWithContext)= /Combine.perKey(TestCombineFnWithContext)/GroupByKey/Read [INFO] 2017-10-09T21:46:36.625Z: (81796e4cf2df7905): Fusing consumer PAsser= t$326/GroupGlobally/GatherAllOutputs/Values/Values/Map into PAssert$326/Gro= upGlobally/GatherAllOutputs/GroupByKey/GroupByWindow [INFO] 2017-10-09T21:46:36.627Z: (81796e4cf2df7c3b): Fusing consumer PAsser= t$326/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow into PAssert$= 326/GroupGlobally/GatherAllOutputs/GroupByKey/Read [INFO] 2017-10-09T21:46:36.630Z: (81796e4cf2df7f71): Fusing consumer View.A= sSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/Batch= ViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/ParDo(UseWindowHashA= sKeyAndWindowAsSortKey) into View.AsSingleton/Combine.GloballyAsSingletonVi= ew/Combine.globally(Singleton)/Values/Values/Map [INFO] 2017-10-09T21:46:36.632Z: (81796e4cf2df72a7): Fusing consumer PAsser= t$325/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign into PAsse= rt$325/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map [INFO] 2017-10-09T21:46:36.635Z: (81796e4cf2df75dd): Fusing consumer View.A= sSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Valu= es/Values/Map into View.AsSingleton/Combine.GloballyAsSingletonView/Combine= .globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Extrac= t [INFO] 2017-10-09T21:46:36.637Z: (81796e4cf2df7913): Fusing consumer PAsser= t$325/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows) into = PAssert$325/GroupGlobally/Window.Into()/Window.Assign [INFO] 2017-10-09T21:46:36.639Z: (81796e4cf2df7c49): Fusing consumer PAsser= t$327/GroupGlobally/Window.Into()/Window.Assign into Combine.globally(TestC= ombineFnWithContext)/Values/Values/Map [INFO] 2017-10-09T21:46:36.642Z: (81796e4cf2df7f7f): Fusing consumer View.A= sSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Comb= ine.perKey(Singleton)/GroupByKey/Write into View.AsSingleton/Combine.Global= lyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Gro= upByKey/Reify [INFO] 2017-10-09T21:46:36.645Z: (81796e4cf2df72b5): Fusing consumer Combin= e.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContex= t)/GroupByKey/Write into Combine.globally(TestCombineFnWithContext)/Combine= .perKey(TestCombineFnWithContext)/GroupByKey/Reify [INFO] 2017-10-09T21:46:36.647Z: (81796e4cf2df75eb): Fusing consumer PAsser= t$326/GroupGlobally/GatherAllOutputs/GroupByKey/Write into PAssert$326/Grou= pGlobally/GatherAllOutputs/GroupByKey/Reify [INFO] 2017-10-09T21:46:36.650Z: (81796e4cf2df7921): Fusing consumer PAsser= t$326/GroupGlobally/GatherAllOutputs/GroupByKey/Reify into PAssert$326/Grou= pGlobally/GatherAllOutputs/Window.Into()/Window.Assign [INFO] 2017-10-09T21:46:36.653Z: (81796e4cf2df7c57): Fusing consumer Combin= e.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContex= t)/GroupByKey/Reify into Combine.globally(TestCombineFnWithContext)/WithKey= s/AddKeys/Map [INFO] 2017-10-09T21:46:36.655Z: (81796e4cf2df7f8d): Fusing consumer PAsser= t$326/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign into PAsse= rt$326/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map [INFO] 2017-10-09T21:46:36.657Z: (81796e4cf2df72c3): Fusing consumer PAsser= t$326/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map into PAssert$326/= GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows) [INFO] 2017-10-09T21:46:36.660Z: (81796e4cf2df75f9): Fusing consumer Combin= e.globally(TestCombineFnWithContext)/WithKeys/AddKeys/Map into Globally Inp= ut Sessions/Window.Assign [INFO] 2017-10-09T21:46:36.662Z: (81796e4cf2df792f): Fusing consumer PAsser= t$326/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows) into = PAssert$326/GroupGlobally/Window.Into()/Window.Assign [INFO] 2017-10-09T21:46:36.664Z: (81796e4cf2df7c65): Fusing consumer Sum/Co= mbine.perKey(SumInts)/GroupByKey+Sum/Combine.perKey(SumInts)/Combine.Groupe= dValues/Partial into Sum/WithKeys/AddKeys/Map [INFO] 2017-10-09T21:46:36.667Z: (81796e4cf2df7f9b): Fusing consumer Combin= e.perKey(TestCombineFnWithContext)/GroupByKey/Reify into PerKey Input Sessi= ons/Window.Assign [INFO] 2017-10-09T21:46:36.671Z: (81796e4cf2df72d1): Fusing consumer View.A= sSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Comb= ine.perKey(Singleton)/GroupByKey/Reify into View.AsSingleton/Combine.Global= lyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Gro= upByKey+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(S= ingleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Partial [INFO] 2017-10-09T21:46:36.676Z: (81796e4cf2df7607): Fusing consumer PAsser= t$326/GroupGlobally/Window.Into()/Window.Assign into Combine.perKey(TestCom= bineFnWithContext)/Combine.GroupedValues [INFO] 2017-10-09T21:46:36.679Z: (81796e4cf2df793d): Fusing consumer Create= .TimestampedValues/ParDo(ConvertTimestamps) into Create.TimestampedValues/C= reate.Values/Read(CreateSource) [INFO] 2017-10-09T21:46:36.682Z: (81796e4cf2df7c73): Fusing consumer Combin= e.perKey(TestCombineFnWithContext)/GroupByKey/Write into Combine.perKey(Tes= tCombineFnWithContext)/GroupByKey/Reify [INFO] 2017-10-09T21:46:36.685Z: (81796e4cf2df7fa9): Fusing consumer Combin= e.perKey(TestCombineFnWithContext)/Combine.GroupedValues into Combine.perKe= y(TestCombineFnWithContext)/GroupByKey/GroupByWindow [INFO] 2017-10-09T21:46:36.688Z: (81796e4cf2df72df): Fusing consumer Sum/Co= mbine.perKey(SumInts)/GroupByKey/Reify into Sum/Combine.perKey(SumInts)/Gro= upByKey+Sum/Combine.perKey(SumInts)/Combine.GroupedValues/Partial [INFO] 2017-10-09T21:46:36.692Z: (81796e4cf2df7615): Fusing consumer Combin= e.perKey(TestCombineFnWithContext)/GroupByKey/GroupByWindow into Combine.pe= rKey(TestCombineFnWithContext)/GroupByKey/Read [INFO] 2017-10-09T21:46:36.695Z: (81796e4cf2df794b): Fusing consumer View.A= sSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Comb= ine.perKey(Singleton)/GroupByKey+View.AsSingleton/Combine.GloballyAsSinglet= onView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.Groupe= dValues/Partial into View.AsSingleton/Combine.GloballyAsSingletonView/Combi= ne.globally(Singleton)/WithKeys/AddKeys/Map [INFO] 2017-10-09T21:46:36.697Z: (81796e4cf2df7c81): Fusing consumer PAsser= t$327/GroupGlobally/KeyForDummy/AddKeys/Map into PAssert$327/GroupGlobally/= RewindowActuals/Window.Assign [INFO] 2017-10-09T21:46:36.700Z: (81796e4cf2df7fb7): Fusing consumer PAsser= t$327/GroupGlobally/RewindowActuals/Window.Assign into PAssert$327/GroupGlo= bally/GatherAllOutputs/Values/Values/Map [INFO] 2017-10-09T21:46:36.703Z: (81796e4cf2df72ed): Fusing consumer PAsser= t$325/GroupGlobally/KeyForDummy/AddKeys/Map into PAssert$325/GroupGlobally/= RewindowActuals/Window.Assign [INFO] 2017-10-09T21:46:36.705Z: (81796e4cf2df7623): Fusing consumer PAsser= t$325/GroupGlobally/RewindowActuals/Window.Assign into PAssert$325/GroupGlo= bally/GatherAllOutputs/Values/Values/Map [INFO] 2017-10-09T21:46:36.707Z: (81796e4cf2df7959): Fusing consumer PAsser= t$325/GroupGlobally/GatherAllOutputs/Values/Values/Map into PAssert$325/Gro= upGlobally/GatherAllOutputs/GroupByKey/GroupByWindow [INFO] 2017-10-09T21:46:36.710Z: (81796e4cf2df7c8f): Fusing consumer PAsser= t$327/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign into PAsse= rt$327/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map [INFO] 2017-10-09T21:46:36.713Z: (81796e4cf2df7fc5): Fusing consumer PAsser= t$325/GroupGlobally/GatherAllOutputs/GroupByKey/Write into PAssert$325/Grou= pGlobally/GatherAllOutputs/GroupByKey/Reify [INFO] 2017-10-09T21:46:36.716Z: (81796e4cf2df72fb): Fusing consumer Sum/Va= lues/Values/Map into Sum/Combine.perKey(SumInts)/Combine.GroupedValues/Extr= act [INFO] 2017-10-09T21:46:36.719Z: (81796e4cf2df7631): Fusing consumer Sum/Co= mbine.perKey(SumInts)/Combine.GroupedValues/Extract into Sum/Combine.perKey= (SumInts)/Combine.GroupedValues [INFO] 2017-10-09T21:46:36.722Z: (81796e4cf2df7967): Fusing consumer Sum/Wi= thKeys/AddKeys/Map into FixedWindows/Window.Assign [INFO] 2017-10-09T21:46:36.725Z: (81796e4cf2df7c9d): Fusing consumer View.A= sSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Comb= ine.perKey(Singleton)/Combine.GroupedValues/Extract into View.AsSingleton/C= ombine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(S= ingleton)/Combine.GroupedValues [INFO] 2017-10-09T21:46:36.727Z: (81796e4cf2df7fd3): Fusing consumer Combin= e.globally(TestCombineFnWithContext)/Values/Values/Map into Combine.globall= y(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/Combin= e.GroupedValues [INFO] 2017-10-09T21:46:36.730Z: (81796e4cf2df7309): Fusing consumer View.A= sSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/ParDo= (IsmRecordForSingularValuePerWindow) into View.AsSingleton/Combine.Globally= AsSingletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindow= HashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortValuesOnly/= Read [INFO] 2017-10-09T21:46:36.732Z: (81796e4cf2df763f): Fusing consumer View.A= sSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/Batch= ViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.G= roupByKeyAndSortValuesOnly/Write into View.AsSingleton/Combine.GloballyAsSi= ngletonView/View.CreatePCollectionView/BatchViewOverrides.GroupByWindowHash= AsKeyAndWindowAsSortKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey) [INFO] 2017-10-09T21:46:36.735Z: (81796e4cf2df7975): Fusing consumer PAsser= t$325/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow into PAssert$= 325/GroupGlobally/GatherAllOutputs/GroupByKey/Read [INFO] 2017-10-09T21:46:36.738Z: (81796e4cf2df7cab): Fusing consumer PAsser= t$327/GroupGlobally/GatherAllOutputs/GroupByKey/Reify into PAssert$327/Grou= pGlobally/GatherAllOutputs/Window.Into()/Window.Assign [INFO] 2017-10-09T21:46:36.740Z: (81796e4cf2df7fe1): Fusing consumer PAsser= t$325/GroupGlobally/GatherAllOutputs/GroupByKey/Reify into PAssert$325/Grou= pGlobally/GatherAllOutputs/Window.Into()/Window.Assign [INFO] 2017-10-09T21:46:36.743Z: (81796e4cf2df7317): Fusing consumer PAsser= t$325/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map into PAssert$325/= GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows) [INFO] 2017-10-09T21:46:36.745Z: (81796e4cf2df764d): Fusing consumer Sum/Co= mbine.perKey(SumInts)/Combine.GroupedValues into Sum/Combine.perKey(SumInts= )/GroupByKey/Read [INFO] 2017-10-09T21:46:36.748Z: (81796e4cf2df7983): Fusing consumer PAsser= t$326/GroupGlobally/GroupDummyAndContents/Reify into PAssert$326/GroupGloba= lly/WindowIntoDummy/Window.Assign [INFO] 2017-10-09T21:46:36.749Z: (81796e4cf2df7cb9): Fusing consumer PAsser= t$325/GroupGlobally/GroupDummyAndContents/Reify into PAssert$325/GroupGloba= lly/WindowIntoDummy/Window.Assign [INFO] 2017-10-09T21:46:36.752Z: (81796e4cf2df7fef): Fusing consumer PAsser= t$327/GroupGlobally/GroupDummyAndContents/Reify into PAssert$327/GroupGloba= lly/WindowIntoDummy/Window.Assign [INFO] 2017-10-09T21:46:36.754Z: (81796e4cf2df7325): Fusing consumer PAsser= t$327/GroupGlobally/GroupDummyAndContents/Write into PAssert$327/GroupGloba= lly/GroupDummyAndContents/Reify [INFO] 2017-10-09T21:46:36.757Z: (81796e4cf2df765b): Fusing consumer PAsser= t$325/GroupGlobally/GroupDummyAndContents/Write into PAssert$325/GroupGloba= lly/GroupDummyAndContents/Reify [INFO] 2017-10-09T21:46:36.759Z: (81796e4cf2df7991): Fusing consumer PAsser= t$326/GroupGlobally/GroupDummyAndContents/Write into PAssert$326/GroupGloba= lly/GroupDummyAndContents/Reify [INFO] 2017-10-09T21:46:36.762Z: (81796e4cf2df7cc7): Fusing consumer PAsser= t$325/GroupGlobally/WindowIntoDummy/Window.Assign into PAssert$325/GroupGlo= bally/Create.Values/Read(CreateSource) [INFO] 2017-10-09T21:46:36.764Z: (81796e4cf2df7ffd): Fusing consumer PAsser= t$326/GroupGlobally/WindowIntoDummy/Window.Assign into PAssert$326/GroupGlo= bally/Create.Values/Read(CreateSource) [INFO] 2017-10-09T21:46:36.767Z: (81796e4cf2df7333): Fusing consumer PAsser= t$327/GroupGlobally/WindowIntoDummy/Window.Assign into PAssert$327/GroupGlo= bally/Create.Values/Read(CreateSource) [INFO] 2017-10-09T21:46:36.781Z: (81796e4cf2df799f): Adding StepResource se= tup and teardown to workflow graph. [INFO] 2017-10-09T21:46:36.954Z: (84505a5cee2dd465): Executing operation Co= mbine.perKey(TestCombineFnWithContext)/GroupByKey/Create [INFO] 2017-10-09T21:46:36.966Z: (2e689d88c7371bec): Executing operation Co= mbine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithCo= ntext)/GroupByKey/Create [INFO] 2017-10-09T21:46:36.971Z: (4d277a79dc32c4a6): Starting 1 workers in = us-central1-f... [INFO] 2017-10-09T21:46:36.978Z: (3818e533f1a99a1a): Executing operation Su= m/Combine.perKey(SumInts)/GroupByKey/Create [INFO] 2017-10-09T21:46:37.071Z: (84505a5cee2dd986): Executing operation Cr= eate.TimestampedValues/Create.Values/Read(CreateSource)+Create.TimestampedV= alues/ParDo(ConvertTimestamps)+PerKey Input Sessions/Window.Assign+Values/V= alues/Map+Globally Input Sessions/Window.Assign+FixedWindows/Window.Assign+= Combine.globally(TestCombineFnWithContext)/WithKeys/AddKeys/Map+Combine.glo= bally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/Gr= oupByKey/Reify+Combine.globally(TestCombineFnWithContext)/Combine.perKey(Te= stCombineFnWithContext)/GroupByKey/Write+Combine.perKey(TestCombineFnWithCo= ntext)/GroupByKey/Reify+Combine.perKey(TestCombineFnWithContext)/GroupByKey= /Write+Sum/WithKeys/AddKeys/Map+Sum/Combine.perKey(SumInts)/GroupByKey+Sum/= Combine.perKey(SumInts)/Combine.GroupedValues/Partial+Sum/Combine.perKey(Su= mInts)/GroupByKey/Reify+Sum/Combine.perKey(SumInts)/GroupByKey/Write [INFO] 2017-10-09T21:46:44.833Z: (e02afb87ad972c9e): Autoscaling: Raised th= e number of workers to 0 based on the rate of progress in the currently run= ning step(s). [INFO] 2017-10-09T21:46:55.329Z: (e02afb87ad972695): Autoscaling: Raised th= e number of workers to 1 based on the rate of progress in the currently run= ning step(s). [INFO] 2017-10-09T21:46:56.247Z: (4f0b830678ff0541): Executing operation PA= ssert$324/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-10-09T21:46:56.266Z: (4f0b830678ff04e0): Executing operation PA= ssert$324/GroupGlobally/GroupDummyAndContents/Read+PAssert$324/GroupGloball= y/GroupDummyAndContents/GroupByWindow+PAssert$324/GroupGlobally/Values/Valu= es/Map+PAssert$324/GroupGlobally/ParDo(Concat)+PAssert$324/GetPane/Map+PAss= ert$324/RunChecks+PAssert$324/VerifyAssertions/ParDo(DefaultConclude) [INFO] 2017-10-09T21:46:57.641Z: (ef64e663c99fb245): Cleaning up. [INFO] 2017-10-09T21:46:57.646Z: (ef64e663c99fb2c9): Stopping worker pool..= . [INFO] 2017-10-09T21:46:57.973Z: (634674dfa98c917): Executing operation PAs= sert$321/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-10-09T21:46:57.997Z: (a13b96a8dda9a175): Executing operation PA= ssert$321/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-10-09T21:46:58.064Z: (634674dfa98c14a): Executing operation PAs= sert$321/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$321/GroupGl= obally/WindowIntoDummy/Window.Assign+PAssert$321/GroupGlobally/GroupDummyAn= dContents/Reify+PAssert$321/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-10-09T21:46:58.082Z: (a13b96a8dda9a2e6): Executing operation PA= ssert$321/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$321/GroupG= lobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$321/GroupGlobally= /GatherAllOutputs/Values/Values/Map+PAssert$321/GroupGlobally/RewindowActua= ls/Window.Assign+PAssert$321/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$= 321/GroupGlobally/GroupDummyAndContents/Reify+PAssert$321/GroupGlobally/Gro= upDummyAndContents/Write [INFO] 2017-10-09T21:47:00.068Z: (e5d5f23c5aff5ede): Executing operation PA= ssert$329/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-10-09T21:47:00.092Z: (21585be0fbe34dce): Executing operation PA= ssert$329/GroupGlobally/GroupDummyAndContents/Read+PAssert$329/GroupGloball= y/GroupDummyAndContents/GroupByWindow+PAssert$329/GroupGlobally/Values/Valu= es/Map+PAssert$329/GroupGlobally/ParDo(Concat)+PAssert$329/GetPane/Map+PAss= ert$329/RunChecks+PAssert$329/VerifyAssertions/ParDo(DefaultConclude) [INFO] 2017-10-09T21:47:01.869Z: (47cb176c41fcd4ba): Executing operation Co= mbine.globally(MeanInts)/View.AsIterable/View.CreatePCollectionView/CreateD= ataflowView [INFO] 2017-10-09T21:47:02.309Z: (634674dfa98c174): Executing operation PAs= sert$321/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-10-09T21:47:02.342Z: (634674dfa98c989): Executing operation PAs= sert$321/GroupGlobally/GroupDummyAndContents/Read+PAssert$321/GroupGlobally= /GroupDummyAndContents/GroupByWindow+PAssert$321/GroupGlobally/Values/Value= s/Map+PAssert$321/GroupGlobally/ParDo(Concat)+PAssert$321/GetPane/Map+PAsse= rt$321/RunChecks+PAssert$321/VerifyAssertions/ParDo(DefaultConclude) [INFO] 2017-10-09T21:47:02.386Z: (a13b96a8dda9adfc): Executing operation PA= ssert$323/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-10-09T21:47:02.413Z: (c20176ac76c22739): Executing operation PA= ssert$323/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-10-09T21:47:02.468Z: (c20176ac76c2270e): Executing operation PA= ssert$323/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$323/GroupG= lobally/WindowIntoDummy/Window.Assign+PAssert$323/GroupGlobally/GroupDummyA= ndContents/Reify+PAssert$323/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-10-09T21:47:02.481Z: (a13b96a8dda9a31f): Executing operation PA= ssert$323/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$323/GroupG= lobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$323/GroupGlobally= /GatherAllOutputs/Values/Values/Map+PAssert$323/GroupGlobally/RewindowActua= ls/Window.Assign+PAssert$323/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$= 323/GroupGlobally/GroupDummyAndContents/Reify+PAssert$323/GroupGlobally/Gro= upDummyAndContents/Write [INFO] 2017-10-09T21:47:02.687Z: (48865561c4748d8d): Executing operation Co= mbine.globally(SumInteger)/Combine.perKeyWithFanout(SumInteger)/PreCombineH= ot/GroupByKey/Close [INFO] 2017-10-09T21:47:02.721Z: (48865561c4748a3c): Executing operation Co= mbine.globally(SumInteger)/Combine.perKeyWithFanout(SumInteger)/PreCombineH= ot/GroupByKey/Read+Combine.globally(SumInteger)/Combine.perKeyWithFanout(Su= mInteger)/PreCombineHot/Combine.GroupedValues+Combine.globally(SumInteger)/= Combine.perKeyWithFanout(SumInteger)/StripNonce/Map+Combine.globally(SumInt= eger)/Combine.perKeyWithFanout(SumInteger)/Window.Remerge/Identity/Map+Comb= ine.globally(SumInteger)/Combine.perKeyWithFanout(SumInteger)/PostCombine/G= roupByKey/Reify+Combine.globally(SumInteger)/Combine.perKeyWithFanout(SumIn= teger)/PostCombine/GroupByKey/Write [INFO] 2017-10-09T21:47:01.969Z: (2549a414b4e9da01): Executing operation Co= mbine.globally(MeanInts)/CreateVoid/Read(CreateSource)+Combine.globally(Mea= nInts)/ProduceDefault+PAssert$331/GroupGlobally/Window.Into()/Window.Assign= +PAssert$331/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows= )+PAssert$331/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$3= 31/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$331/G= roupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$331/GroupGlobally/Ga= therAllOutputs/GroupByKey/Write [INFO] 2017-10-09T21:47:02.000Z: (f71bdd3335f996a5): Cleaning up. [INFO] 2017-10-09T21:47:02.005Z: (f71bdd3335f991b9): Stopping worker pool..= . [INFO] 2017-10-09T21:47:04.706Z: (5d69db5610a8e004): Executing operation Su= m/Combine.perKey(SumInts)/GroupByKey/Close [INFO] 2017-10-09T21:47:04.728Z: (eeeef747b58601ef): Executing operation Vi= ew.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/= Combine.perKey(Singleton)/GroupByKey/Create [INFO] 2017-10-09T21:47:04.748Z: (5d69db5610a8e227): Executing operation PA= ssert$333/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-10-09T21:47:04.805Z: (eeeef747b5860926): Executing operation Su= m/Combine.perKey(SumInts)/GroupByKey/Read+Sum/Combine.perKey(SumInts)/Combi= ne.GroupedValues+Sum/Combine.perKey(SumInts)/Combine.GroupedValues/Extract+= Sum/Values/Values/Map+Sum/View.AsIterable/View.CreatePCollectionView/ParDo(= ToIsmRecordForGlobalWindow)+View.AsSingleton/Combine.GloballyAsSingletonVie= w/Combine.globally(Singleton)/WithKeys/AddKeys/Map+View.AsSingleton/Combine= .GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singlet= on)/GroupByKey+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.glo= bally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Partial+Vi= ew.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/= Combine.perKey(Singleton)/GroupByKey/Reify+View.AsSingleton/Combine.Globall= yAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Grou= pByKey/Write+PAssert$333/GroupGlobally/Window.Into()/Window.Assign+PAssert$= 333/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert= $333/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$333/GroupG= lobally/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$333/GroupGloba= lly/GatherAllOutputs/GroupByKey/Reify+PAssert$333/GroupGlobally/GatherAllOu= tputs/GroupByKey/Write [INFO] 2017-10-09T21:47:05.859Z: (2549a414b4e9df0a): Executing operation PA= ssert$331/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-10-09T21:47:05.877Z: (2549a414b4e9d032): Executing operation PA= ssert$331/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-10-09T21:47:05.963Z: (2549a414b4e9db16): Executing operation PA= ssert$331/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$331/GroupG= lobally/WindowIntoDummy/Window.Assign+PAssert$331/GroupGlobally/GroupDummyA= ndContents/Reify+PAssert$331/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-10-09T21:47:05.974Z: (47cb176c41fcd019): Executing operation PA= ssert$331/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$331/GroupG= lobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$331/GroupGlobally= /GatherAllOutputs/Values/Values/Map+PAssert$331/GroupGlobally/RewindowActua= ls/Window.Assign+PAssert$331/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$= 331/GroupGlobally/GroupDummyAndContents/Reify+PAssert$331/GroupGlobally/Gro= upDummyAndContents/Write [INFO] 2017-10-09T21:47:09.075Z: (a13b96a8dda9ae35): Executing operation PA= ssert$323/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-10-09T21:47:09.091Z: (a13b96a8dda9a7da): Executing operation PA= ssert$323/GroupGlobally/GroupDummyAndContents/Read+PAssert$323/GroupGloball= y/GroupDummyAndContents/GroupByWindow+PAssert$323/GroupGlobally/Values/Valu= es/Map+PAssert$323/GroupGlobally/ParDo(Concat)+PAssert$323/GetPane/Map+PAss= ert$323/RunChecks+PAssert$323/VerifyAssertions/ParDo(DefaultConclude) [INFO] 2017-10-09T21:47:07.916Z: (ea20ccea2e0f3fd8): Autoscaling: Resized w= orker pool from 1 to 0. [INFO] 2017-10-09T21:47:07.919Z: (ea20ccea2e0f3092): Autoscaling: Would fur= ther reduce the number of workers but reached the minimum number allowed fo= r the job. [INFO] 2017-10-09T21:47:09.128Z: (48865561c47483fe): Executing operation Co= mbine.globally(SumInteger)/Combine.perKeyWithFanout(SumInteger)/PostCombine= /GroupByKey/Close [INFO] 2017-10-09T21:47:09.146Z: (48865561c47484c6): Executing operation PA= ssert$328/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-10-09T21:47:09.202Z: (48865561c47486ba): Executing operation Co= mbine.globally(SumInteger)/Combine.perKeyWithFanout(SumInteger)/PostCombine= /GroupByKey/Read+Combine.globally(SumInteger)/Combine.perKeyWithFanout(SumI= nteger)/PostCombine/Combine.GroupedValues+Combine.globally(SumInteger)/Valu= es/Values/Map+ParDo(GetLast)+PAssert$328/GroupGlobally/Window.Into()/Window= .Assign+PAssert$328/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestampsAnd= Windows)+PAssert$328/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PA= ssert$328/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+PAsser= t$328/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$328/GroupGlob= ally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-10-09T21:47:08.841Z: (eeeef747b5860904): Executing operation Su= m/View.AsIterable/View.CreatePCollectionView/CreateDataflowView [INFO] 2017-10-09T21:47:08.893Z: (eeeef747b5860f38): Executing operation Su= m/CreateVoid/Read(CreateSource)+Sum/ProduceDefault+View.AsSingleton/Combine= .GloballyAsSingletonView/Combine.globally(Singleton)/WithKeys/AddKeys/Map+V= iew.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)= /Combine.perKey(Singleton)/GroupByKey+View.AsSingleton/Combine.GloballyAsSi= ngletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.G= roupedValues/Partial+View.AsSingleton/Combine.GloballyAsSingletonView/Combi= ne.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Reify+View.AsSi= ngleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine= .perKey(Singleton)/GroupByKey/Write+PAssert$333/GroupGlobally/Window.Into()= /Window.Assign+PAssert$333/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimest= ampsAndWindows)+PAssert$333/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys= /Map+PAssert$333/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign= +PAssert$333/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$333/Gr= oupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-10-09T21:47:10.794Z: (a8f3e6d9524cfff3): Autoscaling: Resizing = worker pool from 1 to 2. [INFO] 2017-10-09T21:47:12.447Z: (77c7163ced5b58b3): Cleaning up. [INFO] 2017-10-09T21:47:12.451Z: (77c7163ced5b530f): Stopping worker pool..= . [INFO] 2017-10-09T21:47:12.980Z: (5d69db5610a8eed7): Executing operation Vi= ew.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/= Combine.perKey(Singleton)/GroupByKey/Close [INFO] 2017-10-09T21:47:12.999Z: (eeeef747b5860727): Executing operation PA= ssert$333/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-10-09T21:47:13.012Z: (5d69db5610a8ed2f): Executing operation Vi= ew.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/B= atchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrid= es.GroupByKeyAndSortValuesOnly/Create [INFO] 2017-10-09T21:47:13.035Z: (eeeef747b586066f): Executing operation PA= ssert$333/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-10-09T21:47:13.094Z: (eeeef747b5860772): Executing operation Vi= ew.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/= Combine.perKey(Singleton)/GroupByKey/Read+View.AsSingleton/Combine.Globally= AsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combi= ne.GroupedValues+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.g= lobally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Extract+= View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton= )/Values/Values/Map+View.AsSingleton/Combine.GloballyAsSingletonView/View.C= reatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSo= rtKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey)+View.AsSingleton/Combine.= GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.Group= ByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortVal= uesOnly/Write [INFO] 2017-10-09T21:47:13.111Z: (ce96e8e67d875b18): Executing operation PA= ssert$333/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$333/GroupG= lobally/WindowIntoDummy/Window.Assign+PAssert$333/GroupGlobally/GroupDummyA= ndContents/Reify+PAssert$333/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-10-09T21:47:13.128Z: (5d69db5610a8e540): Executing operation PA= ssert$333/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$333/GroupG= lobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$333/GroupGlobally= /GatherAllOutputs/Values/Values/Map+PAssert$333/GroupGlobally/RewindowActua= ls/Window.Assign+PAssert$333/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$= 333/GroupGlobally/GroupDummyAndContents/Reify+PAssert$333/GroupGlobally/Gro= upDummyAndContents/Write [INFO] 2017-10-09T21:47:15.015Z: (48865561c474807c): Executing operation PA= ssert$328/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-10-09T21:47:15.563Z: (2549a414b4e9d91c): Executing operation PA= ssert$332/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-10-09T21:47:15.587Z: (2549a414b4e9d01f): Executing operation PA= ssert$332/GroupGlobally/GroupDummyAndContents/Read+PAssert$332/GroupGloball= y/GroupDummyAndContents/GroupByWindow+PAssert$332/GroupGlobally/Values/Valu= es/Map+PAssert$332/GroupGlobally/ParDo(Concat)+PAssert$332/GetPane/Map+PAss= ert$332/RunChecks+PAssert$332/VerifyAssertions/ParDo(DefaultConclude) [INFO] 2017-10-09T21:47:15.041Z: (940ffcf7d505338): Executing operation PAs= sert$328/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-10-09T21:47:15.097Z: (48865561c4748625): Executing operation PA= ssert$328/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$328/GroupG= lobally/WindowIntoDummy/Window.Assign+PAssert$328/GroupGlobally/GroupDummyA= ndContents/Reify+PAssert$328/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-10-09T21:47:15.118Z: (940ffcf7d505877): Executing operation PAs= sert$328/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$328/GroupGl= obally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$328/GroupGlobally/= GatherAllOutputs/Values/Values/Map+PAssert$328/GroupGlobally/RewindowActual= s/Window.Assign+PAssert$328/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$3= 28/GroupGlobally/GroupDummyAndContents/Reify+PAssert$328/GroupGlobally/Grou= pDummyAndContents/Write [INFO] 2017-10-09T21:47:16.352Z: (3f45a207cd9898fd): Autoscaling: Raised th= e number of workers to 2 based on the rate of progress in the currently run= ning step(s). [INFO] Job 2017-10-09_14_43_47-12406762828826977461 finished with status DO= NE. [INFO] 2017-10-09T21:47:17.439Z: (ff92d284ad653b35): Executing operation PA= ssert$331/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-10-09T21:47:17.457Z: (ff92d284ad6536ba): Executing operation PA= ssert$331/GroupGlobally/GroupDummyAndContents/Read+PAssert$331/GroupGloball= y/GroupDummyAndContents/GroupByWindow+PAssert$331/GroupGlobally/Values/Valu= es/Map+PAssert$331/GroupGlobally/ParDo(Concat)+PAssert$331/GetPane/Map+PAss= ert$331/RunChecks+PAssert$331/VerifyAssertions/ParDo(DefaultConclude) [INFO] Success result for Dataflow job 2017-10-09_14_43_47-1240676282882697= 7461. Found 2 success, 0 failures out of 2 expected assertions. [INFO] 2017-10-09T21:47:20.459Z: (58871228fed4a8c1): Cleaning up. [INFO] 2017-10-09T21:47:20.464Z: (58871228fed4a0d5): Stopping worker pool..= . [INFO] 2017-10-09T21:47:22.683Z: (ce96e8e67d875ab7): Executing operation PA= ssert$333/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-10-09T21:47:22.698Z: (ce96e8e67d875e34): Executing operation PA= ssert$333/GroupGlobally/GroupDummyAndContents/Read+PAssert$333/GroupGloball= y/GroupDummyAndContents/GroupByWindow+PAssert$333/GroupGlobally/Values/Valu= es/Map+PAssert$333/GroupGlobally/ParDo(Concat)+PAssert$333/GetPane/Map+PAss= ert$333/RunChecks+PAssert$333/VerifyAssertions/ParDo(DefaultConclude) [INFO] 2017-10-09T21:47:22.751Z: (48865561c4748b6a): Executing operation PA= ssert$328/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-10-09T21:47:22.772Z: (48865561c4748819): Executing operation PA= ssert$328/GroupGlobally/GroupDummyAndContents/Read+PAssert$328/GroupGloball= y/GroupDummyAndContents/GroupByWindow+PAssert$328/GroupGlobally/Values/Valu= es/Map+PAssert$328/GroupGlobally/ParDo(Concat)+PAssert$328/GetPane/Map+PAss= ert$328/RunChecks+PAssert$328/VerifyAssertions/ParDo(DefaultConclude) [INFO] 2017-10-09T21:47:25.719Z: (615f6dfabba40fa8): Cleaning up. [INFO] 2017-10-09T21:47:25.723Z: (615f6dfabba406c4): Stopping worker pool..= . [INFO] 2017-10-09T21:47:24.595Z: (4b113dd5d919ea7a): Workers have started s= uccessfully. [INFO] 2017-10-09T21:47:24.849Z: (766f386d3f893e3a): Autoscaling: Resized w= orker pool from 1 to 0. [INFO] 2017-10-09T21:47:24.851Z: (766f386d3f893280): Autoscaling: Would fur= ther reduce the number of workers but reached the minimum number allowed fo= r the job. [INFO] 2017-10-09T21:47:24.856Z: (36218e23a8d7cec3): Worker pool stopped. [INFO] 2017-10-09T21:47:32.528Z: (eeeef747b58601d4): Executing operation Vi= ew.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/B= atchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrid= es.GroupByKeyAndSortValuesOnly/Close [INFO] 2017-10-09T21:47:32.544Z: (eeeef747b5860b33): Executing operation Vi= ew.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/B= atchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrid= es.GroupByKeyAndSortValuesOnly/Read+View.AsSingleton/Combine.GloballyAsSing= letonView/View.CreatePCollectionView/ParDo(IsmRecordForSingularValuePerWind= ow) [INFO] Job 2017-10-09_14_44_04-15577214043146081346 finished with status DO= NE. [INFO] Success result for Dataflow job 2017-10-09_14_44_04-1557721404314608= 1346. Found 2 success, 0 failures out of 2 expected assertions. [INFO] 2017-10-09T21:47:41.594Z: (eeeef747b586036d): Executing operation Vi= ew.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/C= reateDataflowView [INFO] 2017-10-09T21:47:41.685Z: (eeeef747b58604bb): Executing operation Co= mbine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithCo= ntext)/GroupByKey/Create [INFO] 2017-10-09T21:47:41.694Z: (ce96e8e67d875006): Executing operation Co= mbine.perKey(TestCombineFnWithContext)/GroupByKey/Create [INFO] 2017-10-09T21:47:41.780Z: (ce96e8e67d87569f): Executing operation Co= mbine.perKey(TestCombineFnWithContext)/GroupByKey+Combine.perKey(TestCombin= eFnWithContext)/Combine.GroupedValues/Partial+Combine.perKey(TestCombineFnW= ithContext)/GroupByKey/Reify+Combine.perKey(TestCombineFnWithContext)/Group= ByKey/Write [INFO] 2017-10-09T21:47:41.801Z: (eeeef747b586044e): Executing operation Co= mbine.globally(TestCombineFnWithContext)/WithKeys/AddKeys/Map+Combine.globa= lly(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/Grou= pByKey+Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombin= eFnWithContext)/Combine.GroupedValues/Partial+Combine.globally(TestCombineF= nWithContext)/Combine.perKey(TestCombineFnWithContext)/GroupByKey/Reify+Com= bine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithCon= text)/GroupByKey/Write [INFO] 2017-10-09T21:47:43.819Z: (ce96e8e67d875bee): Executing operation Co= mbine.perKey(TestCombineFnWithContext)/GroupByKey/Close [INFO] 2017-10-09T21:47:43.842Z: (ce96e8e67d8756c6): Executing operation PA= ssert$334/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-10-09T21:47:43.891Z: (ce96e8e67d8759e2): Executing operation Co= mbine.perKey(TestCombineFnWithContext)/GroupByKey/Read+Combine.perKey(TestC= ombineFnWithContext)/Combine.GroupedValues+Combine.perKey(TestCombineFnWith= Context)/Combine.GroupedValues/Extract+PAssert$334/GroupGlobally/Window.Int= o()/Window.Assign+PAssert$334/GroupGlobally/GatherAllOutputs/ParDo(ReifyTim= estampsAndWindows)+PAssert$334/GroupGlobally/GatherAllOutputs/WithKeys/AddK= eys/Map+PAssert$334/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Ass= ign+PAssert$334/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$334= /GroupGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-10-09T21:47:44.944Z: (ce96e8e67d875542): Executing operation PA= ssert$334/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-10-09T21:47:44.963Z: (ce96e8e67d87501a): Executing operation PA= ssert$334/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-10-09T21:47:45.005Z: (ce96e8e67d875336): Executing operation PA= ssert$334/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$334/GroupG= lobally/WindowIntoDummy/Window.Assign+PAssert$334/GroupGlobally/GroupDummyA= ndContents/Reify+PAssert$334/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-10-09T21:47:45.016Z: (8c98cac1cc419c83): Executing operation PA= ssert$334/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$334/GroupG= lobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$334/GroupGlobally= /GatherAllOutputs/Values/Values/Map+PAssert$334/GroupGlobally/RewindowActua= ls/Window.Assign+PAssert$334/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$= 334/GroupGlobally/GroupDummyAndContents/Reify+PAssert$334/GroupGlobally/Gro= upDummyAndContents/Write [INFO] 2017-10-09T21:47:46.662Z: (eeeef747b586059c): Executing operation Co= mbine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithCo= ntext)/GroupByKey/Close [INFO] 2017-10-09T21:47:46.676Z: (eeeef747b58604e4): Executing operation PA= ssert$335/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-10-09T21:47:46.726Z: (eeeef747b5860b18): Executing operation Co= mbine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithCo= ntext)/GroupByKey/Read+Combine.globally(TestCombineFnWithContext)/Combine.p= erKey(TestCombineFnWithContext)/Combine.GroupedValues+Combine.globally(Test= CombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/Combine.Grou= pedValues/Extract+Combine.globally(TestCombineFnWithContext)/Values/Values/= Map+PAssert$335/GroupGlobally/Window.Into()/Window.Assign+PAssert$335/Group= Globally/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$335/Grou= pGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$335/GroupGlobally/G= atherAllOutputs/Window.Into()/Window.Assign+PAssert$335/GroupGlobally/Gathe= rAllOutputs/GroupByKey/Reify+PAssert$335/GroupGlobally/GatherAllOutputs/Gro= upByKey/Write [INFO] 2017-10-09T21:47:47.823Z: (eeeef747b5860838): Executing operation PA= ssert$335/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-10-09T21:47:47.876Z: (eeeef747b5860780): Executing operation PA= ssert$335/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-10-09T21:47:47.926Z: (eeeef747b5860db4): Executing operation PA= ssert$335/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$335/GroupG= lobally/WindowIntoDummy/Window.Assign+PAssert$335/GroupGlobally/GroupDummyA= ndContents/Reify+PAssert$335/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-10-09T21:47:47.940Z: (5d69db5610a8ec7d): Executing operation PA= ssert$335/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$335/GroupG= lobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$335/GroupGlobally= /GatherAllOutputs/Values/Values/Map+PAssert$335/GroupGlobally/RewindowActua= ls/Window.Assign+PAssert$335/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$= 335/GroupGlobally/GroupDummyAndContents/Reify+PAssert$335/GroupGlobally/Gro= upDummyAndContents/Write [INFO] 2017-10-09T21:47:49.317Z: (d13272e217de526e): Autoscaling: Resized w= orker pool from 1 to 0. [INFO] 2017-10-09T21:47:49.319Z: (d13272e217de57a0): Autoscaling: Would fur= ther reduce the number of workers but reached the minimum number allowed fo= r the job. [INFO] 2017-10-09T21:47:50.350Z: (84505a5cee2dd8ab): Executing operation Su= m/Combine.perKey(SumInts)/GroupByKey/Close [INFO] 2017-10-09T21:47:50.369Z: (44a651d701e683ef): Executing operation Co= mbine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithCo= ntext)/GroupByKey/Close [INFO] 2017-10-09T21:47:50.383Z: (84505a5cee2dd928): Executing operation Co= mbine.perKey(TestCombineFnWithContext)/GroupByKey/Close [INFO] 2017-10-09T21:47:50.401Z: (2e689d88c7371e42): Executing operation Vi= ew.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/= Combine.perKey(Singleton)/GroupByKey/Create [INFO] 2017-10-09T21:47:50.419Z: (84505a5cee2dd7d0): Executing operation PA= ssert$325/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-10-09T21:47:50.485Z: (84505a5cee2ddc74): Executing operation Su= m/Combine.perKey(SumInts)/GroupByKey/Read+Sum/Combine.perKey(SumInts)/Combi= ne.GroupedValues+Sum/Combine.perKey(SumInts)/Combine.GroupedValues/Extract+= Sum/Values/Values/Map+PAssert$325/GroupGlobally/Window.Into()/Window.Assign= +View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleto= n)/WithKeys/AddKeys/Map+PAssert$325/GroupGlobally/GatherAllOutputs/ParDo(Re= ifyTimestampsAndWindows)+View.AsSingleton/Combine.GloballyAsSingletonView/C= ombine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey+View.AsSing= leton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.p= erKey(Singleton)/Combine.GroupedValues/Partial+View.AsSingleton/Combine.Glo= ballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/= GroupByKey/Reify+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.g= lobally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Write+PAssert$325/G= roupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$325/GroupGloball= y/GatherAllOutputs/Window.Into()/Window.Assign+PAssert$325/GroupGlobally/Ga= therAllOutputs/GroupByKey/Reify+PAssert$325/GroupGlobally/GatherAllOutputs/= GroupByKey/Write [INFO] 2017-10-09T21:47:50.079Z: (5d69db5610a8e0c3): Executing operation PA= ssert$335/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-10-09T21:47:50.094Z: (5d69db5610a8eb50): Executing operation PA= ssert$335/GroupGlobally/GroupDummyAndContents/Read+PAssert$335/GroupGloball= y/GroupDummyAndContents/GroupByWindow+PAssert$335/GroupGlobally/Values/Valu= es/Map+PAssert$335/GroupGlobally/ParDo(Concat)+PAssert$335/GetPane/Map+PAss= ert$335/RunChecks+PAssert$335/VerifyAssertions/ParDo(DefaultConclude) [INFO] 2017-10-09T21:47:52.393Z: (ce96e8e67d8752d5): Executing operation PA= ssert$334/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-10-09T21:47:52.412Z: (ce96e8e67d875652): Executing operation PA= ssert$334/GroupGlobally/GroupDummyAndContents/Read+PAssert$334/GroupGloball= y/GroupDummyAndContents/GroupByWindow+PAssert$334/GroupGlobally/Values/Valu= es/Map+PAssert$334/GroupGlobally/ParDo(Concat)+PAssert$334/GetPane/Map+PAss= ert$334/RunChecks+PAssert$334/VerifyAssertions/ParDo(DefaultConclude) [INFO] Job 2017-10-09_14_44_23-9008148160174578587 finished with status DON= E. [INFO] Success result for Dataflow job 2017-10-09_14_44_23-9008148160174578= 587. Found 3 success, 0 failures out of 3 expected assertions. [INFO] 2017-10-09T21:47:55.945Z: (35854c58b1bc8230): Cleaning up. [INFO] 2017-10-09T21:47:55.950Z: (35854c58b1bc8284): Stopping worker pool..= . [INFO] 2017-10-09T21:47:59.891Z: (4b7a43066729de46): Autoscaling: Resized w= orker pool from 2 to 0. [INFO] 2017-10-09T21:47:59.893Z: (4b7a43066729dd84): Autoscaling: Would fur= ther reduce the number of workers but reached the minimum number allowed fo= r the job. [INFO] 2017-10-09T21:47:59.400Z: (84505a5cee2dd118): Executing operation Vi= ew.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/= Combine.perKey(Singleton)/GroupByKey/Close [INFO] 2017-10-09T21:47:59.410Z: (2e689d88c7371d3b): Executing operation PA= ssert$325/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-10-09T21:47:59.421Z: (84505a5cee2ddfc0): Executing operation Vi= ew.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/B= atchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrid= es.GroupByKeyAndSortValuesOnly/Create [INFO] 2017-10-09T21:47:59.432Z: (2e689d88c73718b3): Executing operation PA= ssert$325/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-10-09T21:47:59.465Z: (84505a5cee2dd28f): Executing operation Vi= ew.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/= Combine.perKey(Singleton)/GroupByKey/Read+View.AsSingleton/Combine.Globally= AsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combi= ne.GroupedValues+View.AsSingleton/Combine.GloballyAsSingletonView/Combine.g= lobally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Extract+= View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton= )/Values/Values/Map+View.AsSingleton/Combine.GloballyAsSingletonView/View.C= reatePCollectionView/BatchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSo= rtKey/ParDo(UseWindowHashAsKeyAndWindowAsSortKey)+View.AsSingleton/Combine.= GloballyAsSingletonView/View.CreatePCollectionView/BatchViewOverrides.Group= ByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrides.GroupByKeyAndSortVal= uesOnly/Write [INFO] 2017-10-09T21:47:59.490Z: (2e689d88c7371d5f): Executing operation PA= ssert$325/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$325/GroupG= lobally/WindowIntoDummy/Window.Assign+PAssert$325/GroupGlobally/GroupDummyA= ndContents/Reify+PAssert$325/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-10-09T21:47:59.504Z: (44a651d701e68227): Executing operation PA= ssert$325/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$325/GroupG= lobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$325/GroupGlobally= /GatherAllOutputs/Values/Values/Map+PAssert$325/GroupGlobally/RewindowActua= ls/Window.Assign+PAssert$325/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$= 325/GroupGlobally/GroupDummyAndContents/Reify+PAssert$325/GroupGlobally/Gro= upDummyAndContents/Write [INFO] 2017-10-09T21:48:02.157Z: (a5ab100c94b3247b): Autoscaling: Resized w= orker pool from 1 to 0. [INFO] 2017-10-09T21:48:02.159Z: (a5ab100c94b320f9): Autoscaling: Would fur= ther reduce the number of workers but reached the minimum number allowed fo= r the job. [INFO] Job 2017-10-09_14_45_27-2042731979221376495 finished with status DON= E. [INFO] Success result for Dataflow job 2017-10-09_14_45_27-2042731979221376= 495. Found 2 success, 0 failures out of 2 expected assertions. [INFO] Job 2017-10-09_14_44_12-18150867826303806192 finished with status DO= NE. [INFO] Success result for Dataflow job 2017-10-09_14_44_12-1815086782630380= 6192. Found 3 success, 0 failures out of 3 expected assertions. [INFO] 2017-10-09T21:48:11.440Z: (84505a5cee2dd389): Executing operation Vi= ew.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/B= atchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrid= es.GroupByKeyAndSortValuesOnly/Close [INFO] 2017-10-09T21:48:11.460Z: (84505a5cee2dd05c): Executing operation Vi= ew.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/B= atchViewOverrides.GroupByWindowHashAsKeyAndWindowAsSortKey/BatchViewOverrid= es.GroupByKeyAndSortValuesOnly/Read+View.AsSingleton/Combine.GloballyAsSing= letonView/View.CreatePCollectionView/ParDo(IsmRecordForSingularValuePerWind= ow) [INFO] 2017-10-09T21:48:12.533Z: (44a651d701e68625): Executing operation PA= ssert$325/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-10-09T21:48:12.555Z: (44a651d701e68896): Executing operation PA= ssert$325/GroupGlobally/GroupDummyAndContents/Read+PAssert$325/GroupGloball= y/GroupDummyAndContents/GroupByWindow+PAssert$325/GroupGlobally/Values/Valu= es/Map+PAssert$325/GroupGlobally/ParDo(Concat)+PAssert$325/GetPane/Map+PAss= ert$325/RunChecks+PAssert$325/VerifyAssertions/ParDo(DefaultConclude) [INFO] 2017-10-09T21:48:23.696Z: (84505a5cee2dd59c): Executing operation Vi= ew.AsSingleton/Combine.GloballyAsSingletonView/View.CreatePCollectionView/C= reateDataflowView [INFO] 2017-10-09T21:48:23.786Z: (44a651d701e689e8): Executing operation PA= ssert$327/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-10-09T21:48:23.816Z: (84505a5cee2dddea): Executing operation PA= ssert$326/GroupGlobally/GatherAllOutputs/GroupByKey/Create [INFO] 2017-10-09T21:48:23.904Z: (44a651d701e68574): Executing operation Co= mbine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithCo= ntext)/GroupByKey/Read+Combine.globally(TestCombineFnWithContext)/Combine.p= erKey(TestCombineFnWithContext)/GroupByKey/GroupByWindow+Combine.globally(T= estCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/Combine.G= roupedValues+Combine.globally(TestCombineFnWithContext)/Values/Values/Map+P= Assert$327/GroupGlobally/Window.Into()/Window.Assign+PAssert$327/GroupGloba= lly/GatherAllOutputs/ParDo(ReifyTimestampsAndWindows)+PAssert$327/GroupGlob= ally/GatherAllOutputs/WithKeys/AddKeys/Map+PAssert$327/GroupGlobally/Gather= AllOutputs/Window.Into()/Window.Assign+PAssert$327/GroupGlobally/GatherAllO= utputs/GroupByKey/Reify+PAssert$327/GroupGlobally/GatherAllOutputs/GroupByK= ey/Write [INFO] 2017-10-09T21:48:23.936Z: (2e689d88c7371fc7): Executing operation Co= mbine.perKey(TestCombineFnWithContext)/GroupByKey/Read+Combine.perKey(TestC= ombineFnWithContext)/GroupByKey/GroupByWindow+Combine.perKey(TestCombineFnW= ithContext)/Combine.GroupedValues+PAssert$326/GroupGlobally/Window.Into()/W= indow.Assign+PAssert$326/GroupGlobally/GatherAllOutputs/ParDo(ReifyTimestam= psAndWindows)+PAssert$326/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/M= ap+PAssert$326/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign+P= Assert$326/GroupGlobally/GatherAllOutputs/GroupByKey/Reify+PAssert$326/Grou= pGlobally/GatherAllOutputs/GroupByKey/Write [INFO] 2017-10-09T21:48:27.237Z: (84505a5cee2dd211): Executing operation PA= ssert$327/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-10-09T21:48:27.283Z: (84505a5cee2dd0b9): Executing operation PA= ssert$327/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-10-09T21:48:27.364Z: (84505a5cee2dd4e0): Executing operation PA= ssert$327/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$327/GroupG= lobally/WindowIntoDummy/Window.Assign+PAssert$327/GroupGlobally/GroupDummyA= ndContents/Reify+PAssert$327/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-10-09T21:48:27.394Z: (44a651d701e685e2): Executing operation PA= ssert$327/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$327/GroupG= lobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$327/GroupGlobally= /GatherAllOutputs/Values/Values/Map+PAssert$327/GroupGlobally/RewindowActua= ls/Window.Assign+PAssert$327/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$= 327/GroupGlobally/GroupDummyAndContents/Reify+PAssert$327/GroupGlobally/Gro= upDummyAndContents/Write [INFO] 2017-10-09T21:48:31.629Z: (2e689d88c737159e): Executing operation PA= ssert$326/GroupGlobally/GatherAllOutputs/GroupByKey/Close [INFO] 2017-10-09T21:48:31.660Z: (3818e533f1a993e7): Executing operation PA= ssert$326/GroupGlobally/GroupDummyAndContents/Create [INFO] 2017-10-09T21:48:31.733Z: (3818e533f1a99ba3): Executing operation PA= ssert$326/GroupGlobally/Create.Values/Read(CreateSource)+PAssert$326/GroupG= lobally/WindowIntoDummy/Window.Assign+PAssert$326/GroupGlobally/GroupDummyA= ndContents/Reify+PAssert$326/GroupGlobally/GroupDummyAndContents/Write [INFO] 2017-10-09T21:48:31.764Z: (44a651d701e689e0): Executing operation PA= ssert$326/GroupGlobally/GatherAllOutputs/GroupByKey/Read+PAssert$326/GroupG= lobally/GatherAllOutputs/GroupByKey/GroupByWindow+PAssert$326/GroupGlobally= /GatherAllOutputs/Values/Values/Map+PAssert$326/GroupGlobally/RewindowActua= ls/Window.Assign+PAssert$326/GroupGlobally/KeyForDummy/AddKeys/Map+PAssert$= 326/GroupGlobally/GroupDummyAndContents/Reify+PAssert$326/GroupGlobally/Gro= upDummyAndContents/Write [INFO] 2017-10-09T21:48:31.588Z: (9eee20d5e7f1796e): Autoscaling: Resized w= orker pool from 2 to 0. [INFO] 2017-10-09T21:48:31.590Z: (9eee20d5e7f170f8): Autoscaling: Would fur= ther reduce the number of workers but reached the minimum number allowed fo= r the job. [INFO] 2017-10-09T21:48:31.204Z: (3a1d4882e78aee0f): Autoscaling: Resized w= orker pool from 1 to 0. [INFO] 2017-10-09T21:48:31.205Z: (3a1d4882e78ae679): Autoscaling: Would fur= ther reduce the number of workers but reached the minimum number allowed fo= r the job. [INFO] 2017-10-09T21:48:31.794Z: (84505a5cee2ddcb1): Executing operation PA= ssert$327/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-10-09T21:48:31.838Z: (84505a5cee2dd984): Executing operation PA= ssert$327/GroupGlobally/GroupDummyAndContents/Read+PAssert$327/GroupGloball= y/GroupDummyAndContents/GroupByWindow+PAssert$327/GroupGlobally/Values/Valu= es/Map+PAssert$327/GroupGlobally/ParDo(Concat)+PAssert$327/GetPane/Map+PAss= ert$327/RunChecks+PAssert$327/VerifyAssertions/ParDo(DefaultConclude) [INFO] 2017-10-09T21:48:36.481Z: (44a651d701e68dde): Executing operation PA= ssert$326/GroupGlobally/GroupDummyAndContents/Close [INFO] 2017-10-09T21:48:36.528Z: (44a651d701e6804f): Executing operation PA= ssert$326/GroupGlobally/GroupDummyAndContents/Read+PAssert$326/GroupGloball= y/GroupDummyAndContents/GroupByWindow+PAssert$326/GroupGlobally/Values/Valu= es/Map+PAssert$326/GroupGlobally/ParDo(Concat)+PAssert$326/GetPane/Map+PAss= ert$326/RunChecks+PAssert$326/VerifyAssertions/ParDo(DefaultConclude) [INFO] 2017-10-09T21:48:37.998Z: (81796e4cf2df7019): Cleaning up. [INFO] 2017-10-09T21:48:38.005Z: (81796e4cf2df7685): Stopping worker pool..= . [INFO] Job 2017-10-09_14_45_24-13725055260415002817 finished with status DO= NE. [INFO] Success result for Dataflow job 2017-10-09_14_45_24-1372505526041500= 2817. Found 1 success, 0 failures out of 1 expected assertions. [INFO] Job 2017-10-09_14_45_31-11972494551378497726 finished with status DO= NE. [INFO] Success result for Dataflow job 2017-10-09_14_45_31-1197249455137849= 7726. Found 2 success, 0 failures out of 2 expected assertions. ERROR: Maven JVM terminated unexpectedly with exit code 137 Not sending mail to unregistered user kirpichov@google.com Not sending mail to unregistered user klk@google.com